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
- Abre el panel de control de Amazon RDS.
- 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.
- Utilice la siguiente tabla para rellenar los campos de esta página y, a continuación, haga clic en Crear:
Campo Descripción Familia de grupos de parámetros Selecciona la familia que coincida con tu base de datos. Tipo Seleccione Grupo de parámetros de clúster de base de datos. Nombre del grupo Asigna un nombre al grupo de parámetros. Descripción Proporciona una descripción del grupo de parámetros. - 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.
- Cambia el valor del parámetro
rds.logical_replication
a 1. - Haz clic en Guardar cambios.
Asigna el grupo de parámetros a la instancia de base de datos
- Abre el panel de control de Amazon RDS.
- En el cajón de navegación, haz clic en Bases de datos y, a continuación, selecciona tu instancia de base de datos.
- En el menú Acciones de la instancia, selecciona Modificar. Aparecerá el cuadro de diálogo Modificar instancia de base de datos.
- En la sección Configuración adicional, selecciona el grupo de parámetros del clúster de base de datos que hayas creado.
- En Periodo de conservación de copias de seguridad, selecciona 7 días.
- Haz clic en Continuar.
- En el panel Programación de modificaciones, selecciona la opción Aplicar inmediatamente.
Reiniciar la instancia de base de datos
- Abre el panel de control de Amazon RDS.
- En el cajón de navegación, haz clic en Bases de datos y, a continuación, selecciona tu instancia de base de datos.
- En el menú desplegable Acciones, selecciona Reiniciar y, a continuación, Confirmar.
Crear una publicación y un slot de replicación
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;
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
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.
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
- Consulta más información sobre cómo funciona Datastream con las fuentes de PostgreSQL.