| const e=JSON.parse('{"key":"v-39bf54dc","path":"/zh/UserGuide/V1.2.x/User-Manual/IoTDB-Data-Pipe_timecho.html","title":"IoTDB 数据订阅","lang":"zh-CN","frontmatter":{"description":"IoTDB 数据订阅功能可以将 IoTDB 的数据传输到另一个数据平台，我们将一个数据订阅任务称为 Pipe。 一个 Pipe 包含三个子任务（插件）： 抽取（Extract）; 处理（Process）; 发送（Connect）; Pipe 允许用户自定义三个子任务的处理逻辑，通过类似 UDF 的方式处理数据。 在一个 Pipe 中，上述的子任务分别由...","head":[["link",{"rel":"alternate","hreflang":"en-us","href":"https://iotdb.apache.org/UserGuide/V1.2.x/User-Manual/IoTDB-Data-Pipe_timecho.html"}],["meta",{"property":"og:url","content":"https://iotdb.apache.org/zh/UserGuide/V1.2.x/User-Manual/IoTDB-Data-Pipe_timecho.html"}],["meta",{"property":"og:site_name","content":"IoTDB Website"}],["meta",{"property":"og:title","content":"IoTDB 数据订阅"}],["meta",{"property":"og:description","content":"IoTDB 数据订阅功能可以将 IoTDB 的数据传输到另一个数据平台，我们将一个数据订阅任务称为 Pipe。 一个 Pipe 包含三个子任务（插件）： 抽取（Extract）; 处理（Process）; 发送（Connect）; Pipe 允许用户自定义三个子任务的处理逻辑，通过类似 UDF 的方式处理数据。 在一个 Pipe 中，上述的子任务分别由..."}],["meta",{"property":"og:type","content":"article"}],["meta",{"property":"og:locale","content":"zh-CN"}],["meta",{"property":"og:locale:alternate","content":"en-US"}],["meta",{"property":"og:updated_time","content":"2023-08-25T10:05:26.000Z"}],["meta",{"property":"article:modified_time","content":"2023-08-25T10:05:26.000Z"}],["script",{"type":"application/ld+json"},"{\\"@context\\":\\"https://schema.org\\",\\"@type\\":\\"Article\\",\\"headline\\":\\"IoTDB 数据订阅\\",\\"image\\":[\\"\\"],\\"dateModified\\":\\"2023-08-25T10:05:26.000Z\\",\\"author\\":[]}"]]},"headers":[{"level":2,"title":"快速开始","slug":"快速开始","link":"#快速开始","children":[]},{"level":2,"title":"Pipe 同步任务管理","slug":"pipe-同步任务管理","link":"#pipe-同步任务管理","children":[{"level":3,"title":"创建流水线","slug":"创建流水线","link":"#创建流水线","children":[]},{"level":3,"title":"启动流水线","slug":"启动流水线","link":"#启动流水线","children":[]},{"level":3,"title":"停止流水线","slug":"停止流水线","link":"#停止流水线","children":[]},{"level":3,"title":"删除流水线","slug":"删除流水线","link":"#删除流水线","children":[]},{"level":3,"title":"展示流水线","slug":"展示流水线","link":"#展示流水线","children":[]},{"level":3,"title":"流水线运行状态迁移","slug":"流水线运行状态迁移","link":"#流水线运行状态迁移","children":[]}]},{"level":2,"title":"系统预置数据订阅插件","slug":"系统预置数据订阅插件","link":"#系统预置数据订阅插件","children":[{"level":3,"title":"预置 extractor","slug":"预置-extractor","link":"#预置-extractor","children":[]},{"level":3,"title":"预置 processor","slug":"预置-processor","link":"#预置-processor","children":[]},{"level":3,"title":"预置 connector","slug":"预置-connector","link":"#预置-connector","children":[]}]},{"level":2,"title":"自定义数据订阅插件开发","slug":"自定义数据订阅插件开发","link":"#自定义数据订阅插件开发","children":[{"level":3,"title":"编程开发依赖","slug":"编程开发依赖","link":"#编程开发依赖","children":[]},{"level":3,"title":"事件驱动编程模型","slug":"事件驱动编程模型","link":"#事件驱动编程模型","children":[]},{"level":3,"title":"自定义数据订阅插件编程接口定义","slug":"自定义数据订阅插件编程接口定义","link":"#自定义数据订阅插件编程接口定义","children":[]}]},{"level":2,"title":"自定义数据订阅插件管理","slug":"自定义数据订阅插件管理","link":"#自定义数据订阅插件管理","children":[{"level":3,"title":"加载插件语句","slug":"加载插件语句","link":"#加载插件语句","children":[]},{"level":3,"title":"删除插件语句","slug":"删除插件语句","link":"#删除插件语句","children":[]},{"level":3,"title":"查看插件语句","slug":"查看插件语句","link":"#查看插件语句","children":[]}]},{"level":2,"title":"权限管理","slug":"权限管理","link":"#权限管理","children":[{"level":3,"title":"Pipe 任务","slug":"pipe-任务","link":"#pipe-任务","children":[]},{"level":3,"title":"Pipe 插件","slug":"pipe-插件","link":"#pipe-插件","children":[]}]},{"level":2,"title":"配置参数","slug":"配置参数","link":"#配置参数","children":[]},{"level":2,"title":"功能特性","slug":"功能特性","link":"#功能特性","children":[{"level":3,"title":"最少一次语义保证 at-least-once","slug":"最少一次语义保证-at-least-once","link":"#最少一次语义保证-at-least-once","children":[]},{"level":3,"title":"源端：数据写入与 Pipe 处理、发送数据异步解耦","slug":"源端-数据写入与-pipe-处理、发送数据异步解耦","link":"#源端-数据写入与-pipe-处理、发送数据异步解耦","children":[]},{"level":3,"title":"源端：可自适应数据写入负载的数据传输策略","slug":"源端-可自适应数据写入负载的数据传输策略","link":"#源端-可自适应数据写入负载的数据传输策略","children":[]},{"level":3,"title":"源端：高可用集群部署时，Pipe 服务高可用","slug":"源端-高可用集群部署时-pipe-服务高可用","link":"#源端-高可用集群部署时-pipe-服务高可用","children":[]}]}],"git":{"createdTime":1692957926000,"updatedTime":1692957926000,"contributors":[{"name":"Beyyes","email":"cgf1993@foxmail.com","commits":1}]},"readingTime":{"minutes":28.51,"words":8553},"filePathRelative":"zh/UserGuide/V1.2.x/User-Manual/IoTDB-Data-Pipe_timecho.md","localizedDate":"2023年8月25日","autoDesc":true}');export{e as data}; |