Compartir por


Agregar de CDC de Azure Cosmos DB como origen en el centro en tiempo real (versión preliminar)

En este artículo se describe cómo agregar Azure Cosmos DB for NoSQL Change Data Capture (CDC) como un origen del evento en el centro de conectividad en tiempo real de Fabric.

El conector de origen de captura de datos modificados (CDC) de Azure Cosmos DB permite capturar una instantánea de los datos actuales en una base de datos de Azure Cosmos DB. El conector supervisa y registra los cambios futuros de nivel de fila en estos datos. Una vez capturados los cambios en un flujo, puede procesar estos datos CDC en tiempo real y enviarlos a diferentes destinos dentro de Fabric para su posterior procesamiento o análisis.

Nota:

El centro en tiempo real está actualmente en versión preliminar.

Requisitos previos

  • Acceda al área de trabajo Premium de Fabric con permisos de Colaborador o superiores.
  • Acceso a una cuenta de Azure Cosmos DB for NoSQL y base de datos.
  • Su base de datos de Azure Cosmos DB for NoSQL debe ser de acceso público y no estar detrás de un servidor de seguridad o protegida en una red virtual.

Obtención de los detalles de conexión de Azure Portal

Las etiquetas de los elementos que necesita recopilar de Azure Portal aparecen en los pasos que se indican a continuación. Siempre necesita el URI del punto de conexión, en un formato como https://<account>.<api>.azure.com:<port>/, la clave principal y los identificadores de nombre y elemento de la base de datos para los que desea recopilar datos.

Nota:

CDC de Azure Cosmos DB for NoSQL utiliza el modo de última versión de la fuente de cambios de Azure Cosmos DB. Captura los cambios en los registros en la última versión. Tenga en cuenta que con este modo no se capturan las eliminaciones.

  1. En la página de Azure Portal de la cuenta de Azure Cosmos DB, seleccione Claves en la Configuración en el panel de navegación de la izquierda.

  2. En la página Claves, copie los valores de URI y Clave principal que se usarán para configurar la conexión de eventstream.

    Captura de pantalla del URI y la clave principal en la página Claves de Azure Cosmos DB en Azure Portal.

  3. En la página Información general de Azure Portal de la cuenta de Azure Cosmos DB, anote el identificador de base de datos y el ID de elemento para el que desea recopilar datos.

    Captura de pantalla de la lista contenedores de una cuenta de NoSQL API de Azure Cosmos DB.

Obtención de eventos de un CDC de Azure Cosmos DB

Puede obtener eventos de un CDC de Azure Cosmos DB en el centro de tiempo real de una de las maneras siguientes:

Iniciar agregar experiencia de origen

  1. Inicie sesión en Microsoft Fabric.

  2. Seleccione Centro en tiempo real en la barra de navegación de la izquierda.

  3. En la página Centro en tiempo real, seleccione + Agregar origen en la esquina superior derecha de la página.

    Captura de pantalla en la que se muestra cómo iniciar el centro en tiempo real en Microsoft Fabric.

Use las instrucciones de la sección Agregar Azure Cosmos DB CDC como origen.

Página orígenes de Microsoft

  1. En centro en tiempo real, seleccione Orígenes de Microsoft.

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

  3. En Suscripción, seleccione una suscripción de Azure que tenga el grupo de recursos con tu cuenta de Cosmos DB.

  4. Para Grupo de recursos, seleccione un grupo de recursos que tenga su cuenta de Cosmos DB.

  5. En Región, seleccione la ubicación de su Cosmos DB.

  6. Ahora, mueva el ratón sobre el nombre del origen Cosmos DB CDC que desea conectar a la central en tiempo real en la lista de bases de datos, y seleccione el botón Conectar, o seleccione ... (elipsis ), y luego seleccione el botón Conectar.

    Captura de pantalla que muestra la página de orígenes de Microsoft con filtros para mostrar CDC de Cosmos DB y el botón Conectar.

    Para configurar la información de conexión, use los pasos de la sección Agregar Azure Cosmos DB CDC como origen. Omita el primer paso para seleccionar CDC de Azure Cosmos DB como tipo de origen en el Asistente para agregar origen.

