Adición de CDC de MySQL Database como origen en el centro en tiempo real

En este artículo se describe cómo agregar la captura de datos modificados (CDC) de MySQL Database como origen de eventos en el centro en tiempo real de Fabric.

El conector de captura de datos modificados (CDC) de Azure MySQL Database permite capturar una instantánea de los datos actuales en una base de datos de Azure MySQL. Debe especificar las tablas que se van a supervisar y sobre las que recibir alertas cuando se produzcan cambios de nivel de fila posteriores en las tablas. Una vez que se capturan los cambios en una secuencia, puede procesar estos datos de CDC en tiempo real y enviarlos a diferentes destinos dentro de Fabric para su posterior procesamiento o análisis.

Requisitos previos

• Accede 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.
• Se ha creado una instancia de Azure Database for MySQL: servidor flexible.

Configuración de la base de datos MySQL

El conector usa el conector Azure MySQL usa el conector Debezium MySQL para capturar los cambios en la base de datos MySQL. Debe definir un usuario de MySQL con permisos en todas las bases de datos que supervisa el conector. Para obtener instrucciones paso a paso, consulta Configuración de la base de datos MySQL (DB).

Habilitación del registro binario

Debe habilitar el registro binario para la replicación de MySQL. Los registros binarios registran las actualizaciones de transacciones de las herramientas de replicación para propagar los cambios. Por ejemplo, Azure Database for MySQL.

1. En Azure Portal, vaya a la instancia de Azure Database for MySQL.

2. En el menú de navegación de la izquierda, seleccione Parámetros del servidor.

3. Configure el servidor MySQL con las siguientes propiedades.

   • binlog_row_image: establezca el valor en full.
   • binlog_expire_logs_seconds: número de segundos para la eliminación automática del archivo de registro binario. Establezca el valor para que coincida con las necesidades del entorno. Por ejemplo, 86400.

   

Obtención de eventos de Azure MySQL Database (CDC)

Puede obtener eventos de CDC de Azure MySQL Database en el centro en tiempo real de una de las maneras siguientes:

• Usar la página orígenes de datos
• Uso de la página orígenes de Microsoft

Página Orígenes de datos

1. Inicie sesión en Microsoft Fabric.

2. Selecciona Tiempo real en la barra de navegación de la izquierda.

3. En la página Centro en tiempo real, selecciona + Orígenes de datos en Conectar a en el menú de navegación izquierdo. También puedes acceder a la página Orígenes de datos desde las páginas Todos los flujos de datos o Mis flujos de datos seleccionando el botón + Conectar origen de datos de la esquina superior derecha.

   

4. En la página Orígenes de datos, seleccione la categoría CDC de base de datos en la parte superior y, a continuación, seleccione Conectar en el icono MySQL DB (CDC).

   

   Use las instrucciones de la sección Adición de CDC de Azure MySQL Database como origen.

Página de orígenes de Microsoft

1. En Centro en tiempo real, selecciona Orígenes de Microsoft.

2. En la lista desplegable Origen, seleccione Azure MySQL DB (CDC).

3. En Suscripción, seleccione una suscripción de Azure que tenga el grupo de recursos con la cuenta de Azure MySQL Database.

4. En Grupo de recursos, seleccione un grupo de recursos que tenga la base de datos.

5. En Región, seleccione una ubicación donde se encuentra la base de datos.

6. Ahora, mueva el mouse sobre el nombre del origen de CDC de Azure MySQL DB que quiera conectar al centro en tiempo real en la lista de bases de datos y seleccione el botón Conectar, o bien seleccione ... (puntos suspensivos) y después el botón Conectar.

   

   Para configurar la información de conexión, siga los pasos de la sección Adición de CDC de Azure MySQL DB como origen.

Adición de CDC de Azure MySQL Database como origen

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

   

2. En la sección Configuración de la conexión, siga estos pasos:

   1. En Servidor, escriba el URI del servidor de Azure MySQL.

   2. En Base de datos, escriba el nombre de la base de datos.

      

3. En la sección Credenciales de conexión, siga estos pasos:

   1. Para Conexión, seleccione si hay una conexión existente a la base de datos MySQL. Si no es así, mantenga el valor predeterminado: Crear una nueva conexión.

   2. Para Tipo de autenticación, seleccione Básica. Actualmente solo se admite la autenticación básica.

   3. Escriba valores para Nombre de usuario y Contraseña.

   4. Especifique si quiere usar una conexión cifrada.

   5. Seleccione Conectar.

      

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

   1. Escriba el nombre de la tabla.
   2. Escriba el id. del servidor.
   3. Escriba el número de puerto o mantenga el valor predeterminado.

5. En la sección Detalles de la secuencia situada a la derecha, siga estos pasos:

   1. Seleccione Área de trabajo de Fabric donde quiera guardar esta conexión y la secuencia de eventos que crea el asistente.

   2. Escriba un nombre para la secuencia de eventos.

   3. El nombre de la secuencia en el centro en tiempo real se ha creado automáticamente.

      

6. Ahora, seleccione Siguiente en la parte inferior de la página.

7. En Revisar y conectar, revisa la configuración y selecciona Crear origen.

   

8. En la página Conectar, seleccione Ir al recurso para ir a la base de datos de Azure PostgreSQL. Anote el nombre del servidor en la página Información general. Tiene el siguiente formato: mysqlserver.mysql.database.azure.com.

   

Visualización de los detalles del flujo de datos

1. En la página Revisar y conectar, si seleccionas Abrir flujo de eventos, el asistente abre el flujo de eventos que creaste automáticamente con el origen de Azure MySQL DB CDC seleccionado. Para cerrar el asistente, selecciona Finalizar o X* en la esquina superior derecha de la página.

   

2. En Centro en tiempo real, selecciona Mis flujos de datos. Para ver el nuevo flujo de datos, actualiza la página.

   

   Para obtener pasos detallados, consulte Visualización de los detalles de los flujos de datos en el centro en tiempo real de Fabric.

Contenido relacionado

Para obtener información sobre cómo consumir flujos de datos, vea los artículos siguientes:

• Procesamiento de secuencias de datos
• Análisis de flujos de datos
• Establecer alertas en flujo de datos