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

update

This commit is contained in:
xyj 2024-01-03 14:05:55 +08:00
parent 672743e531
commit 9cbaef07f4
1 changed files with 6 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
test.py
View File

@ -77,25 +77,17 @@ async def startup(username, device):
def push_stream(username, device): def push_stream(username, device):
MQTT = MQTTClient(broker, port, device, username, username) MQTT = MQTTClient(broker, port, device, username, username)
try:
MQTT.start() MQTT.start()
MQTT.push() MQTT.push()
except Exception as e:
# print(e)
pass
def close_stream(username, device): def close_stream(username, device):
try:
MQTT = MQTTClient(broker, port, device, username, username) MQTT = MQTTClient(broker, port, device, username, username)
MQTT.start() MQTT.start()
MQTT.close() MQTT.close()
except Exception as e:
# print(e)
pass
if __name__ == '__main__': if __name__ == '__main__':
broker = 'mqtt.lihaink.cn' broker = 'mqtt.lihaink.cn'
port = 1883 port = 1883
uvicorn.run(app, host="127.0.0.1", port=8001) uvicorn.run(app, host="127.0.0.1", port=8000)