Aggiungere un'origine del database con mirroring (feed di modifiche) a un flusso di eventi

Questo articolo illustra come aggiungere un'origine database con mirroring (feed di modifiche) a un flusso di eventi.

Il connettore di origine Database con mirroring (feed di modifiche) per i flussi di eventi di Microsoft Fabric consente di acquisire eventi di modifica in tempo reale da un Database con mirroring di Fabric. I database sottoposti a mirroring in Fabric forniscono una replica di sola lettura quasi in tempo reale dei dati del database esterno. Con questo connettore è possibile acquisire inserimenti, aggiornamenti ed eliminazioni man mano che si verificano nel database con mirroring e trasmetterli in un flusso di eventi per l'elaborazione, l'analisi e il routing in tempo reale a varie destinazioni Fabric.

Questo connettore supporta tutti i tipi di database sottoposti a mirroring disponibili in Fabric Mirroring, tra cui:

  • Database SQL di Microsoft Azure
  • Azure Cosmos DB, un servizio di database distribuito globale di Microsoft
  • Snowflake
  • Aprire il mirroring

Note

Questo connettore è attualmente in anteprima. Il connettore acquisisce gli eventi grezzi del feed delle modifiche dal database mirrorato. DeltaFlow (trasformazione di eventi pronti per l'analisi) non è attualmente supportato con questo connettore.

Prerequisiti

  • Accesso a un'area di lavoro in modalità di licenza della capacità Fabric o alla modalità di licenza Trial con autorizzazioni di Collaboratore o superiori.
  • Un database con mirroring esistente nell'area di lavoro Fabric che sincronizza attivamente i dati dal database di origine.
  • Il database con mirroring deve avere il feed di modifiche abilitato.
  • Se non si dispone di un flusso di eventi, creare un flusso di eventi.

Avvia la procedura guidata di Connect per le origini dati

Se non è ancora stata aggiunta alcuna origine al flusso di eventi, selezionare il riquadro Connetti origini dati . È anche possibile selezionare Aggiungi origine>Connetti origini dati sulla barra multifunzione.

Screenshot che mostra la selezione del tile per usare un'origine esterna.

Se stai aggiungendo la sorgente a un flusso di eventi già pubblicato, passa alla modalità Modifica. Sulla barra multifunzione selezionare Aggiungi origine>Connetti origini dati.

Screenshot che mostra le selezioni per l'aggiunta di fonti esterne.

Nella pagina Selezionare un'origine dati cercare Database con mirroring e selezionare Connetti nel riquadro Database con mirroring (feed di modifiche).

Schermata che mostra la selezione di Database duplicato (feed di modifiche) come tipo di origine nella procedura guidata Recupera eventi.

Configurare e connettersi al feed di modifiche del database con mirroring

Inserire eventi del feed di modifiche in un flusso di eventi da un database Fabric con mirroring a scelta

  1. Nella pagina Connetti selezionare un database con mirroring a cui connettersi.

    1. Per Area di lavoro, passa a e seleziona l'area di lavoro Fabric che contiene il database di cui è stato eseguito il mirroring.

    2. Per Database con mirroring selezionare il database con mirroring nell'elenco dei database disponibili nell'area di lavoro selezionata.

      Schermata che mostra l'area di lavoro e il selettore del database con mirroring nella pagina Connetti.

  2. Selezionare Tutte le tabelle oppure Immettere i nomi di tabella per specificare le tabelle da monitorare per le modifiche. Se si seleziona quest'ultimo, specificare le tabelle usando un elenco delimitato da virgole di identificatori di tabella completi (schemaName.tableName) o espressioni regolari valide. Per esempio:

    • Usare dbo.Orders.* per selezionare tutte le tabelle i cui nomi iniziano con dbo.Orders.
    • Usare dbo\.(Orders|Customers) per selezionare dbo.Orders e dbo.Customers.

    È possibile combinare entrambi i formati usando virgole. Il limite di caratteri totale per l'intera voce è di 102.400 caratteri.

    Note

    Nella versione di anteprima corrente è disponibile solo l'opzione Tutte le tabelle .

  3. Nella pagina Rivedi e connetti esaminare il riepilogo delle impostazioni e quindi selezionare Aggiungi.

    Screenshot che mostra la pagina Rivedi e connetti per l'origine del feed di modifiche del database con mirroring.

  4. È possibile visualizzare l'origine Database con mirroring (Change Feed) aggiunta al flusso di eventi mentre sei ancora in Edit mode.

Visualizzare il flusso di eventi aggiornato

  1. Per implementare questa nuova origine Mirrored Database (Change Feed), selezionare Pubblica. Dopo aver completato questi passaggi, l'origine del database con mirroring (feed delle modifiche) può essere visualizzata nella Live view.

    Schermata della sorgente del feed delle modifiche del database mirrorato in streaming nella vista Live.

Configurare le destinazioni Eventstream per l'uso degli schemi

Attualmente, solo la eventhouse, l'endpoint personalizzato e le destinazioni di flusso derivate sono supportate per gli eventi con schemi associati. Questa sezione illustra come aggiungere e configurare una destinazione Eventhouse quando le funzionalità estese (ad esempio il supporto dello schema) sono abilitate per il flusso di eventi.

Note

Quando si usa DeltaFlow (anteprima) con un'origine CDC (Change Data Capture) supportata, le tabelle di destinazione nella Eventhouse vengono create e gestite automaticamente in modo che corrispondano alla struttura della tabella di origine. Non è necessario configurare manualmente lo schema della tabella di destinazione. DeltaFlow gestisce anche automaticamente l'evoluzione dello schema quando le tabelle di origine cambiano.

Configurare uno schema per una destinazione endpoint personalizzata

  1. Selezionare Trasforma eventi o aggiungi destinazione e quindi selezionare CustomEndpoint.

  2. Nel riquadro Endpoint personalizzato specificare un nome per la destinazione.

  3. In Schema di input selezionare lo schema per gli eventi. Quando si abilita il supporto dello schema per un flusso di eventi, effettuare una selezione in questa casella.

Screenshot che mostra il riquadro per la configurazione di un endpoint personalizzato.

Per informazioni dettagliate sulla configurazione di una destinazione endpoint personalizzata, vedere Aggiungere un endpoint personalizzato o una destinazione app personalizzata a un flusso di eventi.

Configurare gli schemi per una destinazione casa degli eventi

  1. Selezionare Trasforma eventi o aggiungi destinazione e quindi selezionare Eventhouse(Casa eventi).

  2. Nel riquadro Eventhouse configurare le impostazioni correlate allo schema seguenti:

    1. Per Schema di input selezionare uno o più schemi dall'elenco a discesa.

      Screenshot che mostra il riquadro di configurazione di eventhouse con uno schema di input selezionato.

      Note

      Se è stata selezionata l'opzione Schema dinamico tramite intestazioni durante la configurazione di un'origine di Hub eventi, potrebbero essere stati configurati più schemi per l'origine e ne è stato eseguito il mapping a varie proprietà e ai relativi valori.

    2. Per Metodo di creazione tabella selezionare Una singola tabella con tutti gli schemi combinati o Tabelle separate per ogni schema, a seconda dei requisiti.

      Screenshot che mostra il riquadro di configurazione di eventhouse con i metodi di creazione delle tabelle.

    3. Per Scrivere dati con, selezionare una delle opzioni seguenti:

      • Solo payload: scrivere i dati del payload estratti nella tabella. Se sono presenti più schemi di input, i dati vengono inviati a più tabelle.
      • Metadati e payload: scrivere metadati e dati di payload in una singola tabella. Le colonne di esempio includono source , subjecttype, e data.

      Screenshot che mostra il riquadro di configurazione dell'evento con le opzioni per la scrittura dei dati.

Per i passaggi dettagliati sulla configurazione di una destinazione dell'evento, vedere Aggiungere una destinazione eventhouse a un flusso di eventi.

Contenuti correlati

Altri connettori:

  • Last updated on