作者:三烽
一、数据流转
1、基本概念
当设备基于Topic进行通信时,您可以在规则引擎的数据流转中,编写SQL对Topic中的数据进行处理,并配置转发规则将处理后的数据转发到其他Topic或阿里云其他服务。
2、方案对比
规则引擎和服务端订阅都可以进行数据流转,两者的对比详见文档https://help.aliyun.com/document_detail/102335.html
3、创建规则
数据类型可选JSON和二进制。因为数据流转是基于Topic处理数据的,所以数据格式要和被处理Topic中的数据格式保持一致。【若选择为二进制,该规则不能处理系统Topic的消息,且不能将数据转发至表格存储、时序时空数据库和云数据库RDS版。】
规则详情页的配置说明请参考文档https://help.aliyun.com/document_detail/42733.html
4、SQL表达式举例说明
产品中有一个属性为struct,数据类型为结构体,结构体中JSON对象分别是length、height和weight。
要正确提取struct中的各参数值,sql语句应如下所示(注意items的使用,详见5数据流转过程)
SQL中的数组使用说明如下所示
【注意事项】
a.SELECT语句中的字段最多支持50个
b.不支持子SQL查询
c.可以使用SQL内置函数,详见文档。
5、数据流转过程
a.通过自定义topic上传,透传结构不变,sql语句中直接填写payload中的key值。
b.通过系统topic上传,注意经过物模型解析后的结果,sql语句中要使用items.xxx的形式。
6、数据格式
上传到系统topic中的数据格式由平台定义,详见文档https://help.aliyun.com/document_detail/73736.html
二、数据流转使用示例
1、数据转发到另一Topic
https://help.aliyun.com/document_detail/42734.html
2、数据转发到消息队列(RocketMQ)
https://help.aliyun.com/document_detail/59000.html
3、数据转发到表格存储(Table Store)
https://help.aliyun.com/document_detail/42735.html
4、数据转发到DataHub
https://help.aliyun.com/document_detail/42734.html
5、数据转发到云数据库(RDS)
https://help.aliyun.com/document_detail/42736.html
6、数据转发到消息服务(Message Service)
https://help.aliyun.com/document_detail/44008.html
7、数据转发到时序时空数据库(TSDB)
https://help.aliyun.com/document_detail/64143.html
8、数据转发到函数计算(FC)
https://help.aliyun.com/document_detail/64234.html
三、场景联动
1、基本概念
场景联动是规则引擎中,一种开发自动化业务逻辑的可视化编程方式,您可以通过可视化的方式定义设备之间联动规则,并将规则部署至云端或者边缘端。
例如,您每天18:00下班回家。在炎热的夏天,您希望您到家后,家里的温度是凉爽、舒适的。您可以创建一条规则,使空调设备自动化,实现这个需求。