Skip to content

动作 ​

动作是MQTT消息与外部数据系统的连接匹配规则,包含数据处理,映射,MQTT协议设备连接MQTT服务实施传递消息,其中动作为数据集成到外部数据系统提供了关联,从而实现设备与其他业务系统的无缝集成。

1. 规则动作 ​

在 规则引擎 -> 动作 进入动作 列表页面,动作基于**连接器**

选择**动作类型**,点击 前进,继续配置

KAFKA动作配置 ​

  • 填写动作名称
  • 选择 kafka连接器,这里的连接器是在连接器列表创建的
  • 主题,这里是**kafka主题**,按照kafka主题命名
  • key ,这里用来映射使用,上报数据需要传输的内容,一般不需要填写
KAFKA动作配置页面截图

RABBIT-MQ动作配置 ​

  • 填写动作名称
  • 选择 rabbitmq连接器,这里的连接器是在连接器列表创建的
  • 队列,这里是**rabbitmq队列**,按照rabbitmq队列填写
  • 交换机 ,rabbitmq的交换机,选填。
RABBIT-MQ动作配置页面截图

MQTT服务动作配置 ​

  • 填写动作名称
  • 选择 MQTT连接器,这里的连接器是在连接器列表创建的
  • 主题,这里是**MQTT主题**,按照MQTT主题命名
  • qos ,mqtt的消息质量
  • retain, 是否保留
MQTT服务动作配置页面截图

ROCKET-MQ动作配置 ​

  • 填写动作名称
  • 选择 rocketmq连接器,这里的连接器是在连接器列表创建的
  • 主题,这里是**rocketmq主题**,按照rocketmq主题命名
  • key ,rocketmq的key值
  • tag, rocketmq标签
ROCKET-MQ动作配置页面截图

WEBHOOK动作配置 ​

  • 填写动作名称

  • 选择 webhook连接器,这里的连接器是在连接器列表创建的

  • template ,是推送数据的模板,可以根据实际情况选择,可选字段如下:

    字段名字段说明
    clientId客户端id
    proto_name协议类型名称
    ip_address客户端IP
    node节点IP
    port客户端端口
    ts事件触发时间
    keepalive心跳间隔
    clean_start是否清除会话
    status是否在线

    template示例

    json
    {
      "clientId":${clientId} 
      "payload" :${payload}
    }
    WEBHOOK动作配置页面截图

蜂信物联 | fastbee.cn