TDengine TSDB（时序数据库） 3.3.7.0 发布：流计算重构 + MQTT 原生支持 + BLOB 类型上线

Simon Guan

2025年7月31日 / 技术文章 - 时序数据库, 时序数据库

近日，TDengine TSDB 3.3.7.0 版本正式发布。本次更新聚焦“时序数据处理与集成能力”双重提升，围绕数据处理的实时性、复杂性和低延迟需求，全面升级 TDengine 流计算架构，并新增 MQTT 数据订阅、BLOB 数据类型、多级存储共享存储支持、IPv6 通信等关键能力，持续强化时序数据平台的场景适应力与可扩展性。

如果你关注 AIoT、车联网、工业控制等前沿领域的时序数据管理，这一版本更新将为你带来更多“用得上”的技术能力👇

重要更新亮点

全新架构流计算：性能更高，能力更强

本次发布的全新流计算系统，围绕灵活性、稳定性与可运维性进行深度升级，具备以下核心特性：

触发与计算分离：支持触发与计算分离，计算不再受限于触发数据源，可作用于任意表，甚至无需触发表，灵活适配复杂流程。
触发机制更灵活：支持定时触发、滑动触发、窗口触发（时间/事件/会话/状态/计数），支持窗口开/关窗分别触发，并可预过滤输入数据。
计算逻辑增强：支持任意 SQL 查询，支持窗口参数占位符，计算结果可写入表、发送通知，或同时执行。
通知机制更完善：支持基于 WebSocket 的窗口事件通知，并可配置触发条件、失败重试策略。
资源调度更灵活：计算过程可在 snode 节点上独立运行，多节点负载均衡与高可用，提升系统稳定性。

此外，新版本特别强化了异常数据重算机制，支持通过选项控制是否自动重算，并可结合 WATERMARK 等多个控制选项实现乱序容忍、数据删除后的结果修复。

👉 流计算重构为 TDengine 时序数据库带来了更强的事件处理能力，是构建低延迟报警、预测分析、实时特征提取等场景的核心基础。同时也为 TDengine 最新发布的 AI 原生工业数据管理平台 IDMP 提供了强有力的支持。

支持 MQTT 协议数据订阅：零代码集成更简单

MQTT 作为工业领域主流的消息协议，TDengine 新增对 MQTT 的原生订阅支持：

bnode 模块上线：作为 Broker 提供服务，用户可通过标准 MQTT 客户端直接订阅数据，无需额外开发。
共享订阅与消费组机制：支持负载均衡与高可用，客户端断连可自动切换，消息可在组内自动重分配。
多种数据格式支持：支持 JSON、Raw Block 格式，适配多种前端解析逻辑。
订阅位置控制：支持 latest、earliest 起始订阅位置，以及持久化和离线消息处理。
主题管理要求：与标准 MQTT Broker 不同，TDengine 的订阅主题需预先创建，不支持通过发布消息动态生成。

👉 通过 MQTT 订阅，TDengine 与业务系统的联动效率进一步提升。这一能力让 TDengine 更易集成到 SCADA、边缘控制、Web 可视化等系统，构建起真正实时、稳定、低门槛的数据消费通道。

新增 BLOB 数据类型：轻松存储大体量二进制数据

为满足车联网、航空航天等行业对大数据报文的存储需求，TDengine 全新引入 BLOB 类型：

用于存储长度较大的、未解析/拆分行列的二进制或者文本型数据
支持最大 4MB 单字段二进制内容写入
支持 SQL 查询语法
使用独立的 BSE 引擎管理存储与读取，性能显著优于传统 Binary 类型
Java、Go、Rust、Python、C# 等连接器已实现 BLOB 类型支持

👉 BLOB 类型是 TDengine 面向非结构化数据的一次重要扩展，让原始报文存储、图像数据、协议帧数据的管理更加高效统一。

原生支持 IPv6 通信协议

为应对未来万物互联趋势，TDengine 现已原生支持集群内部通过 IPv6 协议通信，包括：

节点发现与连接、心跳同步、审计监控等通信流程
创建节点（dnode/mnode/qnode）时支持 IPv6 地址配置
taosc 连接、白名单、安全策略全面适配 IPv6
Java、Go、Rust、Python、C# 等连接器全面适配 IPv6

👉 这项更新为全球部署、未来网络架构提供了更强的适应力。

TDgpt 协变量分析预测能力增强

TDengine 的 AI 模块 TDgpt 新增“协变量预测”能力，在建模时不仅考虑目标变量自身的历史数值，还可引入天气、节假日等外部因素作为协变量，显著提升对复杂周期性变化的预测效果。

以未来协变量预测为例，示例如下：

select _frowts, forecast(val, past_co, future_co, "algo=moirai,rows=4, dynamic_val=[1 1 1 1], dynamic_val_col=future_co") from foo;

TDengine TSDB（时序数据库） 3.3.7.0 发布：流计算重构 + MQTT 原生支持 + BLOB 类型上线 - TDengine Database 时序数据库

多级存储支持共享存储（企业版）

针对冷数据管理需求，3.3.7.0 正式支持多种共享存储（如 SAN、NAS、S3、DFS），实现：

冷数据自动迁移：支持设定数据在本地保留时长，达到阈值后自动上传至共享存储
按需查询：查询时自动加载所需数据块，确保性能与成本平衡
多节点共享机制：主节点上传，副本节点复用，避免冗余

👉 这一能力特别适合对存储成本敏感、历史数据不常访问但不能丢弃的工业企业与能源场景。

天脉系统适配及数据挂载支持（企业版）

为了更好地服务国产化、军工与航天等高安全行业客户，TDengine 企业版现已完成对天脉系统（ACoreOS）的适配。作为由中航工业计算所自主研发的国产机载实时操作系统，天脉广泛应用于工业控制、航空航天等关键领域。新版本支持：

在机载端部署 TDengine，并通过 RPC 通信与地面系统交互
在地面端通过 SQL 命令挂载机载磁盘目录，实现数据统一管理

create mount mount1 on dnode 1 from "/var/lib/TDengine"

挂载性能高效，秒级完成，兼顾实时性与安全性

👉 此功能使 TDengine 成为工业嵌入式场景中可部署、可接管、可统一管理的数据平台解决方案，助力国产化进程稳步推进。

SparkplugB 数据接入（企业版）

在 TDengine 3.3.7.0 中，taosX 平台正式支持 SparkplugB 规范的数据接入。taosX 是专为工业环境设计的开放式数据接入平台，此次对 SparkplugB 的支持，进一步扩展了 TDengine 在工业协议集成方面的能力。

SparkplugB 是基于 MQTT 的工业物联网（IIoT）数据传输规范，旨在提升工业环境中的数据互操作性与传输效率，具备以下显著优势：

提升带宽利用率：相比原始 MQTT，SparkplugB 数据压缩率高达 3 倍，特别适用于低带宽网络环境。与 Modbus 相比，最高可节省 75% 至 99.5% 的带宽资源。
标准化与互操作性强：为设备与系统间的数据交换提供统一数据语义，消除厂商壁垒，支持无缝对接 SCADA、MES、ERP 等企业系统，实现 IT 与 OT 的融合。
数据可靠性更强：具备会话状态感知与双向通信能力，支持设备级闭环控制。

👉 凭借高效、轻量、易部署等特点，SparkplugB 正成为工业物联网场景下最具实用价值的通信协议之一，尤其适用于需要低带宽、高可靠性、强互操作性的工业应用场景。与 OPC UA 等传统工业协议相比，其在带宽利用率、部署简便性和可扩展性方面表现尤为突出。