python mqtt客户端无法接受到blinker订阅的数据
我之前自己写了一个python mqtt客户端用来获取blinker上的实时数据,前几天能正常使用的但今天运行接受不到数据,请问是我这有问题还是blinker那服务器有什么变动?import jsonimport time
import MySQLdb
import paho.mqtt.client as mqtt
# Client对象构造
MQTTHOST = "broker.diandeng.tech"
MQTTPORT = 1883
mqttClient = mqtt.Client("7DF9D22CCT814C2DJ5ZLB3YQ")
mqttClient.username_pw_set("5zWZPptLbcKAPrqSFRynifVJbS", "XeFBhY82CRZtzNDsQNE34w2wvoaDAavB")
# 连接MQTT服务器
def on_mqtt_connect():
mqttClient.connect(MQTTHOST, MQTTPORT, 60)
mqttClient.loop_start()
print("connected")
# publish 消息
def on_publish(topic, payload, qos):
mqttClient.publish(topic, payload, qos)
# 消息处理函数
def on_message_come(client, userdata, msg):
print(msg.topic + " " + ":" + str(msg.payload))
# subscribe 消息
def on_subscribe():
# 订阅监听自定义Topic
mqttClient.subscribe("/device/C4ABBDA29LQ7FAOK38Z7J3KX/s", 1)
mqttClient.on_message = on_message_come # 消息到来处理函数
def main():
on_mqtt_connect()
# 自定义Topic消息上行
on_subscribe()
while True:
pass
if __name__ == '__main__':
main()
我这边看到是用户名密码错误
我对connect方法加一个error事件handler看到的
mmxmmx 发表于 2022-3-4 17:02
我这边看到是用户名密码错误
我对connect方法加一个error事件handler看到的
谢谢!我回头再看看。 请参考我们例程
页:
[1]