update
This commit is contained in:
parent
ed2d3023b8
commit
8e27d64b18
24
config.py
24
config.py
|
@ -1,9 +1,9 @@
|
||||||
# 数据库插入类型
|
# 数据库插入类型
|
||||||
import base64
|
import base64
|
||||||
|
|
||||||
rfid_type = ["TEXT", "TEXT", "FLOAT"]
|
rfid_type = ["TEXT", "TEXT", "FLOAT", "INT32"]
|
||||||
air_type = ["TEXT", "FLOAT", "FLOAT"]
|
air_type = ["TEXT", "FLOAT", "FLOAT", "INT32"]
|
||||||
else_type = ["TEXT", "FLOAT"]
|
else_type = ["TEXT", "FLOAT", "INT32"]
|
||||||
dataTypes = {
|
dataTypes = {
|
||||||
0: rfid_type,
|
0: rfid_type,
|
||||||
1: air_type,
|
1: air_type,
|
||||||
|
@ -25,3 +25,21 @@ headers = {
|
||||||
'ContentType': 'application/json',
|
'ContentType': 'application/json',
|
||||||
'Authorization': "Basic " + token
|
'Authorization': "Basic " + token
|
||||||
}
|
}
|
||||||
|
# RFID
|
||||||
|
send1 = {
|
||||||
|
"m": ["cid", "r", "v", "t"],
|
||||||
|
"v": ["abcd", "rfid", 10.62, 0],
|
||||||
|
"l": 63
|
||||||
|
}
|
||||||
|
# 空气
|
||||||
|
send2 = {
|
||||||
|
"m": ["cid", "at", "ah", "t"],
|
||||||
|
"v": ["test2", 10.62, 50.22, 1],
|
||||||
|
"l": 65
|
||||||
|
}
|
||||||
|
# 普通
|
||||||
|
send3 = {
|
||||||
|
"m": ["cid", "v", "t"],
|
||||||
|
"v": ["test1", 10.62, 2],
|
||||||
|
"l": 50
|
||||||
|
}
|
2
main.py
2
main.py
|
@ -126,8 +126,8 @@ async def process_data(request: Request):
|
||||||
return 301
|
return 301
|
||||||
m = payload["m"]
|
m = payload["m"]
|
||||||
v = payload["v"]
|
v = payload["v"]
|
||||||
t = payload["t"]
|
|
||||||
cid = v[0]
|
cid = v[0]
|
||||||
|
t = v[-1]
|
||||||
send_json = {
|
send_json = {
|
||||||
"devices": ["root.farm." + cid],
|
"devices": ["root.farm." + cid],
|
||||||
"timestamps": [int(time.time() * 1000)],
|
"timestamps": [int(time.time() * 1000)],
|
||||||
|
|
Loading…
Reference in New Issue