Adición de un origen de CDC de base de datos de PostgreSQL a una secuencia de eventos

En este artículo se muestra cómo agregar un origen de captura de datos modificados (CDC) de base de datos de PostgreSQL a una secuencia de eventos.

El conector de origen de captura de datos modificados (CDC) de base de datos de PostgreSQL para secuencias de eventos de Microsoft Fabric permite capturar una instantánea de los datos actuales en una base de datos de PostgreSQL. A continuación, el conector supervisa y registra los cambios futuros a nivel de fila en estos datos. Una vez capturados los cambios en el flujo de eventos, puede procesar estos datos de CDC en tiempo real y enviarlos a diferentes destinos dentro de Fabric para su posterior procesamiento o análisis.

Nota:

Este origen no se admite en las siguientes regiones de su capacidad de área de trabajo: Oeste de EE. UU. 3, Oeste de Suiza.

Requisitos previos

• Acceso a un área de trabajo en el modo de licencia de capacidad de Fabric (o) el modo de licencia de prueba con los permisos Colaborador o superior.

• Acceso de usuario registrado en la base de datos de PostgreSQL.

• La base de datos de PostgreSQL debe ser accesible públicamente y no estar detrás de un firewall o protegido en una red virtual.

• CDC habilitado en la base de datos y las tablas de PostgreSQL.

  Si tiene Azure Database for PostgreSQL, siga los pasos de la sección siguiente para habilitar CDC. Para obtener información detallada, consulte Replicación lógica y descodificación lógica: Azure Database for PostgreSQL con servidor flexible.

  Para otras base de datos de PostgreSQL, consulte Conector de Debezium para PostgreSQL - Documentación de Debezium.

• Si no tiene una secuencia de eventos, cree una.

Habilitación de CDC en Azure Database for PostgreSQL

Siga estos pasos para habilitar CDC en el servidor flexible de Azure Database for PostgreSQL.

1. En la página de Azure Database for PostgreSQL con servidor flexible de Azure Portal, seleccione Parámetros del servidor en el menú de navegación.

2. En la página Parámetros del servidor:

   • Establezca wal_level en logical.
   • Actualice max_worker_processes al menos a 16.

   

3. Guarde los cambios y reinicie el servidor.

4. Confirme que la instancia de servidor flexible de Azure Database for PostgreSQL permite el tráfico de red público.

5. Conceda permisos de replicación de usuarios administradores mediante la ejecución de la siguiente instrucción SQL. Si desea usar otra cuenta de usuario para conectar la base de datos de PostgreSQL para capturar CDC, asegúrese de que el usuario es el propietario de la tabla.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

Inicio del Asistente para seleccionar un origen de datos

Si aún no ha agregado ningún origen a la secuencia de eventos, seleccione el mosaico Usar origen externo.

Si va a agregar el origen a un elemento Eventstream ya publicado, cambie al modo Editar, seleccione Agregar origen en la cinta de opciones y, a continuación, seleccione Orígenes externos.

 

En la página Seleccionar un origen de datos, busque y seleccione Conectar en el mosaico Azure DB for PostgreSQL (CDC).

Configuración y conexión a CDC de Azure Database para PostgreSQL

1. En la página Conectar, seleccione Nueva conexión.

   

2. Escriba la información siguiente en la sección Configuración de la conexión.

   • Servidor: la dirección del servidor de la base de datos de PostgreSQL, por ejemplo, my-pgsql-server.postgres.database.azure.com.

   • Base de datos: el nombre de la base de datos, por ejemplo, my_database.

     

3. Desplácese hacia abajo y, en la sección Credenciales de conexión, siga estos pasos.

   1. Para Nombre de conexión, introduzca un nombre para la conexión.

   2. Para Tipo de autenticación, seleccione Básica.

      Nota:

      Actualmente, las secuencias de eventos de Fabric solo admiten la autenticación Básica.

   3. Escriba el Nombre de usuario y la Contraseña de la base de datos.

   4. Seleccione Conectar.

      

4. Ahora, en la página Conectar, realice estos pasos:

   1. En Tabla, escriba un nombre de tabla.

   2. Para Puerto, escriba el número de puerto o deje el valor predeterminado 5432.

   3. Selecciona Siguiente en la parte inferior de la página.

      

5. En la página Revisar y conectar, revise el resumen y, a continuación, seleccione Agregar.

   

Nota:

El número máximo de orígenes y destinos para una secuencia de eventos es 11.

Visualización de la secuencia de eventos actualizado

1. Puede ver el origen de CDC de la base de datos de PostgreSQL agregado a la secuencia de eventos en Modo de edición.

   

2. Para implementar este origen de CDC de base de datos de PostgreSQL recién agregado, seleccione Publicar. Después de completar estos pasos, el origen de CDC de base de datos de PostgreSQL está disponible para su visualización en la Vista en vivo.

   

Contenido relacionado

Otros conectores:

• Flujos de datos de Amazon Kinesis
• Azure Cosmos DB
• Azure Event Hubs
• Azure Service Bus
• Azure IoT Hub
• Captura de datos modificados de la base de datos Azure SQL
• Confluent Kafka
• Punto de conexión personalizado
• Google Cloud Pub/Sub
• CDC de base de datos de MySQL
• CDC de base de datos de PostgreSQL
• Datos de ejemplo
• Eventos de Azure Blob Storage
• Evento de área de trabajo de Fabric