数据转发到表格存储
您可以使用规则引擎数据流转功能,将数据转发到表格存储(Tablestore)中存储。
前提条件
创建数据表
设置数据流转规则
-
在IoT测试环境实例的左侧导航栏,选择。
在云产品流转页面,单击创建规则。
重要若当前页面显示新版功能,先单击右上角返回旧版,进入旧版功能页面,再单击创建规则。
-
在创建云产品流转规则对话框,输入规则名称温控器数据流转,数据格式为JSON,单击确认。
-
规则创建成功后,将跳转到数据流转规则页面。参照以下操作,编辑处理消息数据的SQL,设置数据转发目的地。
页面分为处理数据和转发数据两个区域。处理数据区域显示规则查询语句及编写SQL按钮,转发数据区域显示数据目的地列表及添加操作按钮。
-
单击编写SQL,在弹出对话框中,输入SELECT的字段,并选择Topic的数据类型为物模型数据上报、产品为家庭温控器、设备为Device1、物模型模块为默认模块、Topic为thing/event/property/post,然后单击确认。
-
单击转发数据一栏的添加操作,设置数据转发目的地为已创建的数据表iot_data。具体操作,请参见数据转发到表格存储(Tablestore)。
在编辑操作对话框中,选择操作为存储到表格存储(Tablestore),地域选择华东 2,实例选择 IoTDataStore,数据表选择 iot_data。主键中 deviceName 键的值为 ${deviceName},timestamp 键的值为 ${time}。角色选择 AliyunIOTAccessingOTSRole,单击确认。
-
-
所有设置完成后,返回至云产品流转页,单击规则对应的启动按钮。规则启动后,数据即可按照规则进行转发。
当虚拟设备有数据上报后,您可以在表格存储的iot_data表中看到实时存储的数据。
数据表中包含 deviceName(主键)、timestamp(主键)、humidity 和 temperature 四个字段,每行记录对应一次设备上报的温湿度数据。
您也可以在IoT企业实例的⽇志服务中,查看完整的流转⽇志,排查数据链路异常情况。
在云端运行日志页签,选择对应产品后,可查看包含时间、TraceID、MessageId、消息内容、DeviceName、业务类型、操作、内容和状态等信息的日志记录,通过业务类型(如规则引擎、物模型等)追踪数据流转链路,状态为 200 表示处理成功。