您可以使用规则引擎将数据转到DataHub上,再由DataHub将数据流转至实时计算、MaxCompute等服务中,以实现更多计算场景。

前提条件

  • 已确认当前物联网平台实例及所在地域支持将数据转发到DataHub。
    支持的实例 支持的地域
    企业版实例:标准型和尊享型
    • 华东2(上海)
    • 华南1(深圳)
    • 华北2(北京)
    公共实例
    • 华东2(上海)
    • 新加坡
    • 德国(法兰克福)
  • 已创建DataHub Project和用于接收数据的Topic。DataHub使用方法,请参见DataHub文档
    重要 企业版实例中,DataHub Project所在地域,必须与企业版实例所在地域一致。
  • 已创建数据转发规则和编写处理数据的SQL,请参见设置数据流转规则

使用说明

目前,新版和旧版云产品流转功能均支持将数据流转到DataHub。新版云产品流转使用示例,请参见数据转发到DataHub(新版)

操作步骤

  1. 登录物联网平台控制台
  2. 实例概览页面,找到对应的实例,单击实例进入实例详情页面。
    重要 目前华东2(上海)、华北2(北京)、华南1(深圳)地域开通了企业版实例服务。其他地域,请跳过此步骤。
    实例概览
  3. 在左侧导航栏,选择规则引擎 > 云产品流转
  4. 单击规则对应的查看,进入数据流转规则页面。
    重要 若当前页面为云产品流转新版页面,需先单击右上角返回旧版,再单击目标规则对应的查看
  5. 单击转发数据一栏对应的添加操作
  6. 添加操作对话框中,按照界面提示,设置参数,单击确认
    数据流转到DataHub
    参数 说明
    选择操作 选择发送数据到DataHub中
    地域 选择DataHub所在地域。
    Project 选择DataHub Project。

    您可以单击创建Project,跳转到DataHub控制台,创建DataHub Project,请参见DataHub文档

    Topic 选择接收数据的DataHub Topic。

    选择Topic后,规则引擎会自动获取Topic中的Schema,规则引擎筛选出来的数据将会映射到对应的Schema中。

    说明
    • 将数据映射到Schema时,需使用${},否则存入表中的将会是一个常量。
    • Schema与规则引擎的数据类型必须保持一致,否则无法存储。

    您可以单击创建Topic,跳转到DataHub控制台,创建DataHub Topic。

    角色 授权物联网平台将数据写入DataHub。

    如您还未创建相关角色,单击创建RAM角色,跳转到RAM控制台,创建角色和授权策略,请参见创建RAM角色

  7. 回到云产品流转页,单击规则对应的启动按钮启动规则。