Skip to content

数据流转

数据流转支持设备运行状态的数据通过多种方式推送到外部服务器

  1. 登录云平台

  2. 在左侧导航栏,选择【设备】>>【规则引擎】>>【规则管理】,点击规则管理页面的【+添加规则】

  3. 在弹出的添加规则页面设置规则名称,在规则类型中选择【数据流转】

  4. 设置设备监听:添加监听设备、添加并设置监听条件(如:温度低于25℃)

    1. 添加监听器:点击【+新增监听器】

    1. 选择监听设备模型:点击【选择模型:】,在弹出的窗口中点击【选择】监听设备模型

    1. 选择监听设备:点击【选择设备】,在弹出的窗口中点击【选择】设备

    1. 添加监听条件:点击【+】

    1. 设置监听设备的监听条件:先点击右侧的【+】,按照下图顺序步骤设置

  5. 根据具体需要添加设备数据过滤(如:在上述满足监听条件的数据中过滤24℃的数据)

    1. 添加过滤器:点击【+新增过滤器】

    1. 添加过滤的设备:点击【指定设备】,在弹出的窗口中点击【选择】过滤设备

    1. 添加设备过滤条件:点击【+】

    1. 设置设备过滤条件:按照下图顺序步骤设置

  6. 当设备监测数据满足设置的条件时,推送设备数据到设定的地址,操作步骤见下图

  7. 【保存】设置,规则设置详情见下图

  8. 在【数据流转】中【启动】该规则

  9. 最终发送地址是http://192.168.2.166:8098/servlet/test。

支持查看规则执行日志、规则详情、对规则进行启动、编辑和删除操作

注:监听条件、过滤条件均支持设置多个设备的多个条件,输出支持同时设置多种推送方式

转换脚本中可用参数介绍

可用参数参数名称说明
msg可用参数deviceId设备Id
productKey产品key
deviceName设备SN
day消息上报日期
type消息类型(lifetime生命周期、state状态、property属性、event事件、service服务)
identifier标识符(type为property时set_reply设置回复、report上报、set设置;type为state时online上线、否则下线;type为lifetime时register注册;)
code消息状态码
data内容
occurred时间戳,设备上的事件或数据产生的本地时间
device可用参数deviceAlias设备名称
topicmqtt、kafka需要指定topic名称

转换脚本示例

1.http示例

云平台配置示例

客户端接收数据示例

{"deviceId":"1725003709810010379701193932820d","deviceSn":"31279103797011939328","productKey":"jteDw85kk6h2XmeG","deviceName":"规则引擎数据流转【勿删】","data":"{\"wendu\":99}"}

2.tcp示例

云平台配置示例

客户端接收数据示例

{"deviceId":"1725003709810010379701193932820d","deviceSn":"31279103797011939328","productKey":"jteDw85kk6h2XmeG","deviceName":"规则引擎数据流转【勿删】","data":"{\"wendu\":99}"}

3.mqtt示例

云平台配置示例

客户端接收数据示例

{"deviceId":"1725003709810010379701193932820d","deviceSn":"31279103797011939328","productKey":"jteDw85kk6h2XmeG","deviceName":"规则引擎数据流转【勿删】","data":"{\"wendu\":99}"}

3.kafka示例

同mqtt转换脚本一致