使用逻辑复制对 Aurora PostgreSQL 执行主要版本升级

在下面的示例中，源写入器实例（蓝色）是运行 PostgreSQL 版本 11.15 的 Aurora PostgreSQL 数据库集群。这是我们复制场景中的发布节点。对于本演示，我们的源代码编写器实例托管了一个包含一系列值的示例表：

CREATE TABLE my_table (a int PRIMARY KEY);
INSERT INTO my_table VALUES (generate_series(1,100));

要在源实例上创建发布，请使用 psql（PostgreSQL 的 CLI）或您选择的客户端连接到该实例的写入器节点。在每个数据库中输入以下命令：

CREATE PUBLICATION publication_name FOR ALL TABLES;

publication_name 指定发布的名称。

您还需要在实例上创建复制插槽。以下命令创建复制插槽并加载 pgoutput 逻辑解码插件。该插件将读取的内容从预写日志（WAL）更改为逻辑复制协议，并根据发布规范筛选数据。

SELECT pg_create_logical_replication_slot('replication_slot_name', 'pgoutput');

使用 Amazon RDS 控制台创建源实例的克隆。在 Amazon RDS 控制台中突出显示实例名称，然后在 Actions（操作）菜单中选择 Create clone（创建克隆）。

为实例提供唯一名称。大多数设置是源实例中的缺省设置。当您对新实例进行了所需的更改后，选择 Create clone（创建克隆）。

当目标实例启动时，写入器节点的 Status（状态）列在 Status（状态）列中显示 Creating（正在创建）。在实例准备就绪后，状态将变为 Available（可用）。

克隆是部署模型中的“绿色”实例。它是复制订阅节点的主机。当节点变为可用时，连接 psql 并查询新的写入器节点以获取日志序列号（LSN）。LSN 标识 WAL 流中记录的开头。

SELECT aurora_volume_logical_start_lsn();

在查询的响应中，您可以找到 LSN 编号。您稍后在此过程中需要这个编号，所以请记下它。

postgres=> SELECT aurora_volume_logical_start_lsn();
aurora_volume_logical_start_lsn 
---------------
0/402E2F0
(1 row)

在升级克隆之前，删除克隆的复制插槽。

SELECT pg_drop_replication_slot('replication_slot_name');

当升级后克隆变为可用时，连接到 psql 并定义订阅。为此，您需要在 CREATE SUBSCRIPTION 命令中指定以下选项：

CREATE SUBSCRIPTION subscription_name 
CONNECTION 'postgres://admin_user_name:admin_user_password@source_instance_URL/database' PUBLICATION publication_name 
WITH (copy_data = false, create_slot = false, enabled = false, connect = true, slot_name = 'replication_slot_name');

创建订阅后，查询 pg_replication_origin 视图以检索 roname 值，该值是复制源的标识符。每个实例都有一个 roname：

SELECT * FROM pg_replication_origin;

例如：

postgres=> 
SELECT * FROM pg_replication_origin;
 
roident | roname 
---------+----------
1 | pg_24586

在命令中提供您在发布节点的先前查询中保存的 LSN 以及从订阅节点 [实例]返回的 roname。此命令使用 pg_replication_origin_advance 函数指定要复制的日志序列的起点。

SELECT pg_replication_origin_advance('roname', 'log_sequence_number');

roname 是 pg_replication_origin 视图返回的标识符。

log_sequence_number 是 aurora_volume_logical_start_lsn 函数的先前查询返回的值。

然后，使用 ALTER SUBSCRIPTION... ENABLE 子句开启逻辑复制。

ALTER SUBSCRIPTION subscription_name ENABLE;

此时，您可以确认复制正在运行。向发布实例添加一个值，然后确认该值已复制到订阅节点。

然后，使用以下命令监控发布节点上的复制滞后：

SELECT now() AS CURRENT_TIME, slot_name, active, active_pid, pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(),
confirmed_flush_lsn)) AS diff_size, pg_wal_lsn_diff(pg_current_wal_lsn(),
confirmed_flush_lsn) AS diff_bytes FROM pg_replication_slots WHERE slot_type = 'logical';

例如：

postgres=> SELECT now() AS CURRENT_TIME, slot_name, active, active_pid, pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(), 
confirmed_flush_lsn)) AS diff_size, pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn) AS diff_bytes FROM pg_replication_slots WHERE slot_type = 'logical';
 
current_time                   | slot_name             | active | active_pid | diff_size | diff_bytes 
-------------------------------+-----------------------+--------+------------+-----------+------------
2022-04-13 15:11:00.243401+00  | replication_slot_name | t      | 21854      | 136 bytes | 136
(1 row)

您可以使用 diff_size 和 diff_bytes 值监控复制滞后。当这些值达到 0 时，即表示副本已赶上源数据库实例进度。