Condividi tramite


Aggiungere Azure Cosmos DB CDC come origine nel hub in tempo reale

Questo articolo descrive come aggiungere Change Data Capture (CDC) di Azure Cosmos DB for NoSQL come origine degli eventi 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.

Nota

Questa sorgente non è supportata nelle seguenti regioni della capacità del tuo spazio di lavoro: West US3, Svizzera occidentale.

Prerequisiti

  • Accesso a un'area di lavoro in modalità di licenza della capacità di Fabric oppure modalità licenza di valutazione con autorizzazioni di Collaboratore o superiori.
  • Accesso a un account e a un 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. Registra le modifiche apportate ai record nell'ultima versione. Si noti che le eliminazioni non vengono acquisite con questa modalità.

  1. Nella pagina del portale di Azure per il tuo account Azure Cosmos DB, seleziona Chiavi sotto Impostazioni nella barra di navigazione 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 Azure Cosmos DB CDC in un hub di elaborazione 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 Tempo reale nella barra di navigazione a sinistra.

    Screenshot che mostra come avviare l'esperienza Connetti all'Origine Dati.

  4. Nella pagina Hub Real-Time, seleziona + Origini dati sotto 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 dalla pagina hubReal-Time selezionando il pulsante + Aggiungi dati nell'angolo superiore destro.

    Screenshot che mostra il pulsante Connetti origine 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 che contenga il gruppo di risorse con l'account Cosmos DB.

  4. In Gruppo di risorse, seleziona un gruppo di risorse che contiene il tuo account di Cosmos DB.

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

  6. Adesso sposta il mouse sul nome dell'origine CDC di Cosmos DB che desideri connettere all'hub Tempo Reale nell'elenco dei database, quindi seleziona il pulsante Connetti oppure seleziona ... (puntini di sospensione) e poi seleziona il pulsante Connetti.

    Screenshot che mostra la pagina delle origini di Microsoft con filtri per visualizzare

    Per configurare le informazioni di connessione, seguire la procedura descritta nella sezione Aggiungere CDC di Azure Cosmos DB come origine. Saltare il primo passaggio selezionando 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 del flusso di eventi, immettere un nome per il flusso di eventi. 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 una volta completata la procedura guidata.

    5. Selezionare Avanti.

      Screenshot che mostra la pagina 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 della procedura guidata

Visualizzare i dettagli del flusso dei dati

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

    Screenshot che mostra la pagina Revisione e connessione dopo la creazione riuscita 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: