Condividi tramite


Aggiungere CDC Azure Cosmos DB come origine nell'hub in tempo reale

Questo articolo descrive come aggiungere Change Data Capture (CDC) di Azure Cosmos DB for NoSQL come origine evento nell'hub in tempo reale di Fabric.

Il connettore di origine Change Data Capture (CDC) di Azure Cosmos DB 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 in un flusso, è possibile elaborare questi dati CDC in tempo reale e inviarli a destinazioni diverse all'interno di Fabric per un'ulteriore elaborazione o analisi.

Prerequisiti

  • Accesso a un'area di lavoro in modalità di licenza della capacità di Infrastruttura (o) modalità licenza di valutazione con autorizzazioni di collaboratore o superiore.
  • 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.
  • Se non si dispone di un flusso di eventi, creare un flusso di eventi.

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à.

  1. Nella pagina Account Azure Cosmos DB, selezionare Chiavi in Impostazioni nel riquadro di spostamento a sinistra.

  2. Nella pagina Chiavi, copiare i valori di URI e chiave primaria da usare per configurare la connessione eventstream.

    Screenshot dell'URI e della chiave primaria nella pagina Chiavi di Azure Cosmos DB nel portale di Azure.

  3. 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.

    Screenshot dell'elenco contenitori per un account API NoSQL di Azure Cosmos DB.

Ottenere eventi da un'istanza di CDC di Azure Cosmos DB

È possibile ottenere eventi da un'istanza di CDC di Azure Cosmos DB in un hub in tempo reale in uno dei modi seguenti:

Pagina Origini dati

  1. Accedere a Microsoft Fabric.

  2. Se visualizzi Power BI in basso a sinistra della pagina, passa al workload di Fabric selezionando Power BI e quindi selezionando Fabric .

    Screenshot che mostra come passare al carico di lavoro Fabric.

  3. Selezionare In tempo reale sulla barra di spostamento a sinistra.

    Screenshot che mostra come avviare l'esperienza di connessione all'origine dati.

  4. Nella pagina Hub in tempo reale selezionare + Origini dati in Connetti a nel menu di spostamento a sinistra.

    Screenshot che mostra la pagina Origini dati nell'hub Real-Time.

    È anche possibile accedere alla pagina Origini dati dalle pagine Tutti i flussi di dati o Flussi di dati personali selezionando il pulsante + Connetti origine dati nell'angolo superiore destro.

    Screenshot che mostra il pulsante Connetti origine dei dati.

Usare le istruzioni della sezione Aggiungere CDC di Azure Cosmos DB come origine.

Pagina Origini Microsoft

  1. Nell'hub in tempo reale selezionare Origini Microsoft.

  2. Nell'elenco a discesa Origine, selezionare Azure Cosmos DB (CDC).

  3. Per Sottoscrizione, selezionare una sottoscrizione di Azure con il gruppo di risorse con l'account Cosmos DB.

  4. In Gruppo di risorse, selezionare o creare un gruppo di risorse per l'account Azure Cosmos DB.

  5. In Area, selezionare una località in cui si trova Cosmos DB.

  6. Spostare ora il mouse sul nome dell'origine CDC di Cosmos DB che si vuole connettere all'hub in tempo reale nell'elenco dei database e selezionare il pulsante Connetti, oppure selezionare ... (puntini di sospensione) e quindi selezionare il pulsante Connetti.

    Screenshot che mostra la pagina Origini Microsoft con filtri per visualizzare Cosmos DB CDC e il pulsante Connetti.

    Per configurare le informazioni di connessione, seguire la procedura descritta nella sezione Aggiungere CDC di Azure Cosmos DB come origine. Ignorare il primo passaggio della selezione di Azure Cosmos DB CDC come tipo di origine nella procedura guidata Aggiungi origine.

Aggiungere CDC di Azure Cosmos DB come origine

  1. Nella pagina Connetti, seleziona Nuova connessione.

    Screenshot che mostra la pagina Aggiungi origine guidata Connetti. con il collegamento **Nuova connessione** evidenziato.

  2. Nella sezione Impostazioni di connessione, specificare l'endpoint cosmos DB. Immettere l'URI o l'endpoint per l'account Cosmos DB copiato dal portale di Azure.

    Screenshot che mostra le impostazioni di connessione della pagina Nuova connessione.

  3. Espandere Opzioni avanzate e seguire questa procedura:

    1. Per Numero di tentativi, specificare il numero massimo di volte in cui il connettore deve ritrasmettere una richiesta al database Cosmos DB se la richiesta ha esito negativo da un errore ripristinabile.

    2. Per Abilitare il passaggio della funzione AVERAGE, specificare se il connettore deve passare la funzione di aggregazione AVG al database Cosmos DB.

    3. Per Abilitare il passaggio SORT per più colonne, specificare se il connettore deve consentire il passaggio di più colonne al database Cosmos DB quando specificato nella clausola ORDER BY della query SQL.

      Screenshot che mostra le opzioni avanzate per configurare il connettore Azure Cosmos DB.

  4. Scorrere verso il basso e nella sezione Credenziali di connessione seguire questa procedura.

    1. Selezionare una connessione esistente e mantenere l'opzione Crea nuova connessione predefinita.
    2. Per creare una connessione, immettere i valori seguenti:
      1. Per Nome connessione, immetti un nome per la connessione.

      2. Per Tipo di autenticazione, selezionare Chiave dell’account.

      3. Per Chiave account immettere il valore della chiave salvato in precedenza.

      4. Selezionare Connetti.

        Screenshot che mostra le Credenziali di connessione della pagina Nuova connessione.

  5. Nella pagina Connetti seguire questa procedura:

    1. Specificare l'ID contenitore del contenitore nell'account Azure Cosmos DB.

    2. Nella sezione Dettagli flusso a destra selezionare l'area di lavoro Fabric in cui si vuole salvare l’eventstream che verrà creato dalla procedura guidata.

    3. Per nome eventstream immettere un nome per l’eventstream. La procedura guidata crea un eventstream con l'istanza CDC di Azure Cosmos DB selezionata come origine.

    4. Il nome del flusso viene generato automaticamente aggiungendo –flusso al nome dell’eventstream. È possibile visualizzare questo flusso nella pagina Tutti i flussi di dati dell'hub in tempo reale al termine della procedura guidata.

    5. Selezionare Avanti.

      Screenshot che mostra la pagina Di connessione della procedura guidata Aggiungi origine compilata.

  6. Nella schermata Rivedi e connetti esaminare il riepilogo e quindi selezionare Crea origine.

    Screenshot che mostra la pagina Revisione e connessione della procedura guidata Aggiungi origine compilata.

Visualizzare i dettagli del flusso dei dati

  1. Nella pagina Rivedi e connetti, se si seleziona Apri eventstream, la procedura guidata apre il flusso di eventi creato automaticamente con l'istanza di Azure Cosmos DB CDC selezionata come origine. Per chiudere la procedura guidata, selezionare Chiudi o X* nell'angolo superiore destro della pagina.

    Screenshot che mostra la pagina Rivedi e connetti dopo la corretta creazione dell'origine.

  2. Nell'hub in tempo reale selezionare Tutti i flussi di dati. Per visualizzare il nuovo flusso di dati, aggiornare la pagina Tutti i flussi di dati.

    Screenshot che mostra la pagina Tutti i flussi di dati dell'hub in tempo reale con il flusso appena creato.

    Per i passaggi dettagliati, vedere Visualizzare i dettagli dei flussi dei dati nell'Hub in tempo reale di Fabric.

Per informazioni sull'utilizzo dei flussi dei dati, vedere gli articoli seguenti: