xyj
/
xumu_iotdb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
xyj 2024-01-24 15:46:31 +08:00
parent d255c1b465
commit 90a3636ebd
1 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
main.py
View File

@ -116,32 +116,32 @@ async def process_data(request: Request):
r = await request.body()
print(r)
return 200
try:
data = await request.body()
data = data.decode("utf-8")
data = json.loads(data)
payload = data["payload"]
receive_len = len(payload)
payload = json.loads(payload)
send_len = payload["l"]
if receive_len != send_len:
return 301
m = payload["m"]
v = payload["v"]
t = payload["t"]
cid = v[0]
send_json = {
"devices": ["root.farm." + cid],
"timestamps": [int(time.time() * 1000)],
"measurements_list": [m],
"data_types_list": [dataTypes[t]],
"values_list": [v],
"is_aligned": False
}
r = requests.post(baseHost + insertUri, headers=headers, json=send_json)
return BaseResponse(data=r.json())
except Exception as e:
return BaseResponse(code=500, msg=str(e))
# try:
# data = await request.body()
# data = data.decode("utf-8")
# data = json.loads(data)
# payload = data["payload"]
# receive_len = len(payload)
# payload = json.loads(payload)
# send_len = payload["l"]
# if receive_len != send_len:
# return 301
# m = payload["m"]
# v = payload["v"]
# t = payload["t"]
# cid = v[0]
# send_json = {
# "devices": ["root.farm." + cid],
# "timestamps": [int(time.time() * 1000)],
# "measurements_list": [m],
# "data_types_list": [dataTypes[t]],
# "values_list": [v],
# "is_aligned": False
# }
# r = requests.post(baseHost + insertUri, headers=headers, json=send_json)
# return BaseResponse(data=r.json())
# except Exception as e:
# return BaseResponse(code=500, msg=str(e))
if __name__ == '__main__':