Añadir Azure Cosmos DB CDC como origen

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

    Captura de pantalla que muestra la página Seleccionar un origen de datos con Azure Cosmos DB (CDC ) seleccionado.

  2. Seleccione el enlace Ir al recurso si desea navegar a la cuenta de Azure Cosmos DB en el Azure Portal.

    Captura de pantalla que muestra la página Conectar con el enlace **Ir al recurso** resaltado.

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

    Captura de pantalla que muestra la página Agregar conexión del asistente para origen. con el vínculo **Nueva conexión** resaltado.

  4. En la sección Configuración de la conexión, especifique el punto de conexión de Cosmos DB. Introduzca el identificador URI o el punto de conexión de su cuenta de Cosmos DB que copió del Azure Portal.

    Captura de pantalla en la que se muestra la sección Configuración de la conexión de la página Nueva conexión.

  5. Expanda Opciones avanzadas, y siga estos pasos:

    1. Para Número de reintentos, especifique el número máximo de veces que el conector debe retransmitir una solicitud a la base de datos de Cosmos DB si la solicitud falla por un error recuperable.

    2. Para Habilitar la transferencia de la función AVERAGE, especifique si el conector debe transferir la función de agregado AVG a la base de datos de Cosmos DB.

    3. En Habilitar la transferencia de la función SORT para varias columnas, especifique si el conector debe permitir la transferencia de varias columnas a la base de datos de Cosmos DB cuando se especifiquen en la cláusula ORDER BY de la consulta SQL.

      Captura de pantalla que muestra las opciones avanzadas para configurar el conector Azure Cosmos DB.

  6. Vaya hacia abajo y, en la sección Credenciales de conexión, siga estos pasos.

    1. Seleccione una conexión existente y mantenga la opción predeterminada Crear nueva conexión.
    2. Para crear una conexión, escriba los siguientes valores:
      1. Para Nombre de conexión, indique un nombre para la conexión.

      2. En Tipo de autenticación, seleccione Clave de cuenta.

      3. En Clave de cuenta, introduzca el valor de la clave que guardó anteriormente.

      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.

  7. Ahora, en la página Conectar, siga estos pasos:

    1. Especifique el ID de contenedor del contenedor en su cuenta de Azure Cosmos DB.

    2. En la sección Detalles del flujo de la derecha, seleccione el espacio de trabajo Fabric en la que desea guardar el flujo de eventos que va a crear el asistente.

    3. En nombre del flujo de eventos, introduzca un nombre para el flujo de eventos. El asistente crea un Flujo de datos con el CDC de Azure Cosmos DB seleccionado como origen.

    4. El Nombre del flujo se genera automáticamente al agregar -flujo al nombre del flujo de eventos. Puede ver esta secuencia en la página Todos los flujos de datos del centro en tiempo real cuando finalice el asistente.

    5. Seleccione Siguiente.

      Captura de pantalla que muestra la página Conectar del Asistente para agregar origen rellenada.

  8. En la pantalla Revisar y crear, revise el resumen y, después, seleccione Crear origen.

    Captura de pantalla que muestra el Asistente para agregar origen rellenado Revisar y crear página.

Ver detalles del flujo de datos

  1. En la página Revisar y crear, si selecciona Abrir flujo de datos, el asistente abre el flujo de datos que creó para usted con el CDC de Azure Cosmos DB seleccionado como origen. Para cerrar el asistente, seleccione Cerrar o X* en la esquina superior derecha de la página.

    Captura de pantalla en la que se muestra la página Revisar y crear después de crear correctamente el origen.

  2. En centro en tiempo real, seleccione Todos los flujos de datos. Para ver el nuevo flujo de datos, actualice la página Todos los flujos de datos.

    Captura de pantalla que muestra la página Todos los flujos de datos del centro en tiempo real con la secuencia que acaba de crear.

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

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