物联网引擎

产品文档

物联网引擎

规则引擎

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

创建规则

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

create-rule

数据转发

  1. 点击 规则名称 , 进入规则引擎详情页

2.1 处理数据/编写脚本

  1. 点击页面上的 编写脚本,进行处理规则引擎转发的规则逻辑编写

scrpit

  • 脚本所用的为 JavaScript 语言
  • 所有的数据都会经过 脚本 进行处理,然后进行数据转发

scrpit

脚本样例如下:

function Filter(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 消息类型

脚本编写完成后,可点击 测试脚本 , 进行脚本测试

测试界面如下:

  • 结果输出为 当执行脚本过滤后 输出的数据
  • 用户可以点击 测试脚本
  • 结果输出 显示经过脚本过滤的数据

scrpit

2.2 转发数据/添加动作

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

scrpit

注意:

设备上报的数据经过规则引擎转发后会进行数据增强处理,增加设备名称,设备标识及设备产品的信息,示例如下:

产品 iottest下的名为test-device的设备上报的数据格式:

{
 "msgId": "123",
 "version": "1.0",
 "data": {
 "message": "Hello World"
 },
 "ts": 1559805611390
}

规则引擎转发出去的格式:

{
  "identifier":"kKvX***kvx",
  "message":"Hello World",
  "productKey":"REwf***gdne",
  "deviceName":"test-device",
  "ts":"1577181657114"
} 

2.2.1 转发到另一个Topic

  • 选择必选项产品、设备和输入自定义topic名称。若产品没有可选项,请先到产品页创建产品,然后去设备页为所属产品添加设备;若设备没有可选项,请到设备页为所属产品添加设备。

scrpit

  • 点击 确定 ,转发列表中即可看到该MQTT操作类型。同时可以对其进行编辑和删除。

2.2.2 转发到JCQ

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

获取消息队列JCQ的参数信息:

  1. 进入 消息队列 JCQ -> Topic管理页
  2. 点击目标 Topic 名称进入该 Topic 详情页。 若Topic管理页没有创建好的Topic,则点击 新建按钮 ,创建Topic。

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

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

2.2.3 转发到ES

转发ES需填写京东云ES内网接入点、京东云ES Index和京东云ES Type 等信息

获取云搜索 Elasticsearch的参数信息:

  1. 进入 云搜索 Elasticsearch -> 集群管理页
  2. 点击目标集群Elasticsearch名称进入该Elasticsearch基本信息页。若Elasticsearch集群管理页没有创建好的Elasticsearch集群,则点击创建按钮,创建集群。

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

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

更新时间:2019-12-30 15:50:41
文档反馈 docs feedback