diff --git a/data_upload3.py b/data_upload3.py deleted file mode 100755 index ea89a47..0000000 --- a/data_upload3.py +++ /dev/null @@ -1,43 +0,0 @@ -import os -import subprocess -import time -import paho.mqtt.client as mqtt - -from device import device_name - - -def on_connect(client, userdata, flags, rc): - global times - if rc == 0: - print("连接成功,执行数据推送和本地存储") - client.publish('success', payload='连接成功,执行数据推送和本地存储', qos=0) - # subprocess.Popen(['/usr/bin/bash /home/pi/lot_manager/bash/start_data_upload.sh'], shell=True) - times = 3 - - -def on_disconnect(client, userdata, rc): - print("失败,执行本地存储") - # subprocess.Popen(['/usr/bin/bash /home/pi/lot_manager/bash/stop_data_upload.sh'], shell=True) - -times = 3 - -client = mqtt.Client(client_id=device_name) -client.username_pw_set("demo", "123456") -# Specify callback function -client.on_connect = on_connect -client.on_disconnect = on_disconnect - -# 尝试连接 MQTT 服务器 -while True: - try: - # ceshi-mqtt.lihaink.cn - client.connect('192.168.1.27', 1883) - client.loop_forever() - except Exception as e: - print("Connection failed:", e) - if times == 0: - # 执行本地存储 - on_disconnect(None, None, None) - print("正在尝试重连") - time.sleep(3) - times -= 1