qiaojialin commented on code in PR #400: URL: https://github.com/apache/iotdb-docs/pull/400#discussion_r1833768084
########## src/zh/UserGuide/Master/User-Manual/Data-subscription.md: ########## @@ -0,0 +1,428 @@ +# 数据订阅 + +## 1. 功能介绍 + +IoTDB 数据订阅模块（又称 IoTDB 订阅客户端）是IoTDB V1.3.3 版本后支持的功能，它为用户提供了一种区别于数据查询的流式数据消费方式。它参考了 Kafka 等消息队列产品的基本概念和逻辑，**提供数据订阅和消费接口**，但并不是为了完全替代这些消费队列的产品，更多的是在简单流式获取数据的场景为用户提供更加便捷的数据订阅服务。 + +在下面应用场景中，使用 IoTDB 订阅客户端消费数据会有显著的优势： + +1. **替换大量数据的轮询查询**：避免查询频率高、测点多时，轮询查询对原有系统性能的较大影响；避免查询范围不好确定问题，可保证下游拿到准确全量的数据； +2. **与下游系统快速集成**：更方便对接 Flink、Spark、Kafka / DataX、Camel / MySQL、PG 等系统组件。不需要为每一个大数据组件，单独定制开发 IoTDB 的变更捕获等逻辑，可简化集成组件设计，提升开发效率。 + +## 2. 主要概念 + +IoTDB 订阅客户端包含 3 个核心概念：Topic、Consumer、Consumer Group，具体关系如下图 + +<div align="center"> + <img src="https://alioss.timecho.com/docs/img/Data_sub_05.png"; alt="" style="width: 60%;"/> +</div> + +1. **Topic（主题）**: Topic 是 IoTDB 订阅客户端中用于分类数据的逻辑概念，可以看作是数据的发布通道。生产者将数据发布到特定的主题，而消费者则订阅这些主题以接收相关数据。不同于 Kafka，在 IoTDB 订阅客户端中，主题对应了待订阅的序列和时间范围，输出格式（消息或 TsFile），及可选的自定义处理逻辑。 + +2. **Consumer（消费者）**: Consumer 是 IoTDB 订阅客户端有所在的应用程序或服务，负责接收和处理发布到特定 Topic 的数据。Consumer 从队列中获取数据并进行相应的处理。在 IoTDB 订阅客户端中提供了两种类型的 Consumers: Review Comment: ```suggestion 2. **Consumer（消费者）**: Consumer 是 IoTDB 的订阅客户端，负责接收和处理发布到特定 Topic 的数据。Consumer 从队列中获取数据并进行相应的处理。在 IoTDB 订阅客户端中提供了两种类型的 Consumers: ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
![https://alioss.timecho.com/docs/img/Data_sub_05.png"](https://alioss.timecho.com/docs/img/Data_sub_05.png"){kind=link}