From d425b65231e3f06d1577543408c661e5e393f2de Mon Sep 17 00:00:00 2001 From: caoqianming Date: Thu, 13 Jun 2024 12:05:07 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=B0=9D=E8=AF=95thread=20save=5Fitems?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mqttc.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mqttc.py b/mqttc.py index 3ae463a..7ec169b 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: - 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): logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}")