qiaojialin commented on code in PR #400: URL: https://github.com/apache/iotdb-docs/pull/400#discussion_r1833824144
########## 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），及可选的自定义处理逻辑。 Review Comment: ```suggestion 1. **Topic（主题）**: Topic 是 IoTDB 的数据空间，由路径和时间范围表示（如 root.** 的全时间范围）。消费者可以订阅这些主题的数据（当前已有的和未来写入的）。不同于 Kafka，IoTDB 可在数据入库后再创建 Topic，且输出格式可选择消息或 TsFile 两种。 * 输出消息格式的特点：实时获取数据（与 Kafka 相同），适合流式处理场景 * 输出 TsFile：直接将 IoTDB 中的 TsFile 文件拷贝出来，适合数据备份、迁移场景 ``` -- 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}