Condividi tramite

Instradare i flussi di dati in base al contenuto nei flussi di eventi di Fabric (anteprima)

  • Articolo

Questo articolo illustra come instradare gli eventi in base al contenuto nei flussi di eventi di Microsoft Fabric.

È ora possibile usare l'editor no-code nell'area di disegno principale dei flussi di eventi di Fabric per creare una logica di elaborazione di flussi complessa senza scrivere codice. Questa funzionalità consente di personalizzare, trasformare e gestire più facilmente i flussi di dati. Dopo aver impostato le operazioni di elaborazione del flusso, è possibile inviare senza problemi i flussi di dati a destinazioni diverse in base allo schema e ai dati di flusso specifici.

Importante

Le funzionalità avanzate dei flussi di eventi di Fabric sono attualmente in anteprima.

Operazioni supportate

Ecco l'elenco delle operazioni supportate per l'elaborazione dei dati in tempo reale:

  • Aggregazione: supporta le funzioni SUM, AVG, MIN e MAX che eseguono calcoli su una colonna di valori, restituendo un singolo risultato.

  • Espandere: espandere un valore di matrice e creare una nuova riga per ogni valore all'interno di una matrice.

  • Filtro: selezionare o filtrare righe specifiche dal flusso di dati in base a una condizione.

  • Raggruppa per: aggrega tutti i dati dell'evento in un determinato intervallo di tempo, con l'opzione per raggruppare una o più colonne.

  • Gestisci campi: aggiungere, rimuovere o modificare il tipo di dati di un campo o di una colonna dei flussi di dati.

  • Unione: Connessione due o più flussi di dati con campi condivisi con lo stesso nome e tipo di dati in un flusso di dati. I campi che non corrispondono vengono eliminati.

  • Join: combinare i dati da due flussi in base a una condizione di corrispondenza tra di essi.

Destinazioni supportate

Le destinazioni supportate sono:

  • Lakehouse: questa destinazione offre la possibilità di trasformare gli eventi in tempo reale prima dell'inserimento nel lakehouse. Gli eventi in tempo reale vengono convertiti in formato Delta Lake e quindi archiviati nelle tabelle lakehouse designate. Questa destinazione consente di gestire scenari di data warehousing.

  • Database KQL: questa destinazione consente di inserire i dati degli eventi in tempo reale nel database KQL, in cui è possibile usare le potenti Linguaggio di query Kusto (KQL) per eseguire query e analizzare i dati. Con i dati nel database KQL, è possibile ottenere informazioni più approfondite sui dati degli eventi e creare report e dashboard avanzati.

  • Riflessi: questa destinazione consente di connettere direttamente i dati degli eventi in tempo reale a un riflesso. Riflesso è un tipo di agente intelligente che contiene tutte le informazioni necessarie per connettersi ai dati, monitorare le condizioni e agire. Quando i dati raggiungono determinate soglie o corrispondono ad altri modelli, Reflex esegue automaticamente azioni appropriate, ad esempio avvisando gli utenti o avviando i flussi di lavoro di Power Automate.

  • Endpoint personalizzato (precedente app personalizzata): con questa destinazione è possibile instradare facilmente gli eventi in tempo reale a un'applicazione personalizzata. Questa destinazione consente di connettere le proprie applicazioni al flusso di eventi e di utilizzare i dati dell'evento in tempo reale. È utile quando si vogliono passare dati in tempo reale a un sistema esterno all'esterno di Microsoft Fabric.

  • Stream: questa destinazione rappresenta il flusso di eventi non elaborato predefinito trasformato da una serie di operazioni, detto anche flusso derivato. Dopo la creazione, è possibile visualizzare il flusso dall'hub in tempo reale.

L'esempio seguente mostra come tre destinazioni eventstream di Fabric distinte possano gestire funzioni separate per una singola origine del flusso di dati. Un database KQL è designato per l'archiviazione di dati non elaborati, un secondo database KQL è per conservare i flussi di dati filtrati e lakehouse viene usato per l'archiviazione di valori aggregati.

Screenshot del routing degli eventi in base al contenuto.

Per trasformare e instradare il flusso di dati in base al contenuto, seguire la procedura descritta in Modificare e pubblicare un flusso di eventi e iniziare a progettare le logiche di elaborazione dei flussi per il flusso di dati.

Contenuto correlato