Verwenden von „pgactive“ zur Unterstützung der Aktiv-Aktiv-Replikation

Um die erste RDS für SQL Postgre-DB-Instance mit der Erweiterung zu konfigurieren pgactive

Das folgende Beispiel zeigt, wie die pgactive Gruppe erstellt wird, zusammen mit anderen Schritten, die zum Erstellen der pgactive Erweiterung auf der RDS for SQL Postgre-DB-Instance erforderlich sind.

1. Verwenden Sie psql oder ein anderes Client-Tool, um eine Verbindung zu Ihrer ersten RDS for SQL Postgre-DB-Instance herzustellen.

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

2. Erstellen Sie mit dem folgenden Befehl eine Datenbank auf der RDS for SQL Postgre-Instance:

   postgres=> CREATE DATABASE app;

3. Wechseln Sie mit dem folgenden Befehl die Verbindung zur neuen Datenbank:

   \c app

4. Führen Sie den folgenden Befehl aus, um zu überprüfen, ob der Parameter „shared_preload_libraries“ „pgactive“ enthält:

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

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

5. Erstellen Sie eine Beispieltabelle und füllen Sie sie mit den folgenden Anweisungen aus: SQL

   1. Erstellen Sie mit der folgenden SQL Anweisung eine Beispieltabelle.

      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. Füllen Sie die Tabelle mit einigen Beispieldaten auf, indem Sie die folgende SQL Anweisung verwenden.

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

   3. Überprüfen Sie mithilfe der folgenden SQL Anweisung, ob Daten in der Tabelle vorhanden sind.

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

6. Erstellen Sie eine „pgactive“-Erweiterung für die bestehende Datenbank.

   app=> CREATE EXTENSION pgactive;

7. Erstellen und initialisieren Sie die Gruppe „pgactive“ mit den folgenden Befehlen:

   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 ist der Name, den Sie vergeben, um einen Knoten in der „pgactive“-Gruppe eindeutig zu identifizieren.

   Anmerkung

   Um diesen Schritt erfolgreich auf einer DB-Instance durchzuführen, auf die öffentlich zugegriffen werden kann, müssen Sie den Parameter „rds.custom_dns_resolution“ aktivieren, indem Sie ihn auf 1 setzen.

8. Verwenden Sie den folgenden Befehl, um zu überprüfen, ob die DB-Instance bereit ist:

   app=> SELECT pgactive.pgactive_wait_for_node_ready();

   Wird der Befehl erfolgreich ausgeführt, wird Ihnen die folgende Ausgabe angezeigt:

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

Um die zweite RDS für SQL Postgre-Instanz zu konfigurieren und sie der pgactive Gruppe hinzuzufügen

Das folgende Beispiel zeigt, wie Sie der pgactive Gruppe eine RDS for SQL Postgre-DB-Instance hinzufügen können, zusammen mit anderen Schritten, die zum Erstellen der pgactive Erweiterung auf der DB-Instance erforderlich sind.

Bei diesen Schritten wird davon ausgegangen, dass ein weiterer für SQL Postgre-DB-Instances mit der pgactive Erweiterung eingerichtet wurde. Weitere Informationen finden Sie unter Initialisierung der „pgactive“-Erweiterungsfunktion.

1. Verwenden Sie psql, um sich mit der Instance zu verbinden, die Updates vom Herausgeber erhalten soll.

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

2. Erstellen Sie mit dem folgenden Befehl eine Datenbank auf der zweiten RDS für SQL Postgre-DB-Instance:

   postgres=> CREATE DATABASE app;

3. Wechseln Sie mit dem folgenden Befehl die Verbindung zur neuen Datenbank:

   \c app

4. Erstellen Sie die „pgactive“-Erweiterung für die bestehende Datenbank.

   app=> CREATE EXTENSION pgactive;

5. Fügen Sie den für die SQL zweite Postgre-DB-Instance wie folgt der pgactive Gruppe hinzu.

   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 ist der Name, den Sie vergeben, um einen Knoten in der „pgactive“-Gruppe eindeutig zu identifizieren.

6. Verwenden Sie den folgenden Befehl, um zu überprüfen, ob die DB-Instance bereit ist:

   app=> SELECT pgactive.pgactive_wait_for_node_ready(); 

   Wird der Befehl erfolgreich ausgeführt, wird Ihnen die folgende Ausgabe angezeigt:

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

   Wenn die erste SQL Datenbank RDS für Postgre relativ groß ist, können Sie sehenpgactive.pgactive_wait_for_node_ready(), dass der Fortschrittsbericht über den Wiederherstellungsvorgang ausgegeben wird. Die Ausgabe sieht folgendermaßen oder ähnlich aus:

   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)
   

   Ab diesem Zeitpunkt werden die Daten zwischen den beiden DB-Instances durch „pgactive“ synchronisiert.

7. Sie können den folgenden Befehl verwenden, um zu überprüfen, ob die Datenbank der zweiten DB-Instance die Daten enthält:

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

   Wenn die Daten erfolgreich synchronisiert wurden, sehen Sie die folgende Ausgabe:

   
    count
   -------
    3

8. Führen Sie den folgenden Befehl aus, um neue Werte einzufügen:

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

9. Stellen Sie eine Verbindung zur Datenbank der ersten DB-Instance her und führen Sie die folgende Abfrage aus:

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

   Wenn die Aktiv-Aktiv-Replikation initialisiert ist, sieht die Ausgabe ungefähr wie folgt aus:

   count
   -------
    4

So trennen Sie eine DB-Instance von der „pgactive“-Gruppe und entfernen Sie daraus

Sie können eine DB-Instance mit den folgenden Schritten von der „pgactive“-Gruppe trennen und daraus entfernen:

1. Sie können die zweite DB-Instance mit dem folgenden Befehl von der ersten DB-Instance trennen:

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

2. Entfernen Sie die „pgactive“-Erweiterung mit dem folgenden Befehl aus der zweiten DB-Instance:

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

   So erzwingen Sie die Entfernung der Erweiterung:

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

3. Löschen Sie die Erweiterung mit dem folgenden Befehl:

   app=> DROP EXTENSION pgactive;