重要更新亮点
全新架构流计算:性能更高,能力更强
本次发布的全新流计算系统,围绕灵活性、稳定性与可运维性进行深度升级,具备以下核心特性:
• 触发与计算分离:支持触发与计算分离,计算不再受限于触发数据源,可作用于任意表,甚至无需触发表,灵活适配复杂流程;
• 触发机制更灵活:支持定时触发、滑动触发、窗口触发(时间/事件/会话/状态/计数),支持窗口开/关窗分别触发,并可预过滤输入数据。
• 计算逻辑增强:支持任意 SQL 查询,支持窗口参数占位符,计算结果可写入表、发送通知,或同时执行。
• 通知机制更完善:支持基于 WebSocket 的窗口事件通知,并可配置触发条件、失败重试策略。
• 资源调度更灵活:计算过程可在 snode 节点上独立运行,多节点负载均衡与高可用,提升系统稳定性。
此外,新版本特别强化了异常数据重算机制,支持通过选项控制是否自动重算,并可结合 WATERMARK 等多个控制选项实现乱序容忍、数据删除后的结果修复。
流计算重构为 TDengine 带来了更强的事件处理能力,是构建低延迟报警、预测分析、实时特征提取等场景的核心基础。也为TDengine 最新发布的 AI 原生工业数据管理平台IDMP 的实时分析等功能提供强有力支持。
支持 MQTT 协议数据订阅:零代码集成更简单
MQTT 作为工业领域主流的消息协议,TDengine TSDB 时序数据库新增对 MQTT 的原生订阅支持:
• bnode 模块上线:作为 Broker 提供服务,用户可通过标准 MQTT 客户端直接订阅数据,无需额外开发。
• 共享订阅与消费组机制:支持负载均衡与高可用,客户端断连可自动切换,消息可在组内自动重分配。
• 多种数据格式支持:支持 JSON、Raw Block 格式,适配多种前端解析逻辑。
• 订阅位置控制:支持 latest、earliest 起始订阅位置,以及持久化和离线消息处理。
• 主题管理要求:与标准 MQTT Broker 不同,TDengine 的订阅主题需预先创建,不支持通过发布消息动态生成。
• 通过 taosX 工具,可将数据库、超级表或查询订阅结果轻松发布至任意 MQTT Broker,实现数据的高效同步与分发。
通过 MQTT 订阅,TDengine TSDB 时序数据库与业务系统的联动效率进一步提升。这一能力让 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=[1 1 1 1], dynamic_val_col=future_co") from foo;
多级存储支持共享存储(企业版)
针对冷数据管理需求,3.3.7.0 正式支持多种共享存储(如 SAN、NAS、S3、DFS),实现:
• 冷数据自动迁移:支持设定数据在本地保留时长,达到阈值后自动上传至共享存储
• 按需查询:查询时自动加载所需数据块,确保性能与成本平衡
• 多节点共享机制:主节点上传,副本节点复用,避免冗余
这一能力特别适合对存储成本敏感、历史数据不常访问但不能丢弃的工业企业与能源场景。
天脉系统适配及数据挂载支持(企业版)
为了更好地服务国产化、军工与航天等高安全行业客户,TDengine 企业版现已完成对天脉系统(ACoreOS)的适配。作为由中航工业计算所自主研发的国产机载实时操作系统,天脉广泛应用于工业控制、航空航天等关键领域。新版本支持:
• 在机载端部署 TDengine,并通过 RPC 通信与地面系统交互
• 在地面端通过 SQL 命令挂载机载磁盘目录,实现数据统一管理
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 等传统工业协议相比,其在带宽利用率、部署简便性和可扩展性方面表现尤为突出。
将订阅数据推送至 MQTT Broker(企业版)
通过 taosX 工具,可将数据库、超级表或查询订阅结果轻松发布至任意 MQTT Broker,实现数据的高效同步与分发。
其他优化项
• 提升 STMT2 写入模式的易用性、稳定性和性能
• 优化数据订阅 Offset 的更新逻辑
• 支持将查询结果写入超级表
• 增加 WAL 文件损坏的异常处理逻辑
• 增加密码安全加密算法
• 增加写入性能诊断的相关监测参数
• 提升节点恢复和副本变更的性能
• 支持更多生态组件:Superset、Quix、Ontop、Node-RED
• 优化数据备份和恢复的功能、稳定性和性能
• 扩展 UDT(User-Defined-Transformer)支持的数据类型
除此之外,TDengine TSDB 时序数据库新版本还包含了多项 bug 修复、功能优化等等。
关于 TDengine TSDB 时序数据库
TDengine TSDB 是一款高性能、集群开源、云原生、极简的时序数据库,它能安全高效地将大量设备每天产生的高达 TB 甚至 PB 级的数据进行汇聚、存储、分析和分发,并提供 AI 智能体对数据进行预测与异常检测,提供实时的商业洞察。