Descrivere l'hub in tempo reale di Microsoft Fabric

  • 15 minuti

Recupero dati nell'hub in tempo reale

L'Hub in tempo reale funge da gateway per individuare e controllare il flusso dei dati di streaming. Si tratta di un catalogo dinamico che include:

Screenshot del ruolo dell'hub in tempo reale in Intelligence in tempo reale.

  • Flussi di eventi: Ottenere l'accesso a tutti i flussi di eventi attivi all'interno di Fabric che è consentito visualizzare.
  • Microsoft Sources: Trovare e configurare rapidamente le origini di streaming disponibili, ad esempio Hub eventi di Azure, l'hub IoT di Azure e varie opzioni di Change Data Capture (CDC) da Azure SQL DB, Azure Cosmos DB e PostgreSQL DB.
  • Eventi Fabric: Usare le funzionalità guidate dagli eventi per le notifiche istantanee e la gestione dei dati. Mantenere le schede sugli eventi dagli elementi dell'area di lavoro infrastruttura ad Archiviazione BLOB di Azure, che possono avviare altri processi o flussi di lavoro. Questa azione può comportare l'avvio di una pipeline di dati o l'invio di un avviso di posta elettronica. Inoltre, è possibile instradare questi eventi verso destinazioni diverse tramite flussi di eventi. Gli avvisi consentono di interagire sia all'interno dell'area di lavoro che al di fuori dell'hub in tempo reale selezionando il pulsante Screenshot del pulsante Seleziona avviso. Imposta avviso.

Tutte queste informazioni vengono presentate in un formato digeribile, per garantire una perfetta integrazione con i carichi di lavoro di Fabric.

Origine del flusso di eventi

La funzionalità flussi di eventi dell'esperienza di Intelligence in tempo reale di Microsoft Fabric consente di integrare senza problemi gli eventi in tempo reale in Fabric. È possibile creare un eventstream, che è un'istanza all'interno di Fabric, per aggiungere origini di dati dell'evento, applicare trasformazioni facoltative ai dati e indirizzarle a varie destinazioni, senza la necessità di scrivere codice. Questo approccio senza codice semplifica il processo di gestione dei dati degli eventi all'interno di Fabric.

Screenshot delle origini del flusso di eventi.

Elaborazione di eventi all'interno di flussi di eventi

L'interfaccia di trascinamento della selezione offre un metodo semplice e intuitivo per costruire i flussi di lavoro dei dati degli eventi. Questo include l'elaborazione, la trasformazione e il routing, il tutto senza la necessità di scrivere codice. Il diagramma del flusso di dati di un eventstream fornisce una rappresentazione visiva chiara del percorso e della struttura dei dati. Inoltre, l'ambiente senza codice dell'editor del processore di eventi consente di progettare la logica di elaborazione dei dati degli eventi semplicemente trascinando e rilasciando elementi sul posto.

  • Descrizione della trasformazione

