ThingsBoard规则引擎取最新2条遥测及Kafka数据乱序问题求助

可以通过规则链中的遥测历史节点（Telemetry History Node）实现，具体配置步骤：

• 在规则链中添加遥测历史节点
• 配置节点核心参数：
  • 实体ID选择Originator（触发事件的目标设备）
  • 遥测Keys填写需要获取的字段（如humidity,temperature，多个字段用逗号分隔）
  • 将Limit参数设置为2，控制返回最新数据的条数
  • 排序方式选择DESC（降序），确保返回的是最新的2条数据
• 配置完成后，可通过后续节点（如脚本节点）访问msg.telemetryData获取这2条遥测数据进行处理

遥测频繁变化的解决方案 #

• 硬件排查：检查DHT22的接线是否牢固、供电是否稳定（需提供3.3V/5V稳定电压），必要时给传感器添加屏蔽罩减少电磁或气流干扰
• 设备端防抖处理：
  • 设置数据上报阈值，仅当温湿度变化超过设定范围（如±0.5）时才向ThingsBoard上报
  • 采用多次采样取平均值的方式，过滤传感器的采样误差后再上报

Kafka数据乱序的解决方案 #

• 指定分区键：在ThingsBoard向Kafka发送消息时，将设备ID作为Kafka的分区键，确保同一设备的所有消息被分配到同一个Kafka分区（分区内消息严格有序）
• 检查规则链配置：确认Kafka发送节点的键策略设置正确，避免未指定分区键导致消息被轮询分配到不同分区
• 消费者端优化：若使用多线程消费Kafka，需保证同一分区的消息由单个线程处理，避免跨线程的消息乱序

内容的提问来源于stack exchange，提问作者B21DCCN328 Phạm Thị Thanh Hằng