Сохранение данных MQTT из темы подписки в текстовом файле - PullRequest
Новая
       16

Сохранение данных MQTT из темы подписки в текстовом файле

0 голосов
/ 21 января 2019

Я настраиваюсь на получение данных MQTT из подписанной темы и хочу сохранить данные в текстовом файле.

Я добавил код для сохранения переменной в текстовом файле. Однако это не работает, так как дает мне только переменную, а не ее значение, т.е. не дает мне значения «on_message». Может кто-нибудь, пожалуйста, помогите мне?

Спасибо

Мой код выглядит следующим образом: 

import paho.mqtt.client as mqttClient
import time

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):
    print "Message received: "  + message.payload

Connected = False   #global variable for the state of the connection

broker_address= "192.168.0.6"  #Broker address
port = 1883                         #Broker port
user = "me"                    #Connection username
password = "abcdef"            #Connection password

client = mqttClient.Client("Python")               #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

f = open('/home/pi/test.txt','w')
f.write('on_message')
f.close()



client.connect(broker_address, port=port)          #connect to broker

client.loop_start()        #start the loop

while Connected != True:    #Wait for connection
    time.sleep(0.1)

client.subscribe("home/OpenMQTTGateway/433toMQTT")

try:
    while True:
        time.sleep(1)

except KeyboardInterrupt:
    print "exiting"
    client.disconnect()
    client.loop_stop()

Я пробовал другие попытки, но потерпел неудачу. Я довольно плохо знаком с Python и все еще учусь.

1 Ответ

0 голосов
/ 22 января 2019

Вы должны добавить данные в файл при обратном вызове on_message и, очевидно, должны подключиться, а затем подписаться на тему 

import paho.mqtt.client as mqttClient
import time

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):
    print "Message received: "  + message.payload
    with open('/home/pi/test.txt','a+') as f:
         f.write("Message received: "  + message.payload + "\n")

Connected = False   #global variable for the state of the connection

broker_address= "192.168.0.6"  #Broker address
port = 1883                         #Broker port
user = "me"                    #Connection username
password = "abcdef"            #Connection password

client = mqttClient.Client("Python")               #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("some/topic") #subscribe
client.loop_forever() #then keep listening forever

Теперь, если вы публикуете сообщение в "some / topic", ваш код добавляет данные в файл

...