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

statistics

This commit is contained in:
xyj 2024-02-20 15:04:51 +08:00
parent 9621df8711
commit c0dd49875d
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
xumu.py
View File

@ -274,13 +274,11 @@ async def message_publish(data):
r = r.json() r = r.json()
res.append(r) res.append(r)
if is_warning(deviceId, v, t): if is_warning(deviceId, v, t):
print(deviceId + "报警")
# 如果是报警数据，则发送到报警数据表 # 如果是报警数据，则发送到报警数据表
send_json = insert_to_warning_sql(deviceId, v, t) send_json = insert_to_warning_sql(deviceId, v, t)
r = requests.post(baseHost + insertUri, headers=headers, json=send_json) r = requests.post(baseHost + insertUri, headers=headers, json=send_json)
r = r.json() r = r.json()
res.append(r) res.append(r)
print(res)
return BaseResponse(data=res) return BaseResponse(data=res)
except Exception as e: except Exception as e:
return BaseResponse(code=500, msg=str(e)) return BaseResponse(code=500, msg=str(e))