阿里云物联网平台数据转发到表格存储(Table Store)示例参考

简介: 使用物联网平台规则引擎的数据流转功能,可将Topic中的数据消息转发至其他Topic或其他阿里云产品进行存储或处理。本文主要结合物模型的结构体类型属性数据,演示payLoad的设置及规则引擎的配置。

概述

使用物联网平台规则引擎的数据流转功能,可将Topic中的数据消息转发至其他Topic或其他阿里云产品进行存储或处理。本文主要结合物模型的结构体类型属性数据,演示payLoad的设置及规则引擎的配置。

前提准备

1、物模型定义
_
_

2、上行消息payLoad

        request.topic = "/sys/" + pk + "/" + dn + "/thing/event/property/post";
        request.payloadObj = "{\"id\":\"230788029\",\"method\":\"thing.event.property.post\",\"params\":{\"Status\":1,\"Data\": [\n" +
                "    {\n" +
                "      \"P\": 25,\n" +
                "      \"I\": 105,\n" +
                "      \"E\": 11\n" +
                "    },\n" +
                "    {\n" +
                "      \"P\": 121,\n" +
                "      \"E\": 119,\n" +
                "      \"I\": 11\n" +
                "    }\n" +
                "  ]},\"version\":\"1.0\"}";

3、日志服务监控上行消息情况

_

4、Table Store准备
_

操作步骤

1、在规则的数据流转详情页,创建规则 --> 编辑查询规则语句:

SELECT deviceName() as deviceName, "items.Data.value[0].P" as P, "items.Data.value[0].I" as I,"items.Data.value[0].E" as E FROM "/sys/a1D8NwXCe56/device1/thing/event/property/post"

_

此处编写相对比较复杂,可以参考SQL表达式数组使用说明部分及数据流转过程系统Topic部分。

小技巧:如果使用者对具体上行消息经过物模型解析后的格式不是特别清楚,建议可以直接使用服务端订阅订阅上行消息,这样就可以直接参考具体的消息格式类型了,如下是测试订阅获取的消息格式:

"deviceName":"device1","items":{"Status":{"value":1,"time":1561886161283},"Data":{"value":[{"P":25,"E":11,"I":105},{"P":121,"E":119,"I":11}],"time":1561886161283}}}

2、转发数据
_

3、数据流转详情
_

4、开启规则引擎(注意配置完成后务必记住要开启,否则配置不生效)
_

5、表格存储中检查数据
_

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
相关文章
|
Web App开发 存储 NoSQL
阿里云表格存储(table store)属于存储类别还是数据库类别?
什么是表格存储? 表格存储是阿里云提供的一种数据服务。阿里云官方文档的定义如下: 表格存储(Table Store)是阿里云自研的NoSQL多模型数据库,提供海量结构化数据存储以及快速的查询和分析服务。
2763 0
|
9天前
|
分布式计算 NoSQL 大数据
MaxCompute产品使用合集之自定义udf连接云上vpc网络的redis获取数据的步骤是什么
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
1月前
|
物联网 Serverless
MQTT常见问题之通过mqtt控制台查询不到设备轨迹如何解决
MQTT(Message Queuing Telemetry Transport)是一个轻量级的、基于发布/订阅模式的消息协议,广泛用于物联网(IoT)中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总:
|
1月前
|
DataWorks 关系型数据库 数据处理
DataWorks常见问题之如何获取上游的表名和id
DataWorks是阿里云提供的一站式大数据开发与管理平台,支持数据集成、数据开发、数据治理等功能;在本汇总中,我们梳理了DataWorks产品在使用过程中经常遇到的问题及解答,以助用户在数据处理和分析工作中提高效率,降低难度。
|
1月前
|
SQL 分布式计算 DataWorks
DataWorks常见问题之API同步接入maxcomputer表如何解决
DataWorks是阿里云提供的一站式大数据开发与管理平台,支持数据集成、数据开发、数据治理等功能;在本汇总中,我们梳理了DataWorks产品在使用过程中经常遇到的问题及解答,以助用户在数据处理和分析工作中提高效率,降低难度。
|
1月前
|
SQL 分布式计算 DataWorks
MaxCompute确实支持对id_card_no进行加密和解密操作
【2月更文挑战第4天】MaxCompute确实支持对id_card_no进行加密和解密操作
33 12
|
XML JSON 关系型数据库
PolarDB-X 1.0-API参考-1.0(2019版本)-广播表-DescribeBroadcastTables
调用DescribeBroadcastTables接口查询广播表。
204 0
|
XML 关系型数据库 分布式数据库
|
XML JSON 关系型数据库
|
XML JSON 关系型数据库
PolarDB-X 1.0-API参考-1.0(2019版本)-广播表-SwitchGlobalBroadcastType
调用SwitchGlobalBroadcastType接口将广播表从多写切换成异步链路模式。
193 0

相关产品

  • 物联网平台