Replicación lógica para Amazon RDS para PostgreSQL

Para activar la descodificación lógica para una instancia de base de datos de RDS for PostgreSQL

1. Asegúrese de que la cuenta de usuario que está utilizando tenga los siguientes roles:

   • El rol rds_superuser para poder activar la replicación lógica

   • El rol rds_replication para conceder permisos para administrar ranuras lógicas y para transmitir datos mediante ranuras lógicas

2. Establezca el parámetro estático rds.logical_replication en 1. Como parte de la aplicación de este parámetro, también defina los parámetros wal_level, max_wal_senders, max_replication_slots y max_connections. Estos cambios de parámetro pueden incrementar la generación de WAL, por lo que el parámetro rds.logical_replication se debe configurar solo cuando se utilicen ranuras lógicas.

3. Reinicie la instancia de base de datos para que el parámetro rds.logical_replication estático tenga efecto.

4. Cree una ranura de replicación lógica como se indica en la siguiente sección. Este proceso necesita que especifique un complemento de descodificación. Actualmente, RDS for PostgreSQL admite los complementos de salida test_decoding y wal2json que se incluyen con PostgreSQL.

1. Creación de las tablas de origen

   Conéctese a la base de datos de origen en la instancia de base de datos de RDS para PostgreSQL:

   
   source=> CREATE TABLE testtab (slno int primary key);
   CREATE TABLE
           

2. Inserción de datos en las tablas de origen

   
   source=> INSERT INTO testtab VALUES (generate_series(1,1000));
   INSERT 0 1000
           

3. Creación de una publicación para las tablas de origen

   • Cree una publicación para las tablas de origen:

     
     source=> CREATE PUBLICATION testpub FOR TABLE testtab;
     CREATE PUBLICATION
             

   • Utilice una consulta SELECT para verificar los detalles de la publicación que se creó:

     
     source=> SELECT * FROM pg_publication;
       oid   | pubname | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot
     --------+---------+----------+--------------+-----------+-----------+-----------+-------------+------------
      115069 | testpub |    16395 | f            | t         | t         | t         | t           | f
     (1 row)
             

   • Verifique que las tablas de origen se hayan agregado a la publicación:

     
     source=> SELECT * FROM pg_publication_tables; 
     pubname | schemaname | tablename
     ---------+------------+-----------
      testpub | public     | testtab
     (1 rows)
             

   • Para replicar todas las tablas de una base de datos, utilice:

     
     CREATE PUBLICATION testpub FOR ALL TABLES;
               

   • Si la publicación ya está creada para una tabla individual y necesita agregar una tabla nueva, puede ejecutar la siguiente consulta para agregar cualquier tabla nueva a la publicación existente:

     
     ALTER PUBLICATION <publication_name> add table <new_table_name>;
               

4. Conéctese a la base de datos de destino y cree tablas de destino

   • Conéctese a la base de datos de destino en la instancia de base de datos de destino. Cree las tablas de destino con los mismos nombres que las tablas de origen:

     
     target=> CREATE TABLE testtab (slno int primary key);
     CREATE TABLE
     

   • Asegúrese de que no haya datos presentes en las tablas de destino ejecutando una consulta SELECT en las tablas de destino:

         
     target=> SELECT count(*) FROM testtab;
      count
     -------
          0
     (1 row)
             

5. Cree y verifique la suscripción en la base de datos de destino

   • Cree la suscripción en la base de datos de destino:

     
     target=> CREATE SUBSCRIPTION testsub 
     CONNECTION 'host=<source RDS/host endpoint> port=5432 dbname=<source_db_name> user=<user> password=<password>' 
     PUBLICATION testpub;
     NOTICE:  Created replication slot "testsub" on publisher
     CREATE SUBSCRIPTION
             

   • Utilice una consulta SELECT para verificar que la suscripción esté habilitada:

     
     target=> SELECT oid, subname, subenabled, subslotname, subpublications FROM pg_subscription;
       oid  | subname | subenabled | subslotname | subpublications
     -------+---------+------------+-------------+-----------------
      16434 | testsub | t          | testsub     | {testpub}
     (1 row)
             

   • Cuando se crea la suscripción, se cargan todos los datos de las tablas de origen en las tablas de destino. Ejecute una consulta SELECT en las tablas de destino para verificar que se cargan los datos iniciales:

     
     target=> SELECT count(*) FROM testtab;
      count
     -------
       1000
     (1 row)
             

6. Verificación de la ranura de replicación en la base de datos de origen

   La creación de una suscripción en la base de datos de destino crea una ranura de replicación en la base de datos de origen. Verifique los detalles de la ranura de replicación ejecutando la siguiente consulta SELECT en la base de datos de origen:

   
   source=> SELECT * FROM pg_replication_slots;
    
   slot_name |  plugin  | slot_type | datoid | database | temporary | active | active_pid | xmin | catalog_xmin | restart_lsn | confirmed_flush_lsn | wal_status | safe_wal_size
   ----------+----------+-----------+--------+----------+-----------+--------+------------+------+--------------+-------------+---------------------+------------+---------------
   testsub   | pgoutput | logical   | 115048 | source   | f         | t      |        846 |      |         6945 | 58/B4000568 | 58/B40005A0         | reserved   |
   (1 row)
           

7. prueba de replicación

   • Compruebe si los cambios en los datos de las tablas de origen se están replicando en las tablas de destino insertando filas en las tablas de origen:

     
     source=> INSERT INTO testtab VALUES(generate_series(1001,2000));
     INSERT 0 1000
     
     source=> SELECT count(*) FROM testtab; 
      count
     -------
       2000
     (1 row)
           

   • Verifique el número de filas en las tablas de destino para confirmar que se están replicando las nuevas inserciones:

     
     target=> SELECT count(*) FROM testtab;
      count
     -------
       2000
     (1 row)
           

8. Actualización de la suscripción después de agregar tablas

   • Cuando se agregan nuevas tablas a una publicación existente, es obligatorio actualizar la suscripción para que los cambios surtan efecto:

     
     ALTER SUBSCRIPTION <subscription_name> REFRESH PUBLICATION;
           

   • Este comando obtiene la información de las tablas que faltan del publicador e inicia la replicación de las tablas que se agregaron a las publicaciones suscritas desde que se creó la suscripción o se actualizó por última vez.