Compartir a través de


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

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.

    Captura de pantalla de la habilitación de CDC para una implementación de servidor flexible.

  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.

    Una captura de pantalla de la creación de un nuevo Eventstream.

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

    Una captura de pantalla de la selección de adición de un 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).

    Captura de pantalla de la selección de PostgreSQL DB (CDC).

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

    Captura de pantalla que muestra la página Conectar de una base de datos de Azure PostgreSQL con el vínculo Nueva conexión resaltado.

  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.

      Captura de pantalla que muestra la sección Configuración de la conexión para el conector de base de datos de Azure PostgreSQL.

  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.

      Captura de pantalla que muestra la sección Credenciales de conexión para el conector de base de datos de Azure PostgreSQL.

  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.

      Captura de pantalla que muestra la página Conectar rellenada para el conector de base de datos de Azure PostgreSQL.

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

    Captura de pantalla que muestra la página Revisar y crear rellenada para el conector de base de datos de Azure PostgreSQL.

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

Captura de pantalla del origen de CDC de la base de datos de PostgreSQL en streaming en la vista Editar.

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.

Captura de pantalla del origen de CDC de la base de datos de PostgreSQL en streaming en la Vista en vivo.

Otros conectores: