Exemple : utilisation de la réplication logique avec les clusters de bases de données Aurora PostgreSQL

Démarrer le processus de réplication logique entre deux clusters de bases de données Aurora PostgreSQL

Ces étapes supposent que vos clusters de bases de données Aurora PostgreSQL disposent d’une instance d’enregistreur avec une base de données dans laquelle créer les tables d’exemple.

1. Sur le cluster de bases de données Aurora PostgreSQL de l’éditeur

   1. Créez une table en utilisant l’instruction SQL suivante.

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. Insérez les données dans la base de données éditeur à l’aide de l’instruction SQL suivante.

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

   3. Vérifiez que les données existent dans la table à l’aide de l’instruction SQL 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 bases de données Aurora PostgreSQL de l’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 bases de données Aurora PostgreSQL de l’éditeur.

      • host – Instance de base de données en écriture du cluster de bases de données Aurora PostgreSQL de l’éditeur.

      • port – Port sur lequel l’instance de base de données écoute. La valeur par défaut pour PostgreSQL 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’instruction SQL suivante sur la base de données abonné.

      SELECT count(*) FROM LogicalReplicationTest;