Quando si crea un flusso di eventi con funzionalità avanzate abilitate, tutte le destinazioni supportano le operazioni di trasformazione. Senza funzionalità avanzate, le trasformazioni sono disponibili solo per le destinazioni Lakehouse e KQL Database, che gestiscono l'elaborazione degli eventi prima dell'inserimento.

  • Filtro: Usare la trasformazione Filtro per filtrare gli eventi in base al valore di un campo dell'input. A seconda del tipo di dati (numero o testo), la trasformazione mantiene i valori corrispondenti alla condizione selezionata, ad esempio è null o is not null.
  • Gestire i campi: Questa trasformazione consente di aggiungere, rimuovere, modificare il tipo di dati o rinominare i campi provenienti da un input o da un'altra trasformazione.
  • Aggregazione: Usare la trasformazione Aggregazione per calcolare un'aggregazione (Somma, Minimo, Massimo o Media) ogni volta che si verifica un nuovo evento in un periodo di tempo. Questa operazione consente anche la ridenominazione di queste colonne calcolate e il filtro o il sezionamento dell'aggregazione in base ad altre dimensioni nei dati. È possibile avere una o più aggregazioni nella stessa trasformazione.
  • Raggruppa per: usa la trasformazione Raggruppa per calcolare le aggregazioni in tutti gli eventi entro un determinato intervallo di tempo. Puoi raggruppare i valori di uno o più campi. È come la trasformazione Aggregazione che consente di rinominare le colonne, ma offre altre opzioni per l'aggregazione e include opzioni più complesse per le finestre temporali. Come Aggregazione, puoi aggiungere più aggregazioni per trasformazione.
  • Unione: Usare la trasformazione Unione per connettere due o più nodi e aggiungere eventi con campi condivisi (con lo stesso nome e tipo di dati) in una tabella. I campi che non corrispondono vengono rimossi e non vengono inclusi nell'output.
  • Espandere: Usare questa trasformazione matrice per creare una nuova riga per ogni valore all'interno di una matrice.
  • Creare un join: si tratta di una trasformazione per combinare i dati di due flussi in base a una condizione di corrispondenza tra di essi.

Posizione di destinazione Standard

È evidente che non scegliendo le funzionalità avanzate, le destinazioni sono limitate.

Destinazione Descrizione
App personalizzata Con questa funzionalità, è possibile indirizzare facilmente il traffico degli eventi in tempo reale a un'applicazione personalizzata. Consente l'integrazione delle applicazioni proprietarie con il flusso di eventi, consentendo l'uso immediato dei dati degli eventi. Questa funzione è vantaggiosa quando si vogliono trasferire dati in tempo reale a un sistema indipendente non ospitato su Microsoft Fabric.
Lakehouse Questa destinazione consente di pre-elaborare gli eventi in tempo reale prima di inserirli nel lakehouse. Gli eventi vengono trasformati in formato Delta Lake e successivamente archiviati in tabelle Lakehouse specifiche, semplificando le esigenze di data warehousing. Per indicazioni dettagliate sull'utilizzo del processore di eventi per la gestione dei dati in tempo reale, vedere la sezione "Elaborare i dati degli eventi con l'editor del processore di eventi".
Database KQL Questa destinazione offre la possibilità di incanalare i dati degli eventi in tempo reale in un database KQL, concedendole la possibilità di usare il linguaggio di query Kusto affidabile (KQL) per l'interrogazione e l'analisi dei dati. L'archiviazione dei dati all'interno del database KQL consente di sfruttare al meglio i dati degli eventi e la creazione di report e dashboard completi. È possibile scegliere uno dei due approcci di inserimento dati: inserimento diretto o pre-elaborazione di eventi prima dell'inserimento.
Reflex Questa destinazione facilita il collegamento diretto dei dati degli eventi in tempo reale con un Reflex. Un Reflex è un'entità intelligente dotata di tutti i dettagli necessari per stabilire connessioni dati, monitorare condizioni specifiche ed eseguire azioni. Quando i dati dell'evento soddisfano determinati criteri predefiniti o identificano modelli specifici, Reflex avvia autonomamente risposte appropriate, ad esempio notificando agli utenti o attivando flussi di lavoro di Power Automate.

Posizione di destinazione avanzati

Quando si scelgono le funzionalità avanzate, è possibile usare le destinazioni standard insieme al flusso derivato.

Destinazione Descrizione
Flusso derivato Il flusso derivato è una destinazione specializzata creata dopo l'applicazione di operazioni di flusso come Filtro o Gestisci campi in un flusso di eventi. Rappresenta il flusso predefinito modificato dopo l'elaborazione, che può essere instradato a varie destinazioni all'interno di Fabric e monitorato nell'hub in tempo reale.

È ora possibile connettersi a più destinazioni all'interno di un flusso di eventi contemporaneamente senza influire o collidere tra loro.

Screenshot dei flussi di eventi simultanei.