Google Cloud SQL Postgres 源端设置指南

信息

如果您使用侧边栏中列出的受支持提供商之一，请参阅该提供商的相应指南。

支持的 Postgres 版本

Postgres 12 及更高版本

启用逻辑复制

如果 cloudsql. logical_decoding 已经为 on 且 wal_sender_timeout 为 0，则无需执行以下步骤。若您是从其他数据复制工具迁移，这些设置通常已经预先配置好。

在概览页面点击 Edit 按钮。

打开 Flags，将 cloudsql.logical_decoding 修改为 on，并将 wal_sender_timeout 修改为 0。这些更改需要重启您的 Postgres 服务器才能生效。

已修改 cloudsql.logical_decoding 和 wal_sender_timeout

创建 ClickPipes 用户并授予权限

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

为 ClickPipes 创建一个专用用户：

CREATE USER clickpipes_user PASSWORD 'some-password';

为上一步创建的用户授予 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;

为该用户授予复制权限：

ALTER USER clickpipes_user WITH REPLICATION;

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

注意
包含在 publication 中的任意表必须定义有 primary key，或者将其 replica identity 配置为 FULL。关于作用域设置的指导，请参阅 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 将包含由指定表生成的变更事件集合，之后会被用于摄取复制流。