Flussi di eventi di Microsoft Fabric - Panoramica
La funzionalità flussi di eventi nell'esperienza di Intelligence in tempo reale di Microsoft Fabric consente di portare eventi in tempo reale in Infrastruttura, trasformarli e quindi indirizzarli a varie destinazioni senza scrivere codice (senza codice). Si crea un flusso di eventi, che è un'istanza dell'elemento Eventstream in Fabric, si aggiungono origini dati evento al flusso, facoltativamente si aggiungono trasformazioni per trasformare i dati dell'evento e quindi si instradano i dati alle destinazioni supportate.
Inserire eventi nell'infrastruttura
La funzionalità flussi di eventi offre vari connettori di origine per recuperare i dati degli eventi dalle varie origini. Quando si abilitano funzionalità avanzate al momento della creazione di un flusso di eventi, sono disponibili più origini.
Importante
Le funzionalità avanzate dei flussi di eventi di Fabric sono attualmente in anteprima.
| Origini | Descrizione |
|---|---|
| Hub eventi di Azure | Se si dispone di un hub eventi di Azure, è possibile inserire i dati dell'hub eventi in Microsoft Fabric usando Eventstream. |
| Hub IoT di Azure | Se si ha un hub IoT di Azure, è possibile inserire dati IoT in Microsoft Fabric usando Eventstream. |
| database SQL di Azure Change Data Capture (CDC) | Il connettore di origine database SQL di Azure CDC consente di acquisire uno snapshot dei dati correnti in un database SQL di Azure. Il connettore monitora e registra quindi eventuali modifiche future a livello di riga a questi dati. |
| Postgre database SQL CDC | Il connettore di origine Postgre database SQL Change Data Capture (CDC) consente di acquisire uno snapshot dei dati correnti in un database PostgreSQL. Il connettore monitora e registra quindi eventuali modifiche future a livello di riga a questi dati. |
| My database SQL CDC | Il connettore di origine Change Data Capture (CDC) di Azure My database SQL consente di acquisire uno snapshot dei dati correnti in un database Database di Azure per MySQL. È possibile specificare le tabelle da monitorare e il flusso di eventi registra eventuali modifiche future a livello di riga alle tabelle. |
| Azure Cosmos DB CDC | Il connettore di origine Change Data Capture (CDC) di Azure Cosmos DB per i flussi di eventi di Microsoft Fabric consente di acquisire uno snapshot dei dati correnti in un database di Azure Cosmos DB. Il connettore monitora e registra quindi eventuali modifiche future a livello di riga a questi dati. |
| Google Cloud Pub/Sub | Google Pub/Sub è un servizio di messaggistica che consente di pubblicare e sottoscrivere flussi di eventi. È possibile aggiungere Google Pub/Sub come origine al flusso di eventi per acquisire, trasformare e instradare gli eventi in tempo reale a varie destinazioni in Fabric. |
| Flussi di dati amazon Disas | Amazoni Amazon è un servizio di inserimento dati altamente scalabile, altamente durevole e ottimizzato per lo streaming dei dati. Grazie all'integrazione diAmazoni amazon data streams come origine all'interno del flusso di eventi, è possibile elaborare facilmente i flussi di dati in tempo reale prima di instradarli a più destinazioni all'interno di Fabric. |
| Confluent Cloud Kafka | Confluent Cloud Kafka è una piattaforma di streaming che offre potenti funzionalità di streaming ed elaborazione dei dati con Apache Kafka. Integrando Confluent Cloud Kafka come origine all'interno del flusso di eventi, è possibile elaborare facilmente flussi di dati in tempo reale prima di instradarli a più destinazioni all'interno di Fabric. |
| eventi Archiviazione BLOB di Azure | Archiviazione BLOB di Azure eventi vengono attivati quando un client crea, sostituisce o elimina un BLOB. Il connettore consente di collegare gli eventi di archiviazione BLOB agli eventi dell'infrastruttura nell'hub in tempo reale. È possibile convertire questi eventi in flussi di dati continui e trasformarli prima di instradarli a varie destinazioni in Fabric. |
| Eventi dell'elemento dell'area di lavoro infrastruttura | Gli eventi dell'elemento dell'area di lavoro infrastruttura sono eventi discreti dell'infrastruttura che si verificano quando vengono apportate modifiche all'area di lavoro infrastruttura. Queste modifiche includono la creazione, l'aggiornamento o l'eliminazione di un elemento fabric. Con i flussi di eventi di Fabric è possibile acquisire questi eventi dell'area di lavoro infrastruttura, trasformarli e indirizzarli a varie destinazioni in Fabric per un'ulteriore analisi. |
| Dati di esempio | È possibile scegliere biciclette, taxi gialli o eventi del mercato azionario come origine dati di esempio per testare l'inserimento dei dati durante la configurazione di un flusso di eventi. |
| Endpoint personalizzato (ad esempio, App personalizzata nella funzionalità standard) | La funzionalità endpoint personalizzata consente alle applicazioni o ai client Kafka di connettersi a Eventstream usando un stringa di connessione, consentendo l'inserimento uniforme dei dati di streaming in Eventstream. |
Elaborare eventi usando un'esperienza senza codice
L'esperienza di trascinamento della selezione offre un modo intuitivo e semplice per creare l'elaborazione dei dati degli eventi, la trasformazione e la logica di routing senza scrivere codice. Un diagramma di flusso di dati end-to-end in un flusso di eventi può offrire una conoscenza completa del flusso di dati e dell'organizzazione. L'editor del processore di eventi è un'esperienza senza codice che consente di trascinare e rilasciare per progettare la logica di elaborazione dei dati dell'evento.
| Trasformazione | Descrizione |
|---|---|
| Filtro | Usare la trasformazione Filtro per filtrare gli eventi in base al valore di un campo nell'input. A seconda del tipo di dati (numero o testo), la trasformazione mantiene i valori corrispondenti alla condizione selezionata, ad esempio is null o is not null. |
| Gestire i campi | La trasformazione Gestisci campi consente di aggiungere, rimuovere, modificare il tipo di dati o rinominare i campi provenienti da un input o da un'altra trasformazione. |
| Aggregazione | Utilizzare 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 | Usare la trasformazione Group by per calcolare le aggregazioni in tutti gli eventi in 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. |
| Popolare | 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 la trasformazione Espandi matrice per creare una nuova riga per ogni valore all'interno di una matrice. |
| Join. | Usare la trasformazione Join per combinare i dati di due flussi in base a una condizione di corrispondenza tra di essi. |
Se sono state abilitate funzionalità avanzate durante la creazione di un flusso di eventi, le operazioni di trasformazione sono supportate per tutte le destinazioni (con flusso derivato che funge da ponte intermedio per alcune destinazioni, ad esempio endpoint personalizzato, Reflex). In caso contrario, le operazioni di trasformazione sono disponibili solo per le destinazioni Lakehouse e KQL Database (elaborazione eventi prima dell'inserimento).
Indirizzare gli eventi alle destinazioni
La funzionalità Flussi di eventi di Fabric supporta l'invio di dati alle destinazioni supportate seguenti.
| Destinazione | Descrizione |
|---|---|
| Endpoint personalizzato (ad esempio, App personalizzata nella funzionalità standard) | Con questa destinazione, è possibile instradare facilmente gli eventi in tempo reale a un endpoint personalizzato. È possibile connettere le proprie applicazioni al flusso di eventi e utilizzare i dati dell'evento in tempo reale. Questa destinazione è utile quando si vogliono passare dati in tempo reale a un sistema esterno all'esterno di Microsoft Fabric. |
| KQL Database | Questa destinazione consente di inserire i dati degli eventi in tempo reale in un 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 Kusto, è possibile ottenere informazioni più approfondite sui dati degli eventi e creare report e dashboard avanzati. È possibile scegliere tra due modalità di inserimento: inserimento diretto ed elaborazione degli eventi prima dell'inserimento. |
| Lakehouse | Questa destinazione offre la possibilità di trasformare gli eventi in tempo reale prima di inserirli nella casa del lago. Gli eventi in tempo reale vengono convertiti in formato Delta Lake e quindi archiviati nelle tabelle lakehouse designate. Questa destinazione supporta scenari di data warehousing. |
| Reflex | 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. |
| Flusso derivato | Il flusso derivato è un tipo specializzato di destinazione che è possibile creare dopo l'aggiunta di operazioni di flusso, ad esempio Filtro o Gestione campi, a un flusso di eventi. Il flusso derivato rappresenta il flusso predefinito trasformato dopo l'elaborazione del flusso. È possibile instradare il flusso derivato a più destinazioni in Fabric e visualizzare il flusso derivato nell'hub in tempo reale. |
È possibile collegare più destinazioni in un flusso di eventi per ricevere contemporaneamente dati dai flussi di eventi senza interferire tra loro.
Nota
È consigliabile usare la funzionalità flussi di eventi di Microsoft Fabric con almeno 4 unità di capacità (SKU: F4)
Funzionalità avanzate (anteprima)
Sono disponibili altre funzionalità, origini e destinazioni quando si abilita l'opzione Funzionalità avanzate (anteprima) durante la creazione di un flusso di eventi. Usare le schede Funzionalità avanzate (anteprima) e Funzionalità Standard per ottenere informazioni su origini e destinazioni aggiuntive supportate con le funzionalità avanzate.
Ecco alcune altre funzionalità importanti delle funzionalità avanzate (anteprima):
- Modalità di modifica e visualizzazione dinamica. Esplorare due modalità distinte per la visualizzazione e la progettazione dell'elaborazione del flusso.
- Flussi predefiniti e derivati. Creare un flusso continuo di flussi con il formato progettato, con un processore di eventi che può essere usato in un secondo momento nell'hub in tempo reale.
- Routing del flusso di dati basato sul contenuto. Trasformare e instradare i flussi di dati ovunque all'interno di Fabric in base al contenuto del flusso di dati progettato con il processore di eventi.
Contenuto correlato
Commenti e suggerimenti
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedere https://aka.ms/ContentUserFeedback.
Invia e visualizza il feedback per