我正在使用Paho连接到我的MQTT-brooker,但是,回调没有按预期工作。我已经阅读了文档,无法理解为什么这些函数没有被注意到。你知道吗
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\u subscribe方法,但是脚本拒绝工作。有人知道为什么回拨没有被解雇吗?你知道吗
程序必须一直运行并从服务器接收消息,当它从服务器得到确认时,它将运行
on_subscribe
。你知道吗你可以用ie
一直运行它
文件:paho-mqtt
相关问题 更多 >
编程相关推荐