设备消息通过kafka流转到服务器
更新时间: 2023-04-10

根据G+link协议规范,将设备上报数据按设备温度进行存储。

# 设备数据实时推送到Kafka规则引擎配置

  • 规则名称

property_2_kafka

  • 描述

设备上报属性推送到消息队列kafka

  • 数据来源

thing/+/+/property/post

  • 数据目的地

    类型:用户Kafka

    主题:选择自定义目的地中添加的kafka主题

  • 测试输入

	{
    "reqId":"442c1da4-9d3a-4f9b-a6e9-bfe858e4ac43",
    "method":"thing.property.post",
    "version":"1.0",
    "timestamp":1610430718000,
    "properties":{
        "humidity":23.5,
        "temperature":35.2,
        "location":{
            "longitude":67.001,
            "latitude":108.66
        }
    }
}
  • 过滤条件

  • 查询条件
{
    "instanceId":"bsx110sdsfb5ihc8",
    "topic":$topic(),
    "payload":$
}