python订阅mqtt保存到文件中

本是古典何须时尚 2022-11-17 13:41 111阅读 0赞

import paho.mqtt.client as mqttClient
    import time
    
    #要连接的服务器与端口号
    broker_address= "iot.xxx.com"  #Broker address
    port = 1883                         #Broker port
    #要订阅的主题
    subscribe = "/gw/304a2653de19/status"
    #打印还是保存,打印哪种数据
    save2file = True
    jsonorhex = True 
    
    
    def on_connect(client, userdata, flags, rc):
    
        if rc == 0:
            print("Connected to broker")
            global Connected                #Use global variable
            Connected = True                #Signal connection
    
        else:
            print("Connection failed")
    
    def on_message(client, userdata, message):
    
        if save2file :
            with open(r'C:\Users\Administrator\Desktop\mqtt_test.log','a+') as f:
                if jsonorhex : 
                    f.write(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + " " + str(message.payload, encoding='utf-8') + "\n") 
                else : 
                    f.write(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + " " + message.payload.hex().upper() + "\n")
        else :
            if jsonorhex :
                print(time.strftime("%Y-%m-%d %H:%M:%S ", time.localtime()) + " " + str(message.payload, encoding='utf-8') + "\n\n") 
            else : 
                print(time.strftime("%Y-%m-%d %H:%M:%S ", time.localtime()) + " " + message.payload.hex().upper() + "\n\n")
            
    
    Connected = False   #global variable for the state of the connection
    
    #broker_address= "iot.beaconyun.com" #Broker address
    #port = 1883 #Broker port
    #user = "me" #Connection username
    #password = "abcdef" #Connection password
    
    client = mqttClient.Client("clientid1")               #create new instance
    #client.username_pw_set(user, password=password) #set username and password
    client.on_connect= on_connect                      #attach function to callback
    client.on_message= on_message                      #attach function to callback
    client.connect(broker_address,port,60) #connect
    client.subscribe(subscribe) #subscribe
    client.loop_forever() #then keep listening forever

为了保险起见 加一个守护进程

#!/bin/sh
    
    #添加本地执行路径
    export LD_LIBRARY_PATH=./
    
    while true; do
            #启动一个循环，定时检查进程是否存在
            server=`ps aux | grep demo.py | grep -v grep`
            if [ ! "$server" ]; then
                #如果不存在就重新启动
                nohup python3 ./demo.py &
                #启动后沉睡10s
                sleep 10
            fi
            #每次循环沉睡10s
            sleep 5
    done

注意隐藏