阿里云物联网平台–云产品流传

一、功能介绍

• 物联网平台支持将设备相关的指定消息Topic通过云产品流转功能，流转至其他Topic、业务服务器或其他阿里云产品中进行处理、过滤、存储和分析等操作。
• 云产品流转功能通过配置数据流转解析器关联数据源（设备消息）和数据目的，使用解析脚本实现设备消息转发。

• 相关名称解释

  • 解析器：一个规则，把数据源的数据，转给数据目的的哪个topic

  • 数据源：发送放

  • 数据目的：接收方

二、云产品流转配置

1.创建解析器

2.解析器命名

3.创建数据源

• 输入数据源名称和描述，单击确定。

• 数据源名称支持中文、英文字母、日文、数字、下划线（_）和短划线（-），长度为1~30个字符，一个中文及日文占2个字符。

• 本次示例创建的数据源为【mcu】

4.数据源topic

• 在数据源详情页面，单击添加Topic，在弹出对话框中，根据页面提示，选择需要处理的消息Topic，然后单击确定。

• 这里的Topic根据实际需求进行选择，一般是【自定义】或者【物模型数据上报】

• 其余配置根据自己的实际内容选择

• 本次示例选用的是【自定义】

5.创建数据目的

• 本次示例创建的数据目的为【app】

6.关联数据源、数据目的

• 进入刚才创建的解析器，选择刚才创建的数据源【mcu】

• 同理添加数据目的【app】

7.编辑解析器脚本

• 只需要改writeIotTopic后面的内容

• 接收Topic1消息的Topic2，支持以下Topic类型。
  • 非云网关产品和设备：支持自定义Topic和物模型数据下发Topic：/sys/${productKey}/${deviceName}/thing/service/property/set。
  • 云网关产品和设备：支持自定义Topic。
• 源Topic消息转发到目的Topic内，目的Topic必须具备订阅权限，且目的Topic所属设备必须已成功订阅对应目的Topic
• 数据转发目的Topic为自定义Topic：
  • 同一产品下，不同设备之间通信。
  • 不同产品下，两个设备之间通信。
• 本次示例使用的是【自定义的/get】"/****/DHT11_Yun/user/get"

8.启用

三、测试案例

使用MQTTX进行测试

• 先创建【DHT11_Yun】与【DHT11_Test】的连接

• 【DHT11_Yun】的连接订阅/i9aijXXkHe1/DHT11_Yun/user/get

• 在【DHT11_Test】的连接中，以之前数据源中添加的topic为头/i9aijXXkHe1/DHT11_Test/user/update， 发送数据
  • 这里的数据格式建议使用物联网平台的json格式，方便统一解析

{
    "id": "123",
    "version": "1.0",
    "params": {
      "Temp": 15,
      "Humi": 60
    }
}

• 【DHT11_Test】发送后【DHT11_Yun】成功接收

• 如果想接收小程序下发，同样配置，可以自己试一试