replicator 镜像文档

概述

replicator 是一个专用工具包，主要功能是将逻辑复制流摄入到 CockroachDB 集群中。它能够处理来自各类源数据库的逻辑复制数据，并将其高效、可靠地导入 CockroachDB 集群，支持数据同步与集成场景。

核心功能与特性

• 逻辑复制流处理：支持解析和处理标准逻辑复制协议（如 PostgreSQL 逻辑复制、Debezium 等）生成的复制流数据。
• CockroachDB 兼容性：针对 CockroachDB 架构特点优化，确保数据导入的兼容性和高性能。
• 数据可靠性保障：内置数据一致性校验和错误重试机制，保障复制过程的稳定性。
• 灵活配置：支持自定义数据转换规则和映射关系，适应不同数据模型和 schema 差异。

使用场景

• 实时数据同步：将源数据库（如 PostgreSQL、MySQL）的变更实时同步至 CockroachDB 集群。
• 灾备数据复制：作为跨集群数据复制工具，支持 CockroachDB 集群的灾备场景数据同步。
• 多源数据整合：将多个独立数据库或集群的逻辑复制数据集中导入 CockroachDB，实现数据集中管理。

使用方法

基本部署

通过 docker run 命令启动容器，基本格式如下：

bash
docker run -d \
  --name replicator \
  -e SOURCE_CONN_STRING="源数据库连接字符串" \
  -e COCKROACHDB_CONN_STRING="postgresql://user:password@cockroachdb-host:26257/dbname?sslmode=require" \
  replicator:latest

配置说明

核心环境变量

使用示例

以下示例将 PostgreSQL 源数据库的逻辑复制流导入 CockroachDB 集群：

bash
docker run -d \
  --name pg-to-cockroach \
  -e SOURCE_CONN_STRING="postgresql://repl_user:pass@pg-source:5432/source_db?replication=database" \
  -e COCKROACHDB_CONN_STRING="postgresql://root@cockroach-node:26257/target_db?sslmode=disable" \
  -e REPLICATION_SLOT="cockroach_repl_slot" \
  -e TABLE_MAPPING="public.orders:orders,public.users:users" \
  replicator:latest

注意事项

• 源数据库需提前配置逻辑复制（如创建复制槽、启用 WAL 归档等）。
• CockroachDB 集群需开放网络访问权限，且连接用户需具备数据写入权限（如 INSERT、UPDATE）。
• 建议根据数据量调整容器资源配置（如内存、CPU 限制），避免性能瓶颈。