Обратные вызовы Paho MQTT не запускаются - PullRequest
Новая
       17

Обратные вызовы Paho MQTT не запускаются

0 голосов
/ 01 декабря 2019

Я использую Paho для подключения к своему брокеру MQTT, однако обратные вызовы не работают должным образом. Я следил за документацией и не могу понять, почему функции остаются незамеченными. 

import paho.mqtt.client as mqtt
import mqttUtils as utils

# Subscribe To Topic


def subscribeToTopic(client, topic):
    try:
        result = client.subscribe(topic, 2)
        if result[0] == 0:
            utils.logging.info("Successfuly Subscribed To Topic")
            return 1
    except:
        utils.logging.info("Failed Subscribe Attempt")
        return 0


def on_subscribe(client, userdata, mid, granted_qos):  # subscribe to mqtt broker
    print("Subscribed", userdata)



host = "x"
client = mqtt.Client()
client.connect(host, port=1883, keepalive=60, bind_address="")
# result = utils.connectToMqtt(client,utils.host)
client.on_subscribe = on_subscribe
subscribeResult = subscribeToTopic(client, "test")

Вот мой код, я объявляю метод on_subscribe перед подпиской, но скрипт отказывается работать. Кто-нибудь знает, почему не срабатывают обратные вызовы?

1 Ответ

0 голосов
/ 01 декабря 2019

Программа должна работать все время и получать сообщения от сервера, а когда она получает подтверждение от сервера, она запускается on_subscribe.

Вы можете использовать т.е. 

client.loop_forever()

чтобы запустить его все время 

import paho.mqtt.client as mqtt

def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed", client, userdata, mid, granted_qos)

def on_message(client, userdata, message):
    #print('on_message:', client, userdata, message)
    #print(dir(message))
    print('on_message:', message.payload.decode())

host = "mqtt.eclipse.org"

client = mqtt.Client()
client.connect(host, port=1883, keepalive=60, bind_address="")
client.on_message = on_message
client.on_subscribe = on_subscribe
client.subscribe('temp', 1)

client.loop_forever()

Документ: paho-mqtt

...