Adición de un origen de CDC de base de datos de PostgreSQL a una secuencia de eventos (versión preliminar)

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.

Importante

Las funcionalidades mejoradas de flujos de eventos de Fabric se encuentran actualmente en versión preliminar.

Nota:

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

Requisitos previos

• Acceda al área de trabajo Premium de Fabric con permisos de Colaborador o superiores.

• 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.

Nota:

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

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;
   

Adición de CDC de Azure Database para PostgreSQL como origen

1. Seleccione Eventstream para crear un nuevo flujo de eventos. Asegúrese de que la opción Funcionalidades mejoradas (versión preliminar) esté habilitada.

   

2. En la siguiente pantalla, seleccione Agregar origen externo.

   

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

1. En la pantalla Seleccionar un origen de datos, seleccione Azure DB for PostgreSQL (CDC).

   

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

   

3. 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.

     

4. 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.

      

5. 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. Seleccione Siguiente en la parte inferior de la página.

      

6. En la pantalla Revisar y crear, revise el resumen y, a continuación, seleccione Agregar.

   

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

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 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