python mqtt客户端无法接受到blinker订阅的数据

Blinkerpan

我之前自己写了一个python mqtt客户端用来获取blinker上的实时数据，前几天能正常使用的但今天运行接受不到数据，请问是我这有问题还是blinker那服务器有什么变动？import json
import 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()

mmxmmx

我这边看到是用户名密码错误

我对connect方法加一个error事件handler看到的

Blinkerpan

mmxmmx 发表于 2022-3-4 17:02
我这边看到是用户名密码错误

我对connect方法加一个error事件handler看到的

谢谢！我回头再看看。

点灯官方

请参考我们例程