AlloyDB Postgres 数据源设置指南

要使用 ClickPipes 将数据从您的 AlloyDB 实例传输到 ClickHouse Cloud，您的实例必须配置为支持逻辑复制。此功能从 AlloyDB 14 版本开始受支持。

要检查 AlloyDB 实例是否已启用逻辑复制，请在主节点实例上运行以下查询：

SHOW  wal_level;

如果结果是 logical，则说明逻辑复制已启用，你可以跳到下一步。如果结果是 replica，则必须在主节点实例中将 alloydb.enable_pglogical 和 alloydb.logical_decoding 标志设为 on。

要启用这些标志，请执行以下操作：

1. 在 Google Cloud Console 中，前往 AlloyDB 的 Clusters 页面。在主节点实例对应的 Actions 菜单中，点击 Edit。

   

2. 向下滚动到 Advanced configuration options 并展开该部分。在 Flags 下，点击 Add a database flag。

   • 添加 allowdb.enable_pglogical 标志，并将其值设为 on
   • 添加 alloydb.logical_decoding 标志，并将其值设为 on

   

3. 点击 Update instance 保存配置更改。请注意，此操作会触发主节点实例重启。

4. 当实例状态从 Updating 变为 Ready 后，对主节点实例运行以下查询，以验证逻辑复制是否已启用：

   SHOW  wal_level;

   结果应为 logical。

   

以管理员用户身份连接到 AlloyDB 实例，然后执行以下命令：

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：

  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 流量，并降低整体复制效率。

接下来，选择 ClickPipes 连接到 AlloyDB 实例的方式。

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