Exemple : utilisation de la réplication logique avec des clusters de SQL base de données Aurora Postgre

Pour démarrer le processus de réplication logique entre deux clusters de SQL base de données Aurora Postgre

Ces étapes supposent que vos clusters de SQL base de données Aurora Postgre disposent d'une instance d'écriture avec une base de données dans laquelle créer les exemples de tables.

1. Sur le cluster de base de données Postgre SQL Aurora de l'éditeur

   1. Créez un tableau à l'aide de l'SQLinstruction suivante.

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. Insérez des données dans la base de données de l'éditeur en utilisant l'SQLinstruction suivante.

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

   3. Vérifiez que les données existent dans le tableau à l'aide de l'SQLinstruction suivante.

      SELECT count(*) FROM LogicalReplicationTest;

   4. Créez une publication pour cette table à l'aide de l'instruction CREATE PUBLICATION, comme suit.

      CREATE PUBLICATION testpub FOR TABLE LogicalReplicationTest;

2. Sur le cluster de SQL base de données Aurora Postgre abonné

   1. Créez la même table LogicalReplicationTest sur l'abonné que celle que vous avez créée sur l'éditeur, comme suit.

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. Vérifiez que cette table est vide.

      SELECT count(*) FROM LogicalReplicationTest;

   3. Créez un abonnement pour obtenir les modifications de la part de l'éditeur. Vous devez utiliser les informations suivantes concernant le cluster de SQL base de données Aurora Postgre de l'éditeur.

      • host — L'instance de base de données d'écriture du SQL cluster de base de données Aurora Postgre de l'éditeur.

      • port – Port sur lequel l'instance de base de données écoute. La valeur par défaut pour Postgre SQL est 5432.

      • dbname – Nom de la base de données.

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

      Note

      Spécifiez un mot de passe autre que celui indiqué ici, en tant que bonne pratique de sécurité.

      Une fois que l'abonnement est créé, un emplacement de réplication logique est créé chez l'éditeur.

   4. Pour vérifier dans cet exemple que les données initiales sont répliquées sur l'abonné, utilisez l'SQLinstruction suivante sur la base de données des abonnés.

      SELECT count(*) FROM LogicalReplicationTest;