开发者社区 > 物联网 > 正文

如何用Python写一个订阅阿里云物联网平台数据的小程序(测试用)

import paho.mqtt.client as mqtt

配置信息

product_key = ""
device_name = ""
device_secret = ""
region_id = "cn-shanghai"
topic = "/sys/k13k3tVfCRE/YBXC1/thing/event/property/post"#.format(product_key, device_name)#可能改

client_id = "python_mqtt_client" # MQTT客户端的唯一ID

连接成功回调函数

def on_connect(client, userdata, flags, rc):
print("Connected with result code " + str(rc))
client.subscribe(topic)

收到消息回调函数

def on_message(client, userdata, msg):
print("Topic: " + msg.topic + " Message: " + str(msg.payload))

创建MQTT客户端

client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, client_id)
client.on_connect = on_connect
client.on_message = on_message

设置用户名和密码

client.username_pw_set(device_name + "&" + device_secret)

连接阿里云物联网平台

client.connect(product_key + ".iot-as-mqtt." + region_id + ".aliyuncs.com", 1883, 60)

开始循环监听

client.loop_forever()

总是报这个错:Connected with result code 4

展开
收起
游客keszef35wa33k 2024-04-16 10:39:38 62 0
1 条回答
写回答
取消 提交回答
  • product_key = ""
    device_name = ""
    device_secret = ""
    这三个省略了

    2024-04-16 10:48:14
    赞同 1 展开评论 打赏

物联网领域前沿技术分享与交流

相关产品

  • 物联网平台
  • 相关电子书

    更多
    美的物联平台的云上实践与应用--- 人机新世代战略下的智能化探索 立即下载
    使用Link Develop 进行物联网一站式开发 立即下载
    阿里云Link物联网平台全链路的一站式开发 立即下载