Configurar una base de datos PostgreSQL de Amazon Aurora

En esta página se describe cómo configurar la captura de datos de cambios (CDC) para transmitir datos de una base de datos de Amazon Aurora PostgreSQL a un destino compatible, como BigQuery o Cloud Storage.

Crear un grupo de parámetros

  1. Abre el panel de control de Amazon RDS.
  2. En el panel de navegación, haga clic en Grupos de parámetros y, a continuación, en Crear grupo de parámetros. Se mostrará la página Crear grupo de parámetros.
  3. Utilice la siguiente tabla para rellenar los campos de esta página y, a continuación, haga clic en Crear:
    CampoDescripción
    Familia de grupos de parámetrosSelecciona la familia que coincida con tu base de datos.
    TipoSeleccione Grupo de parámetros de clúster de base de datos.
    Nombre del grupoAsigna un nombre al grupo de parámetros.
    DescripciónProporciona una descripción del grupo de parámetros.
  4. Marca la casilla situada a la izquierda del grupo de parámetros que acabas de crear y, a continuación, en Acciones del grupo de parámetros, haz clic en Editar.
  5. Cambia el valor del parámetro rds.logical_replication a 1.
  6. Haz clic en Guardar cambios.

Asigna el grupo de parámetros a la instancia de base de datos

  1. Abre el panel de control de Amazon RDS.
  2. En el cajón de navegación, haz clic en Bases de datos y, a continuación, selecciona tu instancia de base de datos.
  3. En el menú Acciones de la instancia, selecciona Modificar. Aparecerá el cuadro de diálogo Modificar instancia de base de datos.
  4. En la sección Configuración adicional, selecciona el grupo de parámetros del clúster de base de datos que hayas creado.
  5. En Periodo de conservación de copias de seguridad, selecciona 7 días.
  6. Haz clic en Continuar.
  7. En el panel Programación de modificaciones, selecciona la opción Aplicar inmediatamente.

Reiniciar la instancia de base de datos

  1. Abre el panel de control de Amazon RDS.
  2. En el cajón de navegación, haz clic en Bases de datos y, a continuación, selecciona tu instancia de base de datos.
  3. En el menú desplegable Acciones, selecciona Reiniciar y, a continuación, Confirmar.

Crear una publicación y un slot de replicación

  1. Crea una publicación para los cambios en las tablas que quieras replicar. Le recomendamos que cree una publicación solo para las tablas que quiera replicar. De esta forma, Datastream puede leer solo los datos pertinentes, lo que reduce la carga de la base de datos y de Datastream:

    CREATE PUBLICATION PUBLICATION_NAME
FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;

    Haz los cambios siguientes:

    • PUBLICATION_NAME: el nombre de tu publicación. Deberá proporcionar este nombre cuando cree un flujo en el asistente de creación de flujos de Datastream.
    • SCHEMA: el nombre del esquema que contiene la tabla.
    • TABLE: el nombre de la tabla que quieres replicar.

    También puede crear una publicación para todas las tablas de su base de datos. Tenga en cuenta que este enfoque aumenta la carga tanto en la base de datos de origen como en Datastream:

    CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;

  2. Crea un slot de replicación introduciendo el siguiente comando de PostgreSQL: 

    SELECT PG_CREATE_LOGICAL_REPLICATION_SLOT('REPLICATION_SLOT_NAME', 'pgoutput');

    Haz los cambios siguientes:

    • REPLICATION_SLOT_NAME: el nombre de tu ranura de replicación. Deberá proporcionar este nombre cuando cree un flujo en el asistente de creación de flujos de Datastream.

Crear un usuario de Datastream

  1. Para crear un usuario de Datastream, introduce el siguiente comando de PostgreSQL: 

    CREATE USER USER_NAME WITH ENCRYPTED PASSWORD 'USER_PASSWORD';

    Haz los cambios siguientes:

    • USER_NAME: nombre del usuario de Datastream que quieras crear.
    • USER_PASSWORD: la contraseña del usuario de Datastream que quieras crear.

  2. Concede los siguientes privilegios al usuario que has creado: 

    GRANT RDS_REPLICATION TO USER_NAME;
GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME;
GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME;
ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME
  GRANT SELECT ON TABLES TO USER_NAME;

    Haz los cambios siguientes:

    • SCHEMA_NAME: el nombre del esquema al que quieres conceder los privilegios.
    • USER_NAME: el usuario al que quieres conceder los privilegios.

Siguientes pasos