基于开源Python MQTT Client连接阿里云IoT-阿里云开发者社区

基于开源Python MQTT Client连接阿里云IoT

2020-04-03 852

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 前面介绍了基于开源JAVA MQTT Client连接阿里云IoT，这里面继续介绍如果使用Python MQTT Client连接阿里云IoT。

作者：俏巴

概述

前面介绍了基于开源JAVA MQTT Client连接阿里云IoT，这里面继续介绍如果使用Python MQTT Client连接阿里云IoT。

操作步骤

1、创建产品和设备

参考：阿里云物联网平台Qucik Start 创建产品和设备部分。

2、建议先使用MQTT.fx完成连接的快速测试及获取连接需要的相关信息，方便后续测试

使用MQTT.fx接入物联网平台

注意：关于认证签名的生成，可以参考签名工具中的js脚本，也可以参考JAVA MQTT Client的示例，Python这里不再单独实现。

3、Python MQTT SDK安装

pip install paho-mqtt

paho-mqtt

4、测试Code

# encoding: utf-8
import paho.mqtt.client as mqtt

# Client对象构造
MQTTHOST = "********.iot-as-mqtt.cn-shanghai.aliyuncs.com"
MQTTPORT = 1883
mqttClient = mqtt.Client("pythondevice2|securemode=3,signmethod=hmacsha1|")
mqttClient.username_pw_set("pythondevice2&********", "5D1090BECB4E4AED75BD5208EA420275********")


# 连接MQTT服务器
def on_mqtt_connect():
    mqttClient.connect(MQTTHOST, MQTTPORT, 60)
    mqttClient.loop_start()

# publish 消息
def on_publish(topic, payload, qos):
    mqttClient.publish(topic, payload, qos)

# 消息处理函数
def on_message_come(lient, userdata, msg):

    print(msg.topic + " " + ":" + str(msg.payload))


# subscribe 消息
def on_subscribe():
    # 订阅监听自定义Topic
    mqttClient.subscribe("/********/pythondevice2/user/update1", 1)
    mqttClient.on_message = on_message_come # 消息到来处理函数


def main():
    on_mqtt_connect()
    # 自定义Topic消息上行
    on_publish("/********/pythondevice2/user/test2", "Hello Python!", 1)
    # 系统属性Topic消息上行
    on_publish("/sys/********/pythondevice2/thing/event/property/post", "{\"method\":\"thing.service.property.set\",\"id\":\"1745506903\",\"params\":{\"Status\":1},\"version\":\"1.0.0\"}", 1)
    on_subscribe()
    while True:
        pass

if __name__ == '__main__':
    main()

5、测试