Google Cloud SQL Postgres 数据源设置指南

将 Google Cloud SQL Postgres 实例配置为 ClickPipes 的数据源

如果你使用的是受支持的提供商之一 (见侧边栏) ，请参阅该提供商对应的专门指南。

​

支持的 Postgres 版本

Postgres 12 及更高版本

​

启用逻辑复制

如果设置 cloudsql. logical_decoding 已开启，则无需执行以下步骤。如果你是从其他数据复制工具迁移而来，通常此设置已预先配置好。

1. 在 Overview 页面上点击 Edit 按钮。

2. 进入 Flags，将 cloudsql.logical_decoding 设置为 on。此更改需要重启 Postgres 服务器。

​

创建 ClickPipes 用户并授予权限

使用管理员用户连接到您的 Cloud SQL Postgres，并运行以下命令：

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。有关如何界定范围的指导，请参阅 Postgres FAQs。

• 为特定表创建 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 IP 添加到防火墙

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

如果您使用 SSH 隧道，则需要将 ClickPipes IP 添加到跳板机/堡垒机的防火墙规则中。

1. 前往 Connections 部分

2. 前往 Networking 子部分

3. 添加 ClickPipes 的公网 IP

​

下一步是什么？

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