Comparteix a través de


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 de la versión más reciente. 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:

  • Mediante la experiencia Obtener eventos.
  • Mediante la pestaña Orígenes de Microsoft

Inicio de la experiencia Obtener eventos

  1. Cambie a la experiencia de inteligencia en tiempo real en Microsoft Fabric. Seleccione Microsoft Fabric en la barra de navegación de la izquierda y después Inteligencia en tiempo real.

    Captura de pantalla que muestra cómo cambiar a la experiencia de inteligencia en tiempo real.

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

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

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

    Captura de pantalla que muestra la selección del botón Obtener eventos en el centro en tiempo real.

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

Pestaña de orígenes de Microsoft

  1. En el centro en tiempo real, cambie a la pestaña 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 pestaña de orígenes de Microsoft con filtros para mostrar Cosmos DB CDC y el botón de conexión.

    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 de seleccionar Azure Cosmos DB CDC como tipo de origen en el asistente Obtener eventos.

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 Conectar del asistente Obtener eventos con el enlace **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. 1.

    2. En la sección Detalles del flujo de la derecha, seleccione el área de trabajo de Fabric donde desee guardar el eventstream 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. Cuando finalice el asistente, verá este flujo en la pestaña Flujos de datos del centro en tiempo real.

    5. Seleccione Siguiente.

      Captura de pantalla en la que se muestra la página Conectar del asistente para obtener eventos rellenada.

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

    Captura de pantalla en la que se muestra la página Revisar y crear del asistente para obtener eventos rellenada.

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 el centro en tiempo real, cambie a la pestaña Flujos de datos. Actualice la página. Debería ver el flujo de datos creado tal como se muestra en la imagen siguiente.

    Captura de pantalla en la que se muestra la pestaña Flujos de datos del centro en tiempo real con el flujo 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: