使用 pgactive 支持主动-主动复制

使用 pgactive 扩展配置第一个 RDS for PostgreSQL 数据库实例

以下示例说明如何创建 pgactive 组，以及在 RDS for PostgreSQL 数据库实例上创建 pgactive 扩展所需的其它步骤。

1. 使用 psql 或其它客户端工具连接第一个 RDS for PostgreSQL 数据库实例。

   psql --host=firstinstance.111122223333.aws-region.rds.amazonaws.com --port=5432 --username=master username --password --dbname=postgres
   

2. 使用以下命令在 RDS for PostgreSQL 实例上创建数据库：

   postgres=> CREATE DATABASE app;

3. 使用以下命令将连接切换到新数据库：

   \c app

4. 要检查 shared_preload_libraries 参数是否包含 pgactive，请运行以下命令：

   app=>SELECT setting ~ 'pgactive' FROM pg_catalog.pg_settings WHERE name = 'shared_preload_libraries';

   
    ?column? 
   ----------
    t

5. 使用以下 SQL 语句创建并填充示例表：

   1. 使用以下 SQL 语句创建一个示例表。

      app=> CREATE SCHEMA inventory;
      CREATE TABLE inventory.products (
      id int PRIMARY KEY, product_name text NOT NULL,
      created_at timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP);

   2. 使用以下 SQL 语句用一些示例数据填充表。

      app=> INSERT INTO inventory.products (id, product_name)
      VALUES (1, 'soap'), (2, 'shampoo'), (3, 'conditioner');
      

   3. 使用以下 SQL 语句验证表中是否存在数据。

       app=>SELECT count(*) FROM inventory.products;
      
       count
      -------
       3

6. 在现有数据库上创建 pgactive 扩展。

   app=> CREATE EXTENSION pgactive;

7. 使用以下命令创建并初始化 pgactive 组：

   app=> SELECT pgactive.pgactive_create_group(
       node_name := 'node1-app',
       node_dsn := 'dbname=app host=firstinstance.111122223333.aws-region.rds.amazonaws.com user=master username password=PASSWORD');

   node1-app 是您分配的名称，用于唯一标识 pgactive 组中的节点。

   注意

   要在可公开访问的数据库实例上成功执行此步骤，必须通过将 rds.custom_dns_resolution 参数设置为 1 将其开启。

8. 要检查数据库实例是否就绪，请使用以下命令：

   app=> SELECT pgactive.pgactive_wait_for_node_ready();

   如果命令成功，您可以看到以下输出：

   
   pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

配置第二个 RDS for PostgreSQL 实例并将其加入 pgactive 组

以下示例说明如何将 RDS for PostgreSQL 数据库实例加入 pgactive 组，以及在数据库实例上创建 pgactive 扩展所需的其它步骤。

这些步骤假设已使用 pgactive 扩展设置了其它 RDS for PostgreSQL 数据库实例。有关更多信息，请参阅 初始化 pgactive 扩展功能。

1. 使用 psql 连接到要从发布者接收更新的实例。

   psql --host=secondinstance.111122223333.aws-region.rds.amazonaws.com --port=5432 --username=master username --password --dbname=postgres
   

2. 使用以下命令在第二个 RDS for PostgreSQL 数据库实例上创建数据库：

   postgres=> CREATE DATABASE app;

3. 使用以下命令将连接切换到新数据库：

   \c app

4. 在现有数据库上创建 pgactive 扩展。

   app=> CREATE EXTENSION pgactive;

5. 将 RDS for PostgreSQL 第二个数据库实例加入 pgactive 组，如下所示。

   app=> SELECT pgactive.pgactive_join_group(
   node_name := 'node2-app',
   node_dsn := 'dbname=app host=secondinstance.111122223333.aws-region.rds.amazonaws.com user=master username password=PASSWORD',
   join_using_dsn := 'dbname=app host=firstinstance.111122223333.aws-region.rds.amazonaws.com user=postgres password=PASSWORD');

   node2-app 是您分配的名称，用于唯一标识 pgactive 组中的节点。

6. 要检查数据库实例是否就绪，请使用以下命令：

   app=> SELECT pgactive.pgactive_wait_for_node_ready(); 

   如果命令成功，您可以看到以下输出：

   
   pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

   如果第一个 RDS for PostgreSQL 数据库相对较大，则可以看到 pgactive.pgactive_wait_for_node_ready() 正在发出还原操作的进度报告。输出看上去类似于以下内容：

   NOTICE:  restoring database 'app', 6% of 7483 MB complete
   NOTICE:  restoring database 'app', 42% of 7483 MB complete
   NOTICE:  restoring database 'app', 77% of 7483 MB complete
   NOTICE:  restoring database 'app', 98% of 7483 MB complete
   NOTICE:  successfully restored database 'app' from node node1-app in 00:04:12.274956
    pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

   此后，pgactive 将在两个数据库实例之间同步数据。

7. 您可以使用以下命令来验证第二个数据库实例的数据库是否具有数据：

   app=> SELECT count(*) FROM inventory.products;

   如果数据成功同步，您将看到以下输出：

   
    count
   -------
    3

8. 运行以下命令插入新值：

   app=> INSERT INTO inventory.products (id, product_name) VALUES ('lotion');

9. 连接到第一个数据库实例的数据库并运行以下查询：

   app=> SELECT count(*) FROM inventory.products;

   如果已初始化主动-主动复制，则输出类似于以下内容：

   count
   -------
    4

从 pgactive 组中分离和移除数据库实例

您可以使用以下步骤从 pgactive 组中分离和移除数据库实例：

1. 您可以使用以下命令将第二个数据库实例与第一个数据库实例分离：

   app=> SELECT * FROM pgactive.pgactive_detach_nodes(ARRAY[‘node2-app']);

2. 使用以下命令从第二个数据库实例中移除 pgactive 扩展：

   app=> SELECT * FROM pgactive.pgactive_remove();

   要强制移除此扩展，请执行以下操作：

   app=> SELECT * FROM pgactive.pgactive_remove(true);

3. 使用以下命令删除扩展：

   app=> DROP EXTENSION pgactive;