Apache IoTDB 0.13.3版本MQTT对接对齐时序报错的解决方法
解决Apache IoTDB 0.13.3 MQTT客户端对齐时序报错问题
报错Caused by: org.apache.iotdb.db.exception.metadata.AlignedTimeseriesException: timeseries under this device are aligned, please use aligned interface的核心原因是目标设备的时间序列处于对齐状态,必须使用对齐写入接口,不能用普通单时序写入逻辑。针对MQTT协议场景,可按以下方式处理:
方式一:使用对齐格式发送MQTT消息
对齐时序要求在单条MQTT消息中一次性写入该设备下所有对齐测点的数据,不能拆分发送。以JSON格式的Payload为例,正确格式如下:
{ "device": "root.sg.d0", "measurements": ["temperature", "humidity", "pressure"], "values": [26.5, 58.3, 101.2], "timestamp": 1699999999000 }
注意:
measurements需包含该设备下所有对齐的测点,不能遗漏values的顺序必须和measurements严格对应- 必须携带
timestamp字段,确保所有测点共享同一时间戳
方式二:解除设备的对齐状态
如果业务场景不需要对齐时序,可通过SQL命令修改设备元数据,取消对齐配置:
ALTER DEVICE [设备全路径] SET ALIGNED = FALSE
示例:
ALTER DEVICE root.lab.device0 SET ALIGNED = FALSE
执行该命令后,即可恢复普通单测点的MQTT写入方式,但此操作会改变设备元数据状态,需根据业务需求确认后执行。
额外注意事项
- 确保MQTT客户端发送消息的主题与IoTDB服务端配置一致,默认主题为
iotdb/mqtt/insert - 若使用非JSON格式的Payload(如CSV),需遵循对齐时序的格式要求,一次性携带所有测点数据和统一时间戳
内容的提问来源于stack exchange,提问作者Hester Tso
相关产品推荐
相关产品推荐

