支持的 Postgres 版本
ClickPipes 支持 Postgres 12 及以上版本。
启用逻辑复制
-
要在 Postgres 实例上启用复制,需要确保已设置以下参数:
wal_level = logical要检查这一点,可以运行以下 SQL 命令:
SHOW wal_level;默认情况下,输出应为
logical。如果不是,请登录 PlanetScale 控制台,前往Cluster configuration->Parameters,然后向下滚动到Write-ahead log进行修改。

- 此外,建议将
max_slot_wal_keep_size从默认的 4GB 调大。这同样需要在 PlanetScale 控制台中完成:前往Cluster configuration->Parameters,然后向下滚动到Write-ahead log。如需帮助确定新的值,请参阅此处。

创建具有相应权限和 publication 的用户
使用默认的 postgres.<...> 用户连接到您的 PlanetScale Postgres 实例,并运行以下命令:
-
为 ClickPipes 创建一个专用用户:
CREATE USER clickpipes_user PASSWORD 'some-password'; -
为上一步创建的用户授予 schema 级只读权限。以下示例展示了
publicschema 的权限。对于每个包含您要复制的表的 schema,都需要重复执行这些命令:GRANT USAGE ON SCHEMA "public" TO clickpipes_user; GRANT SELECT ON ALL TABLES IN SCHEMA "public" TO clickpipes_user; ALTER DEFAULT PRIVILEGES IN SCHEMA "public" GRANT SELECT ON TABLES TO clickpipes_user; -
为该用户授予复制特权:
ALTER USER clickpipes_user WITH REPLICATION; -
使用您要复制的表创建一个 publication。我们强烈建议只在 publication 中包含您确实需要的表,以避免额外的性能开销。
-
要为特定表创建 publication:
CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;-
要为特定 schema 中的所有表创建 publication:
CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";
-
clickpipes publication 定义了其变更事件将流式传输到 ClickPipes 的那组表。除非您打算复制每一张表,否则我们不建议使用 FOR ALL TABLES,因为包含不必要的表会增加从 Postgres 到 ClickPipes 的 WAL 流量,并降低整体复制效率。
注意事项
- 要连接到 PlanetScale Postgres,需要在上文创建的用户名后追加当前分支信息。例如,如果创建的用户名称为
clickpipes_user,那么在创建 ClickPipe 时填写的实际用户名应为clickpipes_user.branch,其中branch指当前 PlanetScale Postgres 分支的 “id”。要快速确认这一点,可以查看你此前用于创建该用户的postgres用户名,句点后面的部分就是分支 id。 - 对于连接到 PlanetScale Postgres 的 CDC (变更数据捕获) 管道,不要使用
PSBouncer端口 (当前为6432) ,必须使用标准端口5432。如果管道仅用于初始加载,则两个端口都可以使用。 - 请确保仅连接到主实例,目前连接到副本实例尚不受支持。
接下来做什么?
您现在可以创建 ClickPipe,并开始将来自 Postgres 实例的数据摄取到 ClickHouse Cloud。 请务必记下设置 Postgres 实例时使用的连接信息,因为在创建 ClickPipe 的过程中会用到这些信息。