Skip to content

数据转发

设备管理平台提供数据流转服务,支持通过配置设备Topic条件等,将数据转发至其他Topic或其他MQ消息队列进行存储或处理。

数据转发流程示意图如下。

MQ实例管理

登录设备管理平台控制台后,鼠标点击左侧菜单->规则->数据转发->数据转发规则,切换Tab页签->MQ实例管理,显示MQ实例列表页面如下图。

列表参数说明

参数描述
实例名称实例名称。
消息中间件类型消息中间件类型目前支持:kafka rabbitmq
mq连接地址mq连接地址,集群地址多个使用逗号分隔。例如:127.0.0.1:9092,192.168.1.1:9092
mq认证用户名mq连接用户名。
mq认证密码mq连接的用户密码。
创建时间mq实例创建的时间。
更新时间mq实例信息更新时间。

新建MQ实例

在MQ实例管理列表中,单击->新建MQ实例,弹出新建MQ实例页面,如下图。

参数描述
消息中间件类型选择消息中间件类型,目前支持:kafka rabbitmq
实例名称输入实例名称。
客户端ID输入客户端ID,可选。
mq连接地址mq连接地址,集群地址多个使用逗号分隔。例如:127.0.0.1:9092,192.168.1.1:9092
用户名mq连接的用户名。
密码mq连接的用户的密码。

编辑MQ实例

在MQ实例管理列表中,选择对应MQ实例,单击->编辑按钮,弹出编辑MQ实例页面,如下图。

删除MQ实例

在MQ实例管理列表中,选择对应MQ实例,单击->删除按钮,弹出删除MQ实例提示,如下图。

    1. 点击->确定,删除MQ实例。
    1. 点击->取消,取消删除MQ实例。

数据转发规则管理

登录设备管理平台控制台后,鼠标点击左侧菜单->规则->数据转发,显示数据转发列表页面如下图。

列表参数说明

参数描述
规则名称规则名称。
规则状态规则状态。 *启用 停用
当前版本当前正在使用的规则版本。
最新版本最新的规则版本。
创建人规则创建人。
创建时间规则创建时间。

新建转发规则

在数据转发规则管理列表中,单击->新建转发规则,弹出新建转发规则页面,如下图。

参数描述
规则名称输入规则名称。
规则描述输入规则描述。

编辑转发规则

在数据转发规则管理列表中,选择对应转发规则,单击->编辑按钮,弹出编辑页面,如下图。

编辑基础信息

单击->编辑按钮

参数描述
规则名称规则名称。
规则ID规则ID。不可编译,自动生成。
规则描述规则描述。

编写SQL-处理数据

单击->编写SQL,弹出编写SQL页面,如下图。

参数描述
Topic需要转发的Topic。
设备状态: 选择指定产品下的所有设备或某些设备转发上下线状态。
设备事件: 选择指定产品下的所有设备或某些设备转发事件。
设备属性: 选择指定产品下的所有设备或某些设备转发上报属性。
自定义: 自定义通配符匹配需要转发的数据。
规则查询语句配置好转发规则后,会生成对应的规则语句,类sql。

转发数据

单击->添加操作,弹出编辑页面,如下图。

参数描述
添加操作需要转发的目的地。
发送到另一个Topic: 转发数据到另一个Topic。
转发到数据库存储: 转发数据到数据库。
调用扩展服务: 转发到其他服务。
发送数据到消息队列: 转发数据到消息队列中。
自定义信息发送到另一个Topic:转发数据到自定义的Topic中。
实例转发到数据库存储:选择要转发的数据库实例。
数据表转发到数据库存储:选择要转发的数据库表。
服务名调用扩展服务:输入需要调用的服务名。
同步/异步调用扩展服务:选择服务调用的方式。
转发目标发送数据到消息队列:选择需要转发的目标MQ。
Topic发送数据到消息队列:输入需要转发到MQ的Topic。

失败执行动作

单击->新增执行动作,添加一条执行动作数据,如下图。

参数描述
执行动作执行动作。
警告输出: 警告数据输出。
消息输出: 普通消息输出。
级别输出级别:
警告
一般
严重
致命
警告名称输入警告名称。
警告内容输入警告内容。
延迟时间延迟执行时间。

启用停用规则

在数据转发规则列表,选择指定规则操作。

启用: 点击启用,规则状态启用。
停用: 点击停用,规则状态停用。

规则下发

当修改了规则后,需要下发给规则引擎才能生效。 在数据转发规则列表,选择指定规则操作。

下发:点击下发,最新修改的规则下发给规则引擎执行。

删除数据转发规则

在数据转发规则列表,单击某个数据转发规则的删除按钮,弹出删除提示框,如下图。

    1. 点击->确定,删除规则。
    1. 点击->取消,取消删除规则。