Adición de un origen CDC de Azure Cosmos DB a una secuencia de eventos (versión preliminar)
En este artículo se muestra cómo agregar un origen de captura de datos modificados de Azure Cosmos DB (Azure Cosmos DB for NoSQL) a un Eventstream.
El conector de origen de captura de datos modificados (CDC) de Azure Cosmos DB para flujos de eventos de Microsoft Fabric permite capturar una instantánea de los datos actuales en una base de datos de Azure Cosmos DB. 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 su 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 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.
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.
En la página Claves, copie los valores de URI y Clave principal que se usarán para configurar la conexión de eventstream.
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.
Nota:
El número máximo de orígenes y destinos para una secuencia de eventos es 11.
Adición de Azure Cosmos DB (CDC) como origen
En Inteligencia en tiempo real de Fabric, seleccione Eventstream para crear un flujo de eventos. Asegúrese de que la opción Funcionalidades mejoradas (versión preliminar) esté habilitada.
En la siguiente pantalla, seleccione Agregar origen externo.
Configuración y conexión a Azure Cosmos DB (CDC)
En la pantalla Seleccionar un origen de datos, seleccione Azure Cosmos DB (CDC).
En la pantalla Conectar, en Conexión, seleccione Nueva conexión para crear una conexión en la nube que vincule a la base de datos de Azure Cosmos DB..
En la pantalla Configuración de la conexión, introduzca la siguiente información:
- Punto de conexión de Cosmos DB: escriba el URI o el punto de conexión de la cuenta de Cosmos DB que copió de Azure Portal.
- Nombre de conexión: generado automáticamente o puede escribir un nombre nuevo para esta conexión.
- Clave de cuenta: escriba la clave principal de la cuenta de Azure Cosmos DB que copió de Azure Portal.
Seleccione Conectar.
Proporcione la siguiente información para el recurso de Azure Cosmos DB:
- Id. de contenedor: escriba el nombre del contenedor o la tabla de Azure Cosmos DB a la que desea conectarse.
- Base de datos: escriba el nombre de la base de datos de Azure Cosmos DB.
- Directiva de desplazamiento: seleccione si quiere empezar a leer los desplazamientos más antiguos o más recientes si no hay ninguna confirmación.
Seleccione Siguiente.
Revise el resumen y luego seleccione Agregar.
Verá el origen de Azure Cosmos DB (CDC) agregado al flujo de eventos en modo de edición.
Seleccione Publicar para publicar los cambios y empezar a transmitir datos CDC de Azure Cosmos DB a la secuencia de eventos.
Contenido relacionado
Otros conectores:
- Flujos de datos de Amazon Kinesis
- 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