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

update

This commit is contained in:
xyj 2023-12-29 18:05:38 +08:00
parent 3cca058837
commit 395219ff13
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test.py
View File

@ -1,5 +1,6 @@
import asyncio import asyncio
import json import json
import time
import uvicorn import uvicorn
from fastapi import FastAPI from fastapi import FastAPI
@ -22,12 +23,14 @@ class MQTTClient:
def push(self): def push(self):
self.client.publish(self.topic, payload=json.dumps({"msg": "open_led"}, ensure_ascii=False), self.client.publish(self.topic, payload=json.dumps({"msg": "open_led"}, ensure_ascii=False),
qos=0) qos=0)
time.sleep(5)
self.client.publish(self.topic, payload=json.dumps({"msg": "push_stream"}, ensure_ascii=False), self.client.publish(self.topic, payload=json.dumps({"msg": "push_stream"}, ensure_ascii=False),
qos=0) qos=0)
def close(self): def close(self):
self.client.publish(self.topic, payload=json.dumps({"msg": "close_stream"}, ensure_ascii=False), self.client.publish(self.topic, payload=json.dumps({"msg": "close_stream"}, ensure_ascii=False),
qos=0) qos=0)
time.sleep(5)
self.client.publish(self.topic, payload=json.dumps({"msg": "close_led"}, ensure_ascii=False), self.client.publish(self.topic, payload=json.dumps({"msg": "close_led"}, ensure_ascii=False),
qos=0) qos=0)