设置数据流转规则

通过规则引擎的云产品流转功能，物联网平台可将指定Topic的数据，流转至其他Topic和其他阿里云产品中。本文将为您介绍设置数据流转规则的完整操作步骤，依次是创建规则、编写处理数据的SQL、设置数据流转目的地、设置流转失败的数据转发目的地。

1. 登录物联网平台控制台。
2. 在实例概览页面，找到对应的实例，单击实例进入实例详情页面。
   
3. 在左侧导航栏，选择规则引擎 > 云产品流转。
4. 在云产品流转页，单击创建规则。
5. 填写参数后，单击确认。

   参数	描述
   规则名称	输入规则名称。支持中文、英文字母、日文、数字、下划线（_）和短划线（-），长度为1~30个字符，一个中文或日文占2个字符。
   数据格式	选择该规则处理数据的格式。可选：JSON和二进制。 说明 因数据流转基于Topic处理数据，此处的数据格式需与被处理Topic中的数据格式保持一致。 若选择为二进制，该规则不能处理基础通信Topic、物模型通信Topic的消息，且不能将数据转发至实例内的时序数据存储、时序数据库、表格存储和云数据库RDS版。
   规则描述	规则描述信息。
   资源组	将该规则划归为某个资源组。默认选择账号全部资源，可以选择已创建的资源组。通过资源组管理，可以授予指定RAM用户查看和操作该规则，而未授权的RAM用户则不可以查看和操作该规则。关于资源组，请参见什么是资源组。 注意 该功能目前仅适用于白名单用户。如有需要，请提交工单，提供您的阿里云账号UID，申请成为白名单用户。 规则创建成功后，可以在资源管理控制台变更规则所属的资源组。

6. 规则创建成功后，将跳转到数据流转规则页面。您需编辑处理消息数据的SQL，设置数据转发目的地，和流转失败数据转发目的地。
   1. 单击编写SQL，编写处理消息字段的SQL。

      SQL编写方法，可参见SQL表达式和函数列表。

      参数	描述
      规则查询语句	系统会在这里，根据您设置的字段、Topic和条件自动补充完整规则查询语句。
      字段	指定要处理的消息内容字段，即SQL中SELECT后的内容。 例如，填入deviceName() as deviceName，则表示需筛选出消息中的deviceName字段内容。字段中可使用的函数，请参见函数列表。 说明 基础通信Topic、物模型通信Topic中的数据为Alink JSON格式，流转到规则引擎前，会经过物模型解析，具体说明，请参见数据流转过程。解析后的数据格式，请参见数据格式。编写SQL字段时，需按照解析后的数据格式来编写。
      Topic	选择需要处理的消息来源Topic，即SQL中FROM后的内容。 可选类型如下，其中，规则数据格式是二进制时，仅支持选择自定义。 自定义：指定消息源是自定义Topic时，支持使用通配符（+）和（#）。 全部设备（+）：指定产品下所有设备。 /user/#：指定设备的所有自定义Topic。 自定义Topic说明，请参见自定义Topic。 设备状态变化通知：设备上下线状态变更消息的Topic。 物模型数据上报：设备上报属性和事件信息的Topic。 包括： thing/event/property/post：设备上报属性数据的Topic。 thing/event/${tsl.identityId}/post：设备上报事件数据的Topic。 thing/downlink/reply/message：设备响应云端命令返回消息的Topic。 设备生命周期变更：设备创建、删除、禁用、启用等消息的Topic。 网关发现子设备上报：网关特有Topic。网关将发现的子设备信息上报给物联网平台的Topic。 设备拓扑关系变更：网关特有Topic。上报子设备和网关之间的拓扑关系建立和解除消息的Topic。 设备标签变更：设备上报标签变更的Topic。 物模型历史数据上报：设备上报历史属性和事件的Topic。 OTA升级设备状态通知：设备上报OTA升级状态的Topic。包括： ota/upgrade：设备上报OTA升级结果的Topic。 ota/progress/post：设备上报OTA升级进度的Topic。 OTA模块版本号上报：设备上报OTA模块版本号变更的Topic。 OTA升级批次状态通知：物联网平台通知OTA升级批次状态变化的Topic。 任务事件：设备任务状态通知的Topic。 边缘即插即用消息：物联网边缘计算的透传模式Topic。
      条件	设置规则触发条件，即SQL中WHERE后的内容。

   2. 单击转发数据一栏的添加操作，设置数据转发目的地。数据转发配置的具体示例，请参见数据流转使用示例目录下的具体文档。
      说明 最多可为一个规则创建10个数据转发操作。
      数据转发时，因选择的目的云产品出现异常情况导致转发失败时：

      • 转发到RocketMQ、RDS、TSDB等类型的云产品时，若云产品资源变化导致目的云产品无法访问，系统将停止执行转发，并在规则列表中显示状态为规则异常。您需要重新设置数据转发目的地。
      • 其他异常情况，系统将间隔1秒、3秒、10秒进行3次重试（重试策略可能会调整）。3次重试均失败后，消息会被丢弃。如果您对消息可靠性要求比较高，可以进行：添加错误操作，将重试失败的消息，转发到其他云产品中。
   3. 单击转发错误操作数据一栏的添加错误操作，设置参数，将重试失败的错误消息转发至指定位置。
      注意

      • 最多支持添加一个错误操作。
      • 正常操作和错误操作的转发目的云产品不能相同。例如，不能同时转发到表格存储。
      • 错误消息转发失败后，不会再进行重试。
      • 这里的错误消息仅针对因其他云产品实例问题导致的规则引擎转发失败错误。
      消息转发至云产品失败后，会进行重试。若重试失败，将根据错误操作数据转发的设置转发错误消息。

      错误消息格式：

      {
            "ruleName":"",
            "topic":"",
            "productKey":"",
            "deviceName":"",
            "messageId":"",
            "base64OriginalPayload":"",
            "failures":[
              {
                "actionType":"OTS",
                "actionRegion":"cn-shanghai",
                "actionResource":"table1",
                "errorMessage":""
              },
              {
                "actionType":"RDS",
                "actionRegion":"cn-shanghai",
                "actionResource":"instance1/table1",
                "errorMessage":""
              }
            ]
      
      }

      错误消息参数说明如下：

      参数	说明
      ruleName	规则名称。
      topic	消息来源Topic。
      productKey	产品ProductKey。
      deviceName	设备名称。
      messageId	云端消息ID。
      base64OriginalPayload	Base64编码后的原始数据。
      failures	错误详情。可能会有多个。
      actionType	出错操作的类型。
      actionRegion	出错操作的地域。
      actionResource	出错操作的目的资源。
      errorMessage	错误信息。

7. 所有设置完成后，返回至云产品流转页面，单击规则对应的启动。规则启动后，数据即可按照规则进行转发。
   您也可以单击：

   • 查看：在数据流转规则页面，修改规则的具体设置。
   • 删除：删除对应规则。
     说明 运行中的规则不可删除。
   • 停止：停止对应规则转发数据。