您可以使用规则引擎数据流转功能,将数据转发到表格存储(Tablestore)中存储。

前提条件

已将设备接⼊到企业版实例。具体操作,请参见设备接入和上报数据

创建数据表

  1. 登录表格存储控制台
  2. 创建一个表格存储实例IoTDataStore。具体操作,请参见创建表格存储实例
  3. 如下图所示,创建数据表iot_data,以deviceName和timestamp为主键。具体操作,请参见创建数据表
    数据表

设置数据流转规则

  1. 登录物联网平台控制台
  2. 在已创建的企业实例中,在左侧导航栏,选择规则引擎 > 云产品流转
  3. 云产品流转页,单击创建规则
  4. 填写参数后,单击确认
    参数 描述
    规则名称 输入规则名称。支持中文、英文字母、日文、数字、下划线(_)和短划线(-),长度为1~30个字符,一个中文或日文占2个字符。
    数据格式 选择该规则处理数据的格式。可选:JSON和二进制。
    说明
    • 因数据流转基于Topic处理数据,此处的数据格式需与被处理Topic中的数据格式保持一致。
    • 若选择为二进制,该规则不能处理基础通信Topic、物模型通信Topic的消息,且不能将数据转发至实例内的时序数据存储、时序数据库、表格存储和云数据库RDS版。
    规则描述 规则描述信息。
    资源组 将该规则划归为某个资源组。默认选择账号全部资源,可以选择已创建的资源组。通过资源组管理,可以授予指定子账号查看和操作该规则,而未授权的子账号则不可以查看和操作该规则。关于资源组,请参见什么是资源组
    说明 该功能目前仅适用于白名单用户。如有需要,请提交工单,提供您的阿里云账号UID,申请成为白名单用户。

    规则创建成功后,可以在资源管理控制台变更规则所属的资源组。

  5. 规则创建成功后,页面将跳转到数据流转规则页。您需编辑处理消息数据的SQL,设置数据转发目的地。
    温控器数据流转
    1. 单击编写SQL,在弹出对话框中,输入SELECT的字段,并选择自定义的Topic,单击确认
      如下所示,请您根据实际情况编写SQL。本示例完整SQL语句如下:
      SELECT items.temperature.value as temperature, items.humidity.value as humidity,deviceName() as deviceName,timestamp() as time FROM "/YourProductKey/YourDeviceName/thing/event/property/post"

      SQL编写方法,可参见SQL表达式函数列表

      编写SQL
    2. 单击转发数据一栏的添加操作,设置数据转发目的地为已创建的数据表iot_data。具体操作,请参见数据转发到表格存储
      编写操作
  6. 所有设置完成后,返回至云产品流转页,单击规则对应的启动按钮。规则启动后,数据即可按照规则进行转发。

    当虚拟设备有数据上报后,您可以在表格存储的iot_data表中看到实时存储的数据。如下图所示。

    数据管理

    您也可以在IoT企业实例的⽇志服务中,查看完整的流转⽇志,排查数据链路异常情况。如下图所示。

    云端运行日志

后续步骤

服务端订阅设备消息