使用Python Link SDK接入阿里云物联网平台_云平台sdk互联实例

1. 配置开发环境

1.1 安装python3.6或以上版本

可以使用pyenv新建一个python 3.6的虚拟环境。具体操作参考：使用pyenv和pyenv-virtualenv管理python 版本

1.2 环境配置

先激活虚拟环境，然后安装aliyun-iot-linkkit

pip install aliyun-iot-linkkit
1

如果需要离线手动安装，可参考阿里云官方帮助页面

1.3 Demo下载

通过此链接下载Demo文件：获取exmaple示例代码
解压后得到如下文件：

• dynamic_register.py: 一型一密设备动态注册例程
• mqtt_connect_TCP.py: 通过TCP方式建立MQTT连接
• mqtt_connect_TLS.py: 通过TLS加密方式建立MQTT连接
• mqtt_sub_pub_on.py: 展示mqtt订阅，发布，接收消息
• thing_alink.py: 通过透传协议，展示物模型能力，进行属性上报，属性设置，事件上报，服务响应
• tsl.json: thing_alink.py使用的物模型文件，需要替换为你自己产品的
• thing_custom.py: 通过用户自定义协议进行展示属性设置及属性上报
• model_raw.json: thing_custom.py 使用的物模型文件
• data_transfer.js: thing_custom.py 对应云端的数据解析脚本

下文使用tsl.json和 thing_alink.py进行演示。注意tsl.json需要替换为你自己产品的物模型文件。

2. 物模型开发

2.1 新建公共实例产品并添加设备

具体可参考Python Link SDK 快速入门，但是不要看这里的代码，这里的代码只涉及自定义消息发布，属性上报是跑不通的，不要问我为什么知道。

2.2 下载物模型文件

到物联网平台-公共实例，点击右侧对应产品名称的查看，然后点击功能定义标签，点击物模型TSL

然后在弹窗中点击导出模型文件，保存文件，解压后更名为tsl.json，与thing_alink.py放在同一个文件夹中。

说明

• tsl.json默认为utf-8格式，如有修改请确保在保存时格式为utf-8。
• 该设置需要在连接云端之前调用。

2.3 修改代码

替换三元组

在thing_alink.py中，替换你自己设备的三元组。

    def __init__(self):
        self.__linkkit = linkkit.LinkKit(
            host_name="cn-shanghai",
            product_key="a18wP******",
            device_name="LightSwitch",
            device_secret="uwMTmVAMnGGHaAkqmeDY6cHxxB******")
1
2
3
4
5
6

修改产品属性

将在thing_alink.py中产品的属性替换成你自己的。

注：对于布尔型属性，应该使用"mypro":1而不是"mypro":True

属性上报

    prop_data = {
      "abs_speed": 11,
      "power_stage": 10
  }
  self.__linkkit.thing_post_property(prop_data)          
1
2
3
4
5

事件上报

    event_data = {
        "power": 10,
        "power_style": 1
    }
    self.__linkkit.thing_trigger_event(("power_state", event_data))            
1
2
3
4
5

3. 其他py文件调用

在在thing_alink.py中添加：

def conn(self):
        self.__linkkit.connect_async()

def post_event(self):
        time.sleep(3)
         event_data = {
        "power": 10,
        "power_style": 1
    }
        self.__linkkit.thing_trigger_event(("power_state", event_data))  

def post_prop(self):
        prop_data = {
        "abs_speed": 11,
        "power_stage": 10
    }
        self.__linkkit.thing_post_property(prop_data)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

新建一个py文件调用：

import thing_alink

def main():
    custom_thing = thing_alink.CustomerThing()
    custom_thing.conn()
    #上报属性
    custom_thing.post_prop()
    #上报事件
    custom_thing.post_event()

if __name__ == '__main__':
    main()
1
2
3
4
5
6
7
8
9
10
11
12