From 113660ca9996eb062f011e9d2364cb7f1ef92093 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Thu, 13 Jun 2024 12:18:59 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20keepalive=E8=AE=BE=E7=BD=AE=E4=B8=BA5?= =?UTF-8?q?=E5=88=86=E9=92=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mqttc.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mqttc.py b/mqttc.py index 7ec169b..86b9a73 100644 --- a/mqttc.py +++ b/mqttc.py @@ -90,7 +90,7 @@ def on_connect(mqttc: mqtt.Client, userdata, flags, rc, properties): def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage): topic = msg.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): 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_message = on_message 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()