Data Pipeline
TiDB Cloud Data Pipeline 可以将全量数据和增量变更从你的 TiDB Cloud 实例同步到 TiDB Cloud Lake,而无需借助第三方 ETL 工具。对于持续同步,它会先导出所选源数据的完整快照,然后持续同步行变更,以便 TiDB Cloud Lake 中的数据保持最新。
你可以在以下场景中使用 Data Pipeline:
- 一次性数据加载:将完整快照导出到 TiDB Cloud Lake,用于初始数据加载或迁移。
- 持续数据同步:使 TiDB Cloud Lake 与你的 TiDB Cloud 实例保持同步,以支持分析和报表工作负载。
工作原理
启用持续同步的 Data Pipeline 分两个阶段运行:
- 完整快照导出:将所选源表一次性导出到外部 stage,TiDB Cloud Lake 再从该 stage 加载快照。
- 增量同步:持续捕获并同步行变更(插入、修改和删除),使 TiDB Cloud Lake 与源端保持一致。
你也可以将管道配置为仅导出完整快照,而不进行持续同步。
外部 stage(Amazon S3 或 Alibaba Cloud OSS)用作 TiDB Cloud 实例与 TiDB Cloud Lake 之间的中间存储。TiDB Cloud 会将导出的快照和捕获到的行变更写入 stage,而 TiDB Cloud Lake 会将 stage 中的数据加载到目标计算集群 (Warehouse)。这种方式将写入速率与消费速率解耦,从而提高可靠性,并让你能够控制成本和延时。
更多信息,请参阅 Data Pipeline 常见问题。
可用性
创建 Data Pipeline
请参考适用于你的计划的指南:
- TiDB Cloud Premium:Set Up a Data Pipeline to TiDB Cloud Lake
- TiDB Cloud Dedicated:Manually set up a data pipeline to replicate data to TiDB Cloud Lake
- TiDB Cloud Essential:Sink to TiDB Cloud Lake
查看 Data Pipeline 页面
要查看和管理你的 Data Pipeline,请执行以下步骤:
在 TiDB Cloud console 中,进入 My TiDB 页面。
提示:
如果你属于多个组织,请先使用左上角的下拉框切换到目标组织。
点击目标 TiDB Cloud Premium 实例的名称进入其概览页面,然后在左侧导航栏中点击 Data > Data Pipeline。此时会显示 Data Pipeline 页面。
在 Data Pipeline 页面中,你可以创建 Data Pipeline、查看现有 Data Pipeline 列表,以及管理现有 Data Pipeline,例如暂停、恢复、编辑和删除管道。
管理 Data Pipeline
暂停和恢复 Data Pipeline
- Pause:停止数据同步,并将管道标记为
Paused。不会丢失数据,同步进度也会被保留。管道在创建过程中或导出完整快照期间无法暂停。 - Resume:从暂停的位置继续同步,包括继续将数据导入 TiDB Cloud Lake。
要暂停或恢复 Data Pipeline,请进入目标 TiDB Cloud Premium 实例的 Data Pipeline 页面,点击管道所在行中的 ...,然后点击 Pause 或 Resume。
编辑 Data Pipeline
要编辑 Data Pipeline,请进入目标 TiDB Cloud Premium 实例的 Data Pipeline 页面,点击管道所在行中的 ...,然后点击 Edit。
当 Data Pipeline 处于 Running 状态时,无法进行编辑。请先暂停管道,再进行编辑,之后恢复管道以使更改生效。
管道创建后,目标类型和同步模式都无法更改。
删除 Data Pipeline
要删除 Data Pipeline,请执行以下步骤:
进入目标 TiDB Cloud Premium 实例的 Data Pipeline 页面,点击管道所在行中的 ...,然后点击 Delete。
阅读警告并确认操作。删除 Data Pipeline 会:
- 立即停止所有数据同步。
- 尝试移除与该管道关联的 TiDB Cloud Lake 数据源和集成任务。如果移除失败,这些资源可能会保留,并需要手动清理。
- 不会 删除已经写入 TiDB Cloud Lake 的数据。
- 不会 删除计算集群中的目标数据库或表。
此操作无法撤销。
另请参阅
- 有关 Data Pipeline 的常见问题,请参阅 Data Pipeline 常见问题。
- 有关 DDL、DML 和列类型支持的详细信息,请参阅 TiDB Cloud Lake 的 Data Pipeline SQL 兼容性。