数据转发流程

概述

数据转发功能用于提供IoTDA与其他第三方以及华为云服务的连接通道，从而实现将设备数据平滑流转至消息中间件、存储、数据分析、业务应用。当前物联网平台支持如下转发方式：

须知：

通过公网进行数据转发流量限制不超过1M/s，超过后消息会直接丢弃。

操作步骤

1. 访问设备接入服务，单击“管理控制台”进入设备接入控制台。选择您的实例，单击实例卡片进入。
2. 选择左侧导航栏的“规则 > 数据转发”，单击页面左上角的“创建规则”。
3. 设置转发数据，然后单击“创建规则”。

   表2 创建规则参数列表

   参数名	参数说明
   规则名称	创建的规则名称。
   规则描述	对该规则的描述。
   数据来源	设备：将操作设备的信息，如设备添加、设备删除、设备更新设置为数据来源。当数据来源选择“设备”时，不支持快速配置。 设备属性：将归属在某个资源空间下的设备上报给平台的属性值设置为数据来源。单击右侧的“快速配置”勾选需要转发的产品、属性、服务等数据。 设备消息：将归属在某个资源空间下的设备上报给平台的消息设置为转发目标。单击右侧的“快速配置”，仅转发指定Topic的数据。选择所属产品，填写Topic名称。您可以使用在产品详情页面自定义的Topic，也可以使用平台预置的Topic。 设备消息状态：将设备和平台之间流转的设备消息状态变更设置为转发目标。设备消息状态详见这里。当数据来源选择“设备消息状态”，不支持快速配置。 设备状态：将归属在某个资源空间下的直连或非直连设备状态变更转发至其他服务。单击“快速配置”，您可以转发设备状态为“在线”、“离线”和“异常”的设备信息到其他服务。物联网平台直连设备状态详见这里。 批量任务：将批量任务状态的数据设置为数据来源。当数据来源选择“批量任务”时，不支持快速配置。 产品：将操作产品的信息，如产品添加、产品删除、产品更新设置为数据来源。当数据来源选择“产品”时，不支持快速配置。 设备异步命令状态：针对LwM2M/CoAP协议的设备，物联网平台支持下发异步命令给设备。将异步命令的状态变更设置为数据来源。物联网平台设备异步命令状态详见这里。当数据来源选择“设备异步命令状态”时，不支持快速配置。 运行日志：将MQTT设备的业务运行日志设置为数据来源。当数据来源选择“运行日志”时，不支持快速配置。
   触发事件	选择数据来源后，对应修改触发事件。
   资源空间	您可以选择单个资源空间或所有资源空间。当选择“所有资源空间”时，不支持快速配置。

4. 单击“设置转发目标”页签，单击“添加”，设置转发目标。

   根据实际情况，选择数据接入服务DIS、分布式消息服务Kafka、对象存储服务OBS、第三方应用服务（HTTP推送）、AMQP推送消息队列、函数工作流服务 （FunctionGraph）、云日志服务（LTS）、云数据库 GeminiDB Influx、云数据库MySQL，，MQTT推送消息队列，设备。

   表3 设置转发目标参数列表

   转发目标	参数说明
   数据接入服务（DIS）	区域：选择转发服务的所在区域，若未授权访问此区域的服务，请根据界面提示，配置云服务访问授权。 通道归属：可以选择自有通道或他人授权。 自有通道：选择需要的通道。若没有通道，请前往DIS服务创建通道。 他人授权：您也可以使用其他用户授权给您的通道。请前往DIS控制台获取通道ID。
   分布式消息服务（Kafka） 说明： 如果选择分布式消息服务，目前只支持转发到Kafka专享版。并且需要开启“kafka自动创建Topic”功能。	区域：选择转发服务的所在区域，若未授权访问此区域的服务，请根据界面提示，配置云服务访问授权。 对接地址：参考连接已开启SASL的Kafka实例获取对接地址。设备接入基础版和标准版实例只支持公网接入专享版Kafka，企业版实例支持私网接入专享版Kafka。 主题：自定义。 SASL认证：若开启SASL认认证，则用户名和密码，填写您在购买kafka实例中输入的SASL用户名和密码。 Kafka安全协议：开启SASL认证后，Kafka安全协议选择您购买的Kafka实例中支持的安全协议。 SASL认证机制：若开启SASL认证后，则SASL认证机制选择您购买的Kafka实例中支持的SASL认证机制。
   对象存储服务（OBS）	区域：选择转发服务的所在区域，若未授权访问此区域的服务，请根据界面提示，配置云服务访问授权。 存储桶：选择需要的桶。若没有，请前往OBS服务创建桶。 参数说明：OBS服务中存储通道文件的自定义目录，多级目录可用(/)进行分隔，不可以斜杠(/)开头或结尾，不能包含两个以上相邻的斜杠(/)。
   第三方应用服务（HTTP推送）	您可以使用HTTP或HTTPS协议进行推送。详细参数填写请参考HTTP/HTTPS服务端订阅。
   AMQP推送消息队列	消息队列：选择需要推送消息的队列。若没有队列，请创建队列。消息队列名限制请参考配置AMQP服务端。
   函数工作流服务 （FunctionGraph） 说明： 目前仅企业版实例和标准版实例支持转发到函数工作流服务，基础版实例不支持。	函数名称：选择需要调用的函数名称（latest版本）。当前不支持跨区域调用函数。若没有函数，请参考这里创建函数。
   云数据库 GeminiDB Influx 说明： 目前仅企业版实例和标准版实例支持转发到GeminiDB Influx，基础版实例不支持。	数据库实例地址：输入GeminiDB Influx实例的连接地址。设备接入企业版实例支持通过内网IP连接GeminiDB Influx，标准版只支持公网连接GeminiDB Influx。详细指导请参考这里。 数据库名称：选择需要的数据库。若没有，请前往GeminiDB Influx服务创建数据库。 访问账户/访问密码：访问InfluxDB实例的控制台获取GeminiDB Influx的账户和密码。详细请参考这里。 表格：输入需要转存的表格（measurement）名称，不存在会自动创建。 转存配置： 转发字段：输入流转数据的属性名。流转数据为json格式，多层级属性名使用“.”分隔，流转数据格式请参考这里。 目标存储字段：输入数据库的列名。
   云数据库 MySQL（RDS） 说明： 目前仅企业版实例和标准版实例支持转发到云数据库 MySQL（RDS），基础版实例不支持。	数据库实例地址：输入RDS实例的连接地址。设备接入企业版实例支持通过内网IP连接RDS，标准版只支持公网连接RDS。详细指导请参考这里。 数据库名称：选择需要的数据库。若没有，请前往RDS服务创建数据库。 访问账户/访问密码：访问RDS实例的控制台获取RDS的账户和密码。详细请参考这里。 SSL：选择是否通过SSL加密方式连接数据库。建议通过SSL方式连接，不通过SSL方式连接可能存在数据传输安全风险。选择通过SSL方式连接时，需要先在数据库实例中设置SSL数据加密。 表格：选择需要转存的表格名称。 转存配置： 转发字段：输入流转数据的属性名。流转数据为json格式，多层级属性名使用“.”分隔，流转数据格式请参考这里。 目标存储字段：选择数据库的列名。
   MQTT推送消息队列	推送Topic：选择需要推送消息的Topic。
   设备	通过MQTT协议实现设备间消息通信，具体参数请参考：设备间消息通信使用说明。

5. 启动规则。

   完成完整的规则定义后，您可以单击“启动规则”，实现数据转发。

   图1 数据转发-启动规则
   

6. 物联网平台提供规则动作转发目标连通性测试功能，具体步骤请参考连通性测试。