一、介绍

IoTDB 数据同步功能可以将 IoTDB 的数据传输到另一个数据平台，我们将一个数据同步任务称为 Pipe。

一个 Pipe 包含三个子任务（插件）：

• 抽取（Extract）
• 处理（Process）
• 发送（Connect）

Pipe 允许用户自定义三个子任务的处理逻辑，通过类似 UDF 的方式处理数据。 在一个 Pipe 中，上述的子任务分别由三种插件执行实现，数据会依次经过这三个插件进行处理：Pipe Extractor 用于抽取数据，Pipe Processor 用于处理数据，Pipe Connector 用于发送数据，最终数据将被发至外部系统。

二、应用场景

Pipe 任务的模型如下：

描述一个数据同步任务，本质就是描述 Pipe Extractor、Pip