TDengine 发布时序数据库TSDB新版本: 全新MQTT订阅、多级存储支持

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

重要更新亮点

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

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

•触发与计算分离：支持触发与计算分离，计算不再受限于触发数据源，可作用于任意表，甚至无需触发表，灵活适配复杂流程;

•触发机制更灵活：支持定时触发、滑动触发、窗口触发(时间/事件/会话/状态/计数)，支持窗口开/关窗分别触发，并可预过滤输入数据。

•计算逻辑增强：支持任意SQL查询，支持窗口参数占位符，计算结果可写入表、发送通知，或同时执行。

•通知机制更完善：支持基于WebSocket的窗口事件通知，并可配置触发条件、失败重试策略。

•资源调度更灵活：计算过程可在snode节点上独立运行，多节点负载均衡与高可用，提升系统稳定性。

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

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

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

MQTT作为工业领域主流的消息协议，TDengineTSDB时序数据库新增对MQTT的原生订阅支持：

•bnode模块上线：作为Broker提供服务，用户可通过标准MQTT客户端直接订阅数据，无需额外开发。

•共享订阅与消费组机制：支持负载均衡与高可用，客户端断连可自动切换，消息可在组内自动重分配。

•多种数据格式支持：支持JSON、RawBlock格式，适配多种前端解析逻辑。

•主题管理要求：与标准MQTTBroker不同，TDengine的订阅主题需预先创建，不支持通过发布消息动态生成。

•通过taosX工具，可将数据库、超级表或查询订阅结果轻松发布至任意MQTTBroker，实现数据的高效同步与分发。

通过MQTT订阅，TDengineTSDB时序数据库与业务系统的联动效率进一步提升。这一能力让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新增“协变量预测”能力，在建模时不仅考虑目标变量自身的历史数值，还可引入天气、节假日等外部因素作为协变量，显著提升对复杂周期性变化的预测效果。

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

sql

select_frowts,forecast(val,past_co,future_co,"algo=moirai,rows=4,dynamic_val=[1111],dynamic_val_col=future_co")fromfoo;

多级存储支持共享存储(企业版)

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

•冷数据自动迁移：支持设定数据在本地保留时长，达到阈值后自动上传至共享存储

•按需查询：查询时自动加载所需数据块，确保性能与成本平衡

•多节点共享机制：主节点上传，副本节点复用，避免冗余

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

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

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

•在机载端部署TDengine，并通过RPC通信与地面系统交互

•在地面端通过SQL命令挂载机载磁盘目录，实现数据统一管理

sql

createmountmount1ondnode1from"/var/lib/TDengine"

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

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

SparkplugB数据接入(企业版)

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

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

•提升带宽利用率：相比原始MQTT，SparkplugB数据压缩率高达3倍，特别适用于低带宽网络环境。与Modbus相比，最高可节省75%至99.5%的带宽资源。

•标准化与互操作性强：为设备与系统间的数据交换提供统一数据语义，消除厂商壁垒，支持无缝对接SCADA、MES、ERP等企业系统，实现IT与OT的融合。

•数据可靠性更强：具备会话状态感知与双向通信能力，支持设备级闭环控制。

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

将订阅数据推送至MQTTBroker(企业版)

通过taosX工具，可将数据库、超级表或查询订阅结果轻松发布至任意MQTTBroker，实现数据的高效同步与分发。

其他优化项

•提升STMT2写入模式的易用性、稳定性和性能

•优化数据订阅Offset的更新逻辑

•支持将查询结果写入超级表

•增加WAL文件损坏的异常处理逻辑

•增加密码安全加密算法

•增加写入性能诊断的相关监测参数

•提升节点恢复和副本变更的性能

•支持更多生态组件：Superset、Quix、Ontop、Node-RED

•优化数据备份和恢复的功能、稳定性和性能

•扩展UDT(User-Defined-Transformer)支持的数据类型

除此之外，TDengineTSDB时序数据库新版本还包含了多项bug修复、功能优化等等。

关于TDengineTSDB时序数据库

TDengineTSDB是一款高性能、集群开源、云原生、极简的时序数据库，它能安全高效地将大量设备每天产生的高达TB甚至PB级的数据进行汇聚、存储、分析和分发，并提供AI智能体对数据进行预测与异常检测，提供实时的商业洞察。