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

feat: keepalive设置为5分钟

This commit is contained in:
caoqianming 2024-06-13 12:18:59 +08:00
parent d425b65231
commit 113660ca99
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
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:
Thread(target=save_items, args=(msg.payload,), daemon=True).start() save_items(msg.payload)
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}")
@ -101,7 +101,7 @@ def start_mqtt():
client.on_connect = on_connect client.on_connect = on_connect
client.on_message = on_message client.on_message = on_message
client.on_disconnect = on_disconnect client.on_disconnect = on_disconnect
client.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT) client.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT, keepalive=60*5)
client.loop_forever() client.loop_forever()