Azure PostgreSQL 灵活服务器源设置指南

将 Azure PostgreSQL 灵活服务器配置为 ClickPipes 的源

ClickPipes 支持 Postgres 12 及以上版本。

​

启用逻辑复制

如果 wal_level 已设置为 logical，则无需执行以下步骤。如果你是从其他数据复制工具迁移过来的，通常该设置已经预先配置好了。

1. 点击 Server parameters 部分

2. 将 wal_level 设置为 logical

3. 此更改需要重启服务器，因此请在系统提示时进行重启。

​

创建 ClickPipes 用户并授予权限

通过管理员用户连接到你的 Azure Database for PostgreSQL 灵活服务器，并运行以下命令：

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

   CREATE USER clickpipes_user PASSWORD 'some-password';
   

2. 为你在上一步创建的用户授予 schema 级只读权限。以下示例展示了 public schema 的权限。请对每个包含你要复制的表的 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;
   

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

   ALTER USER clickpipes_user WITH REPLICATION;
   

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

publication 中包含的任何表都必须定义了主键，_或者_将其副本标识配置为 FULL。有关如何确定 publication 范围的指导，请参阅 Postgres 常见问题。

• 为特定表创建 publication：

  CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;
  

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

    CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";
    

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

​

将 ClickPipes IP 地址添加到防火墙

请按照以下步骤，将 ClickPipes IP 地址 添加到您的网络中。

1. 前往 Networking 选项卡，将 ClickPipes IP 地址 添加到 Azure Database for PostgreSQL 灵活服务器的防火墙中；如果您使用 SSH 隧道，请将其添加到 Jump Server/堡垒机的防火墙中。

​

下一步是什么？

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