Beispiel: Verwenden der logischen Replikation mit DB-Clustern von Aurora PostgreSQL

So starten Sie den logischen Replikationsprozess zwischen zwei DB-Clustern von Aurora PostgreSQL

Bei diesen Schritten wird davon ausgegangen, dass Ihre DB-Cluster von Aurora PostgreSQL über eine Writer-Instance mit einer Datenbank verfügen, in der die Beispieltabellen erstellt werden können.

1. Auf dem Herausgeber-DB-Cluster von Aurora PostgreSQL

   1. Erstellen Sie mit der folgenden SQL-Anweisung eine Tabelle.

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. Fügen Sie mit der folgenden SQL-Anweisung Daten in die Herausgebertabelle ein.

      INSERT INTO LogicalReplicationTest VALUES (generate_series(1,10000));

   3. Stellen Sie sicher, dass Daten in der Tabelle vorhanden sind, indem Sie die folgende SQL-Anweisung verwenden.

      SELECT count(*) FROM LogicalReplicationTest;

   4. Erstellen Sie eine Veröffentlichung für diese Tabelle, indem Sie die CREATE PUBLICATION-Anweisung wie folgt verwenden.

      CREATE PUBLICATION testpub FOR TABLE LogicalReplicationTest;

2. Auf dem Abonnenten-DB-Cluster von Aurora PostgreSQL

   1. Erstellen Sie wie folgt dieselbe LogicalReplicationTest-Tabelle auf dem Abonnenten, die Sie auf dem Herausgeber erstellt haben.

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. Stellen Sie sicher, dass diese Tabelle leer ist.

      SELECT count(*) FROM LogicalReplicationTest;

   3. Erstellen Sie ein Abonnement, um die Änderungen vom Herausgeber zu erhalten. Sie müssen die folgenden Details über den Herausgeber-DB-Cluster von Aurora PostgreSQL verwenden.

      • host – Die Writer-DB-Instance des Herausgeber-DB-Clusters von Aurora PostgreSQL.

      • port – Der Port, den die Writer-DB-Instance überwacht. Der Standardwert für PostgreSQL lautet 5432.

      • dbname – Der Name der Datenbank.

      CREATE SUBSCRIPTION testsub CONNECTION 
         'host=publisher-cluster-writer-endpoint port=5432 dbname=db-name user=user password=password' 
         PUBLICATION testpub; 
      

      Anmerkung

      Geben Sie aus Sicherheitsgründen ein anderes Passwort als hier angegeben an.

      Nachdem das Abonnement erstellt wurde, wird für den Herausgeber ein Slot für die logische Replikation erstellt.

   4. Um für dieses Beispiel zu überprüfen, dass das Anfangsdatum für den Abonnenten repliziert wird, verwenden Sie die folgende SQL-Anweisung für die Abonnenten-Datenbank.

      SELECT count(*) FROM LogicalReplicationTest;