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

fix: 记录掉线日志

This commit is contained in:
caoqianming 2024-06-13 11:33:18 +08:00
parent 0dbecbc439
commit 7741928edc
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mqttc.py
View File

@ -92,13 +92,17 @@ def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage):
if topic == conf.MQTT_TOPIC: if topic == conf.MQTT_TOPIC:
save_items(msg.payload) save_items(msg.payload)
def on_disconnect(mqttc: mqtt.Client, userdata, rc):
logger.error("Disconnected from MQTT broker")
def start_mqtt(): def start_mqtt():
client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2, client_id='hfnf_105') client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2, client_id='hfnf_105')
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.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT) client.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT)
client.loop_forever() client.loop_start()
if __name__ == '__main__': if __name__ == '__main__':