目录
- 一、介绍
- 二、应用场景
- 三、IoTDB 数据库搭建
- 四、数据同步
一、介绍
IoTDB 数据同步功能可以将 IoTDB 的数据传输到另一个数据平台,我们将一个数据同步任务称为 Pipe。
一个 Pipe 包含三个子任务(插件):
- 抽取(Extract)
- 处理(Process)
- 发送(Connect)
Pipe 允许用户自定义三个子任务的处理逻辑,通过类似 UDF 的方式处理数据。 在一个 Pipe 中,上述的子任务分别由三种插件执行实现,数据会依次经过这三个插件进行处理:Pipe Extractor 用于抽取数据,Pipe Processor 用于处理数据,Pipe Connector 用于发送数据,最终数据将被发至外部系统。
二、应用场景
Pipe 任务的模型如下:
描述一个数据同步任务,本质就是描述 Pipe Extractor、Pip