基础知识学习参考：
1、使用消息通讯Topic
2、python link SDK
一、环境变量配置
1、python3.6：下载安装
2、安装paho-mqtt 1.4.0版本
pip install paho-mqtt==1.4.0
3、安装安装Link SDK最新版本
pip install aliyun-iot-linkkit
4、下载python ADK demo文件：下载
5、解压pycharm打开
二、MQTT订阅
1、填入了ProductKey、DeviceName等参数信息
2、订阅信息替换
通过lk.to_full_topic(“xxx/xxx”）快速生成一个topic。to_full_topic是一个Topic自动生成接口，在上一步已经填入了ProductKey、DeviceName等参数，该接口调用后将返回一个字符串，其值等同于/YourProductKey/YourDeviceName/xxx/xxx。
3、订阅结果通过on_subscribe_topic通知用户：
lk.on_subscribe_topic = on_subscribe_topic
def on_subscribe_topic(mid, granted_qos, userdata):
print("on_subscribe_topic mid:%d, granted_qos:%s" %
(mid, str(','.join('%s' % it for it in granted_qos))))
pass
granded_qos为订阅Topic列表对应的QoS返回结果，正常值为0或1，128表示订阅失败。
4、接收与处理来自云端的消息，通过on_topic_message()回调告知用户：
lk.on_topic_message = on_topic_message
def on_topic_message(topic, payload, qos, userdata):
print("on_topic_message:" + topic + " payload:" + str(payload) + " qos:" + str(qos))
pass
5、通过物联网平台在线调试测试代码，先运行代码再调试顺序不要错：
输入3，granded_qos为订阅Topic列表对应的QoS返回结果，128表示订阅失败了。
原因是通过lk.to_full_topic(“xxx/xxx”）快速生成的topic缺少前面的sys/
此时我们不使用lk.to_full_topic(“xxx/xxx”）方法生成topic，直接输入正常的topic
运行代码后输入3，granded_qos为订阅Topic列表对应的QoS返回结果，正常值为0或1，这里返回了1就是正常订阅了，通过日志也可以看到成功了。
再次调试
控制台可查看到调试的订阅结果
至此订阅代码调试完成了。
三、MQTT发布
1、比如发布设备属性上报主题
2、发布消息逻辑
（1）通过调用publish_topic()实现将消息发送到云端：
rc, mid = lk.publish_topic(topic, payload)
（2）消息发送后，云端是否成功接收通过on_publish_topic回调通知用户：
lk.on_publish_topic = on_publish_topic
def on_publish_topic(mid, userdata):
print("on_publish_topic mid:%d" % mid)
publish_topic rc返回值为0则表明已经写入到了发送缓冲区，回调on_publish_topic表明publish成功。
（3）代码修改，保证topic正确，消息格式可以从日志中复制
3、运行代码输入5，控制台日志可以看到topic拼接得到正确，rc返回的0
4、日志中确认是否有发布成功日志
至此，订阅/发布代码逻辑都已调通。
