阿里云物联网平台创建数据转发规则引擎

规则引擎的数据转储功能,可将Topic中的数据消息转发至其他Topic或其他的阿里云产品进行存储或处理。

1.创建规则
登录物联网中心控制台
左侧到导航选择管理-规则引擎
点击页面上方的创建规则引擎

数据转发
点击规则名称,进入规则引擎详情页

2.1处理数据/编写脚本
点击页面上的编写脚本,进行处理规则引擎转发的规则逻辑编写
脚本所用的为JavaScript语言
所有的数据都会经过脚本进行处理,然后进行数据转发

脚本样例如下:

functionFilter(msg,metadata,msgType){if(metadata.deviceName=='testDevice'){return{msg:msg,metadata:metadata,msgType:msgType}}}属性描述msg用户产品中定义的属性,设备上报数据metadata静态元数据
metadata元数据中包括:
metadata.deviceName为设备名称
metadata.identifier为设备Key
metadata.ts为消息上报的时间
metadata.version为当前版本msgType消息类型

脚本编写完成后,可点击测试脚本,进行脚本测试
结果输出为当执行脚本过滤后输出的数据
用户可以点击测试脚本
结果输出显示经过脚本过滤的数据

2.2转发数据/添加动作
点击添加动作,出现添加动作弹窗,添加操作有三种方式,分别是转发到另一个Topic,转发到JCQ,转发到ES

2.2.1转发到另一个Topic
选择必选项产品、设备和输入自定义topic名称。若产品没有可选项,请先到产品页创建产品,然后去设备页为所属产品添加设备;若设备没有可选项,请到设备页为所属产品添加设备。
点击确定,转发列表中即可看到该MQTT操作类型。同时可以对其进行编辑和删除。

2.2.2转发到JCQ

转发JCQ需填写JCQ接入点、Topic名称、Topic类型和地域等信息,可以进入消息队列JCQ产品中查找到相关信息。

获取消息队列JCQ的参数信息:
进入消息队列JCQ-Topic管理页
点击目标Topic名称进入该Topic详情页。若Topic管理页没有创建好的Topic,则点击新建按钮,创建Topic。

AK/SK信息在AccessKey管理页可以创建/获取。

点击确定,转发列表中即可看到该JCQ动作。同时可对其进行编辑和删除。

2.2.3转发到ES

转发ES需填写阿里云ES内网接入点、阿里云ESIndex和阿里云ESType等信息

获取云搜索的参数信息:
进入云搜索集群管理页,点击目标集群名称进入该基本信息页。若集群管理页没有创建好的集群,则点击创建按钮,创建集群。

AK/SK信息在AccessKey管理页可以创建/获取。

点击确定,转发列表中即可看到该ES动作。同时可对其进行编辑和删除。