利用PYTHON连接阿里云物联网平台一、创建产品与设备二、为产品定义物模型三、建立设备与平台的连接

180 阅读 0 评论 119 点赞

我是靠谱客的博主灵巧老虎，这篇文章主要介绍利用PYTHON连接阿里云物联网平台一、创建产品与设备二、为产品定义物模型三、建立设备与平台的连接，现在分享给大家，希望可以做个参考。

语言：python 3.7

环境：windows 10

实例：公共实例（免费）

阿里云的官方文档只有C语言和Linux环境，因此自我探索出利用PYTHON连接阿里云物联网平台的方法和步骤。

概述 - 阿里云物联网平台 - 阿里云

一、创建产品与设备

二、为产品定义物模型

三、建立设备与平台的连接

1.创建和激活VirtualEnvironments

2.安装Link SDK最新版本

3.一机一密认证连接

一、创建产品与设备

使用物联网平台的第一步是在云端创建产品和对应设备，获取设备证书（ProductKey、DeviceName和DeviceSecret）

创建产品与设备 - 阿里云物联网平台 - 阿里云

以上链接说得十分详细了，不再赘述

二、为产品定义物模型

物联网平台支持为产品定义物模型，将实际产品抽象成由属性、服务、事件所组成的数据模型，便于云端管理和数据交互。产品创建完成后，您可以为它定义物模型，产品下的设备将自动继承物模型内容。

有提示：在中国地域，目前仅华东2（上海）地域开通了公共实例服务。

我问了阿里的程序员，说是不在上海也可以直接用。

为产品定义物模型 - 阿里云物联网平台 - 阿里云

三、建立设备与平台的连接

1.创建和激活VirtualEnvironments

首先安装 Virtualenv。打开命令提示符，输入以下代码：

复制代码

1
pip install virtualenv

安装成功后就可以开始创建虚拟环境。

指定一个你喜欢的目录，Virtualenv 会把这个新的虚拟环境装到你指定目录下。例如我把它装到 D:PyCharm_WorkSpace目录下，并将虚拟环境命名为 blogproject_env（也可以取任何你喜欢的名字）。在命令栏运行如下命令：

复制代码

1
2
virtualenv
D:PyCharm_WorkSpaceblogproject_env

虚拟环境已经创建好了，我们需要激活环境，运行 blogproject_envScripts 目录下的 activate 程序激活它：

复制代码

1
D:PyCharm_WorkSpaceblogproject_envScriptsactivate

可以看到命令提示符前面多了 (blogproject_env)，说明我们已经成功激活了虚拟环境。

2.安装Link SDK最新版本

打开命令提示符，输入以下代码：

复制代码

1
pip install aliyun-iot-linkkit

3.一机一密认证连接

接下来需要用到PyCharm了

按照以上流程安装。

第一次用还需要添加第三方库aliyun-iot-linkkit，办法如下

https://jingyan.baidu.com/article/48b37f8dc107441a6564887e.html

创建新的project的时候记得选择VirtualEnvironments，并添加解释器

接下来启动连接

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
from linkkit import linkkit
#一机一密 认证连接
lk = linkkit.LinkKit(
host_name="cn-shanghai",
product_key="gsf8fx1IxB1",
device_name="device1",
device_secret="7e475324fb0a5977ba77b9176d644668")
lk.config_mqtt(port=1883, protocol="MQTTv311", transport="TCP",
secure="TLS", keep_alive=60, clean_session=True,
max_inflight_message=20, max_queued_message=0,
auto_reconnect_min_sec=1,
auto_reconnect_max_sec=60,
cadata=None)
#回调函数
#设备与物联网平台建立连接后，您可通过on_connect回调函数了解连接结果。连接成功后，如果连接断开，您#可通过on_disconnect回调函数，编写业务场景所需的处理逻辑。
def on_connect(session_flag, rc, userdata):
print("on_connect:%d,rc:%d,userdata:" % (session_flag, rc))
pass
lk.on_connect = on_connect
print(lk.on_connect)
#启动连接
lk.connect_async()
lk.start_worker_loop()
while True:
try:
msg = input()
except KeyboardInterrupt:
sys.exit()
else:
if msg == "1":
lk.disconnect()