ThingsBoard中处理数组类型遥测数据的完整解决方案

背景介绍

在物联网应用中，设备经常会发送包含数组类型数据的遥测信息。ThingsBoard作为主流的物联网平台，其标准数据处理方式是将每个数据点作为独立的时间序列存储。但当设备发送的是数组形式的数据（如ADC采样值列表）时，直接存储会导致无法在仪表盘中正确展示图表。

问题现象

用户在使用ThingsBoard社区版3.9.0时遇到以下情况：

• 设备通过MQTT发送包含ADC_VAL数组的JSON数据
• 原始数据格式示例：{"ADC_VAL": [0.01, -0.19, -0.2,...], "CH_NO": "0"}
• 直接存储后在仪表盘只能显示整个数组，无法绘制时序曲线

技术原理分析

ThingsBoard的时序数据库设计：

1. 每个时间序列数据点需要独立的timestamp
2. 仪表盘图表组件基于时间序列数据绘制
3. 数组类型数据会被视为单一数据点存储

解决方案实现

通过规则链中的JavaScript转换节点，将数组拆分为独立数据点：

1. 规则链配置

在"Post telemetry"节点后添加"Transformation"节点，类型选择JavaScript。

2. JavaScript转换脚本

function Transform(msg, metadata, msgType) {
    if (msg.ADC_VAL && Array.isArray(msg.ADC_VAL)) {
        var values = msg.ADC_VAL;
        var result = [];
        var baseTimestamp = Date.now();
        
        for (var i = 0; i < values.length; i++) {
            var newMetadata = JSON.parse(JSON.stringify(metadata));
            newMetadata.ts = baseTimestamp + i * 100;
            newMetadata.deviceName = msg.MACADDRESS || "Unknown Device";
            newMetadata.deviceType = metadata.deviceType || "SensorProfile";
            
            var transformedMsg = {
                msg: {
                    "ADC_VAL": values[i],
                    "CH_NO": msg.CH_NO
                },
                metadata: newMetadata,
                msgType: msgType
            };
            result.push(transformedMsg);
        }
        return result;
    } else {
        return [{ msg: msg, metadata: metadata, msgType: msgType }];
    }
}

3. 关键配置要点

1. 时间戳生成：为每个数组元素分配递增的时间戳
2. 元数据保留：复制原始metadata并添加必要字段
3. 数据格式转换：将每个数组元素转换为独立消息对象

4. 规则节点连接

转换节点后必须连接"Save timeseries"节点，并确保：

• 使用metadata中的ts而非服务器时间
• 正确映射数据字段

调试技巧

1. 启用规则节点的Debug模式
2. 检查输入/输出消息格式
3. 验证时间戳是否按预期生成
4. 确认数据字段名称与仪表盘配置一致

最佳实践建议

1. 数据密度控制：根据采样率合理设置时间间隔
2. 字段命名规范：保持设备、规则链和仪表盘使用一致的字段名
3. 错误处理：在脚本中添加对异常数据的处理逻辑
4. 性能优化：对于大数据量数组，考虑分批处理

扩展应用

此方案不仅适用于ADC采样值，还可应用于：

• 传感器历史数据批量上传
• 设备状态变化序列
• 周期性采集的多参数数据集

通过这种数据预处理方式，用户可以在ThingsBoard中完美展示各种数组形式的设备数据，充分发挥平台的数据可视化能力。

总结