zcdsj
/
mtc
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 尝试thread save_items

This commit is contained in:
caoqianming 2024-06-13 12:05:07 +08:00
parent 0732b1f3e8
commit d425b65231
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mqttc.py
View File

@ -90,7 +90,7 @@ def on_connect(mqttc: mqtt.Client, userdata, flags, rc, properties):
def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage): def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage):
topic = msg.topic topic = msg.topic
if topic == conf.MQTT_TOPIC: if topic == conf.MQTT_TOPIC:
save_items(msg.payload) Thread(target=save_items, args=(msg.payload,), daemon=True).start()
def on_disconnect(mqttc: mqtt.Client, userdata, disconnect_flags, reason_code, properties): def on_disconnect(mqttc: mqtt.Client, userdata, disconnect_flags, reason_code, properties):
logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}") logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}")