设计目的

设计开发一个py应用程序，实现对阿里云数据的双向传输和访问。

功能要求和关键问题

环境配置问题

本地程序通过MQTT协议与阿里云相连，首先我们需要下载一个模块，可以使用pip命令进行安装，pip install aliyun-iot-linkkit，如因为下载速度慢而下载失败，可通过命令 + -i + 国内源地址解决。相同的，通过pip3 install pycryptodome安装pycrypto。（aliyun-iot-linkkit是与阿里云物联网平台连接用到的模块，prcryptodome是一种加密算法模块）

本地程序如何连接云上设备

我们需要创建一个阿里云账号，创建一个产品和设备，本地的程序连接这台设备实现数据的上下交换。引用linkkit库和json库，主要通过产品设备基本信息的配置和调用各类回调函数来实现。

云上的数据交互问题

阿里云上的数据交互通过阿里云的规则引擎实现。

界面设计问题

界面设计考虑使用tkinter库实现。

下面将具体的操作过程列一下。

阿里云相关操作

首先注册一个阿里云账号,阿里云是可以用阿里巴巴旗下的应用账号注册绑定的。注册好以后点击页面右上角的“控制台”。

然后鼠标放置右上角的设置图标，在弹出的工具栏的产品与服务中搜索“物联网平台”，开通物联网平台。

依照提示创建产品，输入产品名称，所属品类选择自定义品类，其他选项默认。

接下来添加设备，在创建好的产品下输入设备的名字。创建好设备将productkey,devicename,devicesecret这个三元组复制保存下来，后面会用到。

关于阿里云上的数据交互，相同的我们在同一产品下再创建一个设备，然后在左侧打开规则引擎，然后点击云产品流转，接着我们可以创建规则，输入规则名称，数据格式选择二进制。

查看创建的规则，然后在新的页面编写SQL，字段输入“ * ”，意为不选择直接透析。输入规则联系的两个设备，假设创建了两个设备A，B。A的规则为user/update，转发数据设备为B，B规则为user/get，这就实现了A向B的数据传输，同样的将A和B对调在创建一条规则即可实现AB数据的双向传输。

本地程序

from linkkit import linkkit
import time
import json//连接阿里云
def on_connect(session_flag, rc, userdata):print("on_connect:%d,rc:%d,userdata:" % (session_flag, rc))pass//取消连接阿里云
def on_disconnect(rc, userdata):print("on_disconnect:rc:%d,userdata:" % rc)
def on_subscribe_topic(mid, granted_qos, userdata):#订阅topicprint("on_subscribe_topic mid:%d, granted_qos:%s" %(mid, str(','.join('%s' % it for it in granted_qos))))pass//接收云端的数据
def on_topic_message(topic, payload, qos, userdata):#print("on_topic_message:" + topic + " payload:" + str(payload) + " qos:" + str(qos))//不知道为什么下行的数据是“123”，设备端的接收到的数据却是b:"123"//所以我在这里用了一个切片去处理数据print("阿里云上传回的数值是:",str(payload)[2:-1])pass
//终止订阅云端数据
def on_unsubscribe_topic(mid, userdata):print("on_unsubscribe_topic mid:%d" % mid)pass
//发布消息的结果，判断是否成功调用发布函数
def on_publish_topic(mid, userdata):print("on_publish_topic mid:%d" % mid)
//设置连接参数，方法为“一机一密”型
lk = linkkit.LinkKit(host_name="cn-shanghai",//填自己的host_name，华东地区填cn-shanghaiproduct_key="***",//填自己的product_keydevice_name="***",//填自己的device_namedevice_secret="***")//填自己的device_secret
//注册接收到云端数据的方法
lk.on_connect = on_connect
//注册取消接收到云端数据的方法
lk.on_disconnect = on_disconnect
//注册云端订阅的方法
lk.on_subscribe_topic = on_subscribe_topic
//注册当接受到云端发送的数据的时候的方法
lk.on_topic_message = on_topic_message
//注册向云端发布数据的时候顺便所调用的方法
lk.on_publish_topic = on_publish_topic
//注册取消云端订阅的方法
lk.on_unsubscribe_topic = on_unsubscribe_topic//连接阿里云的函数（异步调用）
lk.connect_async()
//因为他是他是异步调用需要时间所以如果没有这个延时函数的话，他就会出现not in connected state的错误
time.sleep(2)
//订阅这个topic，不需要写prodect_key和device_name
rc, mid = lk.subscribe_topic(lk.to_full_topic("user/get"))
a=input("你想要将什么数值传到阿里云上去？")
//调用数据上传的函数，将string类的a上传到阿里云上去
rc, mid = lk.publish_topic(lk.to_full_topic("user/update"), str(a))

我们可以运行程序，输入一串字符串作为数据上传，然后在阿里云物联网平台上的产品的日志服务里看到数据是否上传以及数据内容是什么，接着可以在设备的Topic中用user/update发布消息，然后将数据传回本地程序。

利用MQTT协议与阿里云数据交互的python程序相关推荐

微信小程序连接物联网（三）:微信小程序远程遥控宿舍开门基于NodeMCU通过MQTT协议连接阿里云物联网平台
索引这是用微信小程序遥控开门的系列文章,具体微信小程序连接物联网的代码在第三章提及. 微信小程序连接物联网(一):初始化ESP8266 NodeMCU 微信小程序连接物联网(二):NodeMCU L ...
树莓派mqtt协议连接阿里云物联网平台，手机端获取数据并控制
树莓派mqtt协议连接阿里云物联网平台(三) 前面树莓派的数据已经上传到云端,可是我的android手机该如何获取树莓派上传的这些数据呢,,困惑了我好几天的疑问,解开的那一刻,真的时拨开云雾见青天啊. ...
Esp8266 进阶之路29【高级篇】百万条消息免费之乐鑫esp8266使用TCP直连模式MQTT协议接入阿里云物联网平台，支持私家服务器对接，支持阿里云规则引擎。（附带Demo）
本系列博客学习由非官方人员半颗心脏潜心所力所写,不做开发板.仅仅做个人技术交流分享,不做任何商业用途.如有不对之处,请留言,本人及时更改. 序号 SDK版本内容链接 1 nonos2.0 搭建 ...
手机控制的esp8266利用mqtt协议接入百度云智能插座
手机控制的esp8266利用mqtt协议接入百度云智能插座 19年的春节,相信大家和我一样都待在家里,利用在家的时间现学现卖,制作了一款手机控制的智能插座,网上资料很多,我在查询资料中发现,esp82 ...
STM32+ESP8266(ESP-12F)物联网温度计-移植paho MQTT协议连接阿里云
STM32+ESP8266(ESP-12F)物联网温度计-移植paho MQTT协议连接阿里云目录 STM32+ESP8266(ESP-12F)物联网温度计-移植paho MQTT协议连接阿里云一 ...
BC26基于MQTT协议的阿里云数据传输
一:MQTT的初始化 1 利用AT+QMTCFG指令为阿里云配置设备信息其后面有五个参数,如果要进行阿里云的设备配置那么第一个参数是固定的一定是"ALIAUTH",第二个参数是W ...
java实现mqtt服务端_基于Swoole使用MQTT协议连接阿里云物联网平台设备实现消息订阅
阿里云物联网平台为设备提供安全可靠的连接通信能力,支撑设备数据采集上云,我们这里认为阿里云物联网平台是 MQTT 服务端,那么我们自己的设备作为客户端,应该如何实现消息订阅? 阿里云没有提供 PHP ...
快速实现主流PLC数据采集并用MQTT协议与阿里云第三方平台数据对接
BL102是一款采集西门子.三菱.欧姆龙.台达.AB.施耐德等各种PLC数据转换为Modbus TCP.OPC UA.MQTT.华为云IoT.亚马逊云IoT.阿里云IoT.金鸽云等协议的网关.支持数据 ...
中移M5311模块MQTT协议连接阿里云物联网平台(干货)
一.准备三元组在阿里云物联网平台新建产品和设备后,平台给每一个设备自动赋予三元组. 二.准备MQTT协议参数新建产品时,阿里云物联网平台会分配一个含productkey的子域名,端口号固定是188 ...

利用MQTT协议与阿里云数据交互的python程序