Aggiungere l'origine CDC di Azure Cosmos DB a un eventstream (anteprima)
Questo articolo illustra come aggiungere un'origine Change Data Capture di Azure Cosmos DB (Azure Cosmos DB for NoSQL) a un eventstream.
Il connettore di origine Change Data Capture (CDC) di Azure Cosmos DB per i flussi di eventi di Microsoft Fabric consente di acquisire uno snapshot dei dati correnti in un database di Azure Cosmos DB. Il connettore monitora e registra poi eventuali modifiche future a livello di riga a questi dati. Dopo aver acquisito le modifiche nell’eventstream, è possibile elaborare questi dati CDC in tempo reale e inviarli a destinazioni diverse all’interno di Fabric per un'ulteriore elaborazione o analisi.
Importante
Le funzionalità avanzate dei flussi di eventi di Fabric sono attualmente in anteprima.
Nota
Questa sorgente non è supportata nelle seguenti regioni della capacità dell'area di lavoro: Stati Uniti occidentali 3, Svizzera occidentale.
Prerequisiti
- Accesso all'area di lavoro Premium di Fabric con autorizzazioni di Collaboratore o superiori.
- Accesso a un account e database Azure Cosmos DB for NoSQL.
- Il database Azure Cosmos DB for NoSQL deve essere accessibile pubblicamente e non essere protetto da un firewall o protetto in una rete virtuale.
Ottenere i dettagli della connessione dal portale di Azure
Le etichette per gli elementi che è necessario raccogliere dai portale di Azure sono illustrate nei passaggi seguenti. È sempre necessario l'URI dell'endpoint, in un formato come https://<account>.<api>.azure.com:<port>/
, la chiave primaria e gli ID elemento e nome del database per cui si vogliono raccogliere i dati.
Nota
CDC di Azure Cosmos DB for NoSQL usa la Modalità Ultima versione del feed di modifiche di Azure Cosmos DB. Acquisisce le modifiche apportate ai record nell’ultima versione. Si noti che le eliminazioni non vengono acquisite con questa modalità.
Nella pagina Account Azure Cosmos DB, selezionare Chiavi in Impostazioni nel riquadro di spostamento a sinistra.
Nella pagina Chiavi, copiare i valori di URI e chiave primaria da usare per configurare la connessione eventstream.
Nella pagina Informazioni generali del portale di Azure per l'account Azure Cosmos DB prendere nota del Database e dell'elemento ID per cui si vogliono raccogliere i dati.
Nota
Il numero massimo di origini e destinazioni per un eventstream è 11.
Aggiungere Azure Cosmos DB (CDC) come origine
In Intelligence in tempo reale di Fabric, selezionare Eventstream per creare un nuovo eventstream. Assicurarsi che l'opzione Funzionalità avanzate (anteprima) sia abilitata.
Nella schermata successiva selezionare Aggiungi origine esterna.
Configurare ed eseguire la connessione ad Azure Cosmos DB (CDC)
Nella schermata Selezionare un'origine dati, selezionare Azure Cosmos DB (CDC).
Nella schermata Connetti, in Connessione, selezionare Nuova connessione per creare un collegamento di connessione cloud al database di Azure Cosmos DB.
Nella scheda Impostazioni connessione, immettere le informazioni seguenti:
- Endpoint di Cosmos DB: immettere l'URI o l'endpoint per l'account Cosmos DB copiato dalla portale di Azure.
- Nome connessione: generato automaticamente oppure è possibile immettere un nuovo nome per questa connessione.
- Chiave dell'account: immettere la chiave primaria per l'account Azure Cosmos DB copiato dal portale di Azure.
Selezionare Connetti.
Specificare le informazioni seguenti per le risorse Azure Cosmos DB:
- ID contenitore: immettere il nome del contenitore o della tabella di Azure Cosmos DB a cui connettersi.
- database: immettere il nome del database Azure Cosmos DB.
- Criterio di offset: selezionare se si inizia a leggere offset Più recenti o Meno recenti se non è presente alcun commit.
Selezionare Avanti.
Esaminare il riepilogo, quindi selezionare Avanti.
Viene visualizzata l'origine di Azure Cosmos DB (CDC) aggiunta all’eventstream in modalità di modifica.
Selezionare Pubblica per pubblicare le modifiche e avviare lo streaming dei dati CDC di Azure Cosmos DB nell’eventstream.
Contenuto correlato
Altri connettori:
- Flussi dei dati Amazon Kinesis
- Hub eventi di Azure
- Hub IoT di Azure
- Change Data Capture (CDC) del Database SQL di Azure
- Confluent Kafka
- Endpoint personalizzato
- Google Cloud Pub/Sub
- CDC del database MySQL
- CDC del database PostgreSQL
- Dati di esempio
- Eventi di Archiviazione BLOB di Azure
- Evento dell'area di lavoro Fabric