跳转到主内容
跳转到主内容

Crunchy Bridge Postgres 源端设置指南

ClickPipes 支持 Postgres 12 及更高版本。

启用逻辑复制​

Crunchy Bridge 默认已启用逻辑复制。请确保下列设置已正确配置；如未正确配置，请根据需要进行调整。

SHOW wal_level; -- should be logical
SHOW max_wal_senders; -- should be 10
SHOW max_replication_slots; -- should be 10

创建 ClickPipes 用户并授予权限​

通过 postgres 用户连接到你的 Crunchy Bridge Postgres，并运行以下命令：

  1. 为 ClickPipes 创建一个专用用户：

    CREATE USER clickpipes_user PASSWORD 'some-password';

  2. 为你在上一步创建的用户授予模式级的只读访问权限。下面的示例展示了对 public 模式的权限设置。对于每个包含你希望复制的表的模式，都需要重复执行这些命令：

    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;

  3. 为该用户授予复制权限：

     ALTER USER clickpipes_user WITH REPLICATION;

  4. 使用你想要复制的表创建一个 publication。我们强烈建议仅将所需的表包含在 publication 中，以避免额外的性能开销。

    注意

    任何包含在 publication 中的表必须要么定义了 主键，要么将其 replica identity 配置为 FULL。有关作用范围设定的指导，请参考 Postgres 常见问题。

    • 为特定表创建 publication：

      CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;

    • 为特定模式中的所有表创建 publication：

      CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";

    clickpipes publication 将包含由指定表生成的一组变更事件，随后会用于摄取复制流。

将 ClickPipes IP 加入允许列表​

在 Crunchy Bridge 中添加 Firewall Rules，将 ClickPipes IPs 加入允许列表。

在 Crunchy Bridge 中查找 Firewall Rules 的位置
在 Crunchy Bridge 中为 ClickPipes 添加 Firewall Rules

后续步骤​

现在可以创建你的 ClickPipe，并开始从 Postgres 实例向 ClickHouse Cloud 摄取数据。 请务必记录在设置 Postgres 实例时使用的连接信息，因为在创建 ClickPipe 的过程中将需要这些信息。