通过规则引擎的云产品流转功能,物联网平台可将指定Topic的数据,流转至其他Topic和其他阿里云产品中。本文介绍添加消息Topic作为数据源的具体操作。

背景信息

配置数据流转解析器时,需关联已添加的消息Topic,作为待流转的数据。每个数据源中最多添加1,000个消息Topic。

解析器脚本中可使用获取消息上下文的函数topic(n),获取消息来源的Topic。更多信息,请参见数据流转支持的函数

创建数据源

  1. 登录物联网平台控制台
  2. 实例概览页面,选择目标环境,找到对应的实例,单击实例ID或备注名称。
    重要 目前仅开通企业版实例服务的地域下,执行此步骤。其他地域,请跳过此步骤。地域及实例的支持说明,请参见实例概述
    实例概览
  3. 在左侧导航栏,选择消息转发 > 云产品流转
  4. 云产品流转页面,单击右上角体验新版,进入新版功能页面。
    说明 如果您已执行过此操作,再次进入云产品流转页面,会直接进入新版功能页面。
  5. 单击数据源页签,然后单击创建数据源
  6. 输入数据源名称和描述,单击确定
    数据源名称支持中文、英文字母、日文、数字、下划线(_)和短划线(-),长度为1~30个字符,一个中文及日文占2个字符
    根据页面提示,可直接进入数据源详情页面。您可单击右上角编辑,修改数据源名称和描述。数据源详情
  7. 数据源详情页面,单击添加Topic,在弹出对话框中,根据页面提示,选择需要处理的消息Topic,然后单击确定
    支持的Topic如下:
    重要 对于开源MQTT托管形态产品和设备,及云网关产品和设备,仅支持选择自定义设备状态变化通知设备生命周期变更
    • 对于MQTT协议云网关产品和设备,若选择自定义需手动输入完整具体的Topic。更多说明,请参见消息通信说明
    • 对于JT/T 808协议云网关产品和设备,若选择自定义需手动输入设备所属的厂商ID、设备型号和设备ID。更多说明,请参见消息转发说明
    表 1. Topic说明
    Topic说明相关文档
    自定义流转自定义数据格式消息的Topic,与自定义Topic的格式相同。格式为:/${productKey}/${deviceName}/user/${TopicShortName}

    其中${TopicShortName}为自定义的Topic类,即自定义Topic的后缀。

    支持使用通配符(+)和(#):

    • 全部设备(+):指定产品下所有设备。
    • /user/#:指定设备的所有自定义Topic。
    自定义Topic
    设备状态变化通知流转设备上下线状态变更消息的Topic:/as/mqtt/status/${productKey}/${deviceName}设备上下线状态
    物模型数据上报包含:
    • 流转设备上报属性数据的Topic:/${productKey}/${deviceName}/thing/event/property/post
    • 流转设备上报事件数据的Topic:/${productKey}/${deviceName}/thing/event/${tsl.event.identifier}/post
    • 流转设备批量上报属性数据的Topic:/${productKey}/${deviceName}/thing/property/batch/post
    • 流转设备批量上报事件数据的Topic:/${productKey}/${deviceName}/thing/event/batch/post
    • 流转设备响应云端命令返回消息的Topic:/${productKey}/${deviceName}/thing/downlink/reply/message
    对应设备上报原始数据的Topic如下:
    • 设备上报属性的Topic:/sys/${productKey}/${deviceName}/thing/event/property/post
    • 设备上报事件的Topic:/sys/${productKey}/${deviceName}/thing/event/${tsl.event.identifier}/post/sys/${productKey}/${deviceName}/thing/event/${tsl.functionBlockId}:{tsl.event.identifier}/post
    • 设备批量上报属性、事件数据的Topic:/sys/${productKey}/${deviceName}/thing/event/property/batch/post
    设备生命周期变更流转设备创建、删除、禁用、启用等消息的Topic:/${productKey}/${deviceName}/thing/lifecycle设备生命周期变更
    网关发现子设备上报网关设备特有的Topic:/${productKey}/${deviceName}/thing/list/found,将发现的子设备信息上报给物联网平台,然后进行流转。网关发现子设备
    设备拓扑关系变更网关设备特有Topic:/${productKey}/${deviceName}/thing/topo/lifecycle,流转子设备和网关之间的拓扑关系建立和解除消息的Topic。设备拓扑关系变更
    对应设备上报原始数据的Topic:/sys/${productKey}/${deviceName}/thing/topo/change通知网关拓扑关系变化
    设备标签变更流转设备标签信息变更的Topic:/${productKey}/${deviceName}/thing/deviceinfo/update设备标签变更
    对应设备上报原始数据的Topic:/sys/${productKey}/${deviceName}/thing/deviceinfo/update上报标签信息
    物模型历史数据上报包含:
    • 流转设备上报历史属性数据的Topic:/${productKey}/${deviceName}/thing/event/property/history/post
    • 流转设备上报历史事件数据的Topic:/${productKey}/${deviceName}/thing/event/${tsl.event.identifier}/history/post
    对应设备上报物模型历史数据的Topic:/sys/${productKey}/${deviceName}/thing/event/property/history/post物模型历史数据上报
    OTA升级设备状态通知包含:
    • 流转设备上报OTA升级结果的Topic:/${productKey}/${deviceName}/ota/upgrade
    • 流转设备上报OTA升级进度的Topic:/${productKey}/${deviceName}/ota/progress/post
    对应设备上报升级进度的Topic:/ota/device/progress/${productKey}/${deviceName}设备上报升级进度
    OTA模块版本号上报流转设备上报OTA模块版本号变更的Topic:/${productKey}/${deviceName}/ota/version/postOTA模块版本号变更通知
    对应设备上报OTA模块版本的Topic:/ota/device/inform/${productKey}/${deviceName}设备上报OTA模块版本
    OTA升级批次状态通知物联网平台通知OTA升级批次状态变化的Topic:/${productKey}/${packageId}/${jobId}/ota/job/statusOTA升级批次状态通知
    任务事件包含:
    • 流转设备任务状态通知的Topic:/sys/uid/${uid}/job/${jobId}/lifecycle
    • 流转实例迁移任务状态通知的Topic:/sys/uid/${uid}/distribution/${jobId}/lifecycle
      说明 迁移产品的名称为实例迁移的任务名称。
    孪生节点属性变更流转数字孪生节点属性数据的Topic:/sys/uid/${uid}/digitaltwin/${dtInstanceId}/${nodeId}/property/update数字孪生节点属性变更
  8. 可选:重复上一步操作,可在当前数据源下,添加多个消息Topic。
    添加Topic后,若有业务需求,您也可在数据源详情页面,删除已添加的消息Topic。Topic列表
  9. 可选:重复步骤5~8,添加多个数据源。

后续步骤

添加转发到的数据目的