数据订阅

为了满足应用程序实时获取 TDengine TSDB 写入的数据的需求，或以事件到达顺序处理数据，TDengine TSDB 提供了类似于消息队列产品的数据订阅和消费接口。在许多场景中，采用 TDengine TSDB 的时序大数据平台，无须再集成消息队列产品，从而简化应用程序设计并降低运维成本。

📄️ 简介

与 Kafka 类似，用户需要在 TDengine TSDB 中定义主题（topic）。TDengine TSDB 的主题可以是一个数据库、一张超级表，或者基于现有超级表、子表或普通表的查询条件，即一条查询语句。用户可以利用 SQL 对标签、表名、列、表达式等条件进行过滤，并对数据进行标量函数与 UDF 计算（不包括数据聚合）。与其他消息队列工具相比，这是 TDengine TSDB 数据订阅功能的最大优势。它提供了更高的灵活性，数据的粒度由定义主题的 SQL 决定，而且数据的过滤与预处理由 TDengine TSDB 自动完成，从而减少传输的数据量并降低应用程序的复杂度。

📄️ Native 数据订阅

TDengine TSDB 提供了类似于消息队列产品的数据订阅和消费接口。在许多场景中，采用 TDengine TSDB 的时序大数据平台，无须再集成消息队列产品，从而简化应用程序设计并降低运维成本。数据订阅的主题管理等基础知识参考 文档 ，详细 API 可参考 开发指南。

📄️ MQTT 数据订阅

TDengine TSDB v3.3.7.0 版本开始提供 MQTT 订阅功能，通过 MQTT 客户端连接 TDengine TSDB Bnode 服务，可直接订阅系统中已有主题的数据。