Elaborare e instradare i dati con i flussi di dati

I flussi di dati semplificano la configurazione dei percorsi di dati per spostare, trasformare e arricchire i dati. Usando i flussi di dati, è possibile connettere varie origini dati ed eseguire operazioni di dati. Il componente flusso di dati fa parte di Operazioni di Azure IoT, che viene distribuito come estensione Azure Arc. È possibile configurare un flusso di dati usando l'interfaccia utente Web dell'esperienza operativa, il interfaccia della riga di comando di Azure o i modelli di Azure Resource Manager.

È possibile scrivere configurazioni per diversi casi d'uso, ad esempio:

  • Trasformare i dati e inviarli di nuovo a MQTT.
  • Trasformare i dati e inviarli al cloud.
  • Inviare dati al cloud o alla periferia senza trasformazione.

I flussi di dati non sono limitati all'area in cui si distribuisce l'istanza di operazioni IoT. È possibile usare i flussi di dati per inviare dati agli endpoint cloud in aree diverse.

Nota

I flussi di dati sostituiscono il componente Data Processor di sola anteprima dalle versioni Operazioni di Azure IoT iniziali. Il --include-dp parametro in az iot ops init è stato rimosso e non è più necessario, ovvero i componenti dei flussi di dati vengono distribuiti automaticamente.

Funzionalità principali

In questa sezione vengono descritte le funzionalità principali dei flussi di dati.

Elaborazione e routing dei dati

I flussi di dati consentono l'inserimento, l'elaborazione e l'instradamento dei messaggi alle destinazioni specificate. Puoi specificare:

  • Origini: da cui si inseriscono messaggi.
  • Destinazioni: dove indirizzi i messaggi, incluso il supporto per il routing dinamico dei temi in base al contenuto dei messaggi per gli endpoint MQTT.
  • Trasformazioni (facoltativo): configurazione per le operazioni di elaborazione dati.

Funzionalità di trasformazione

È possibile applicare trasformazioni ai dati durante la fase di elaborazione per eseguire varie operazioni. Queste operazioni possono includere:

  • Calcolo di nuove proprietà: in base alle proprietà esistenti nel messaggio.
  • Ridenominazione delle proprietà: per standardizzare o chiarire i dati.
  • Conversione di unità: convertire i valori in unità di misura diverse.
  • Standardizzazione dei valori: ridimensionare i valori delle proprietà in un intervallo definito dall'utente.
  • Contestualizzazione dei dati: aggiungere dati di riferimento ai messaggi per l'arricchimento e per ricavare approfondimenti.

Suggerimento

Per funzionalità di elaborazione più avanzate, tra cui routing condizionale, aggregazione basata sul tempo e pipeline di trasformazione componibili, vedere Grafici del flusso di dati.

Configurazione e distribuzione

Specificare la configurazione usando l'interfaccia utente Web dell'esperienza operativa, il interfaccia della riga di comando di Azure o i modelli di Azure Resource Manager. In base a questa configurazione, l'operatore flusso di dati crea istanze del flusso di dati per garantire disponibilità elevata e affidabilità.

Vantaggi

  • Configurazione semplificata: connettere facilmente origini dati e destinazioni.
  • Trasformazioni flessibili: eseguire un'ampia gamma di operazioni di dati.
  • Configurazione scalabile: Utilizzare gli strumenti di Azure per configurazioni scalabili e gestibili.
  • Disponibilità elevata: la risorsa nativa Kubernetes garantisce l'affidabilità.

Usando i flussi di dati, è possibile gestire in modo efficiente i percorsi dei dati. È possibile assicurarsi che i dati vengano inviati, trasformati e arricchiti in modo accurato per soddisfare le esigenze operative.

Registro schemi

Il Registro dello schema, una funzionalità fornita dal Registro dispositivi di Azure, è un repository sincronizzato nel cloud e nell'edge. Il Registro di sistema dello schema archivia le definizioni dei messaggi provenienti dagli asset perimetrali e quindi espone un'API per accedere a tali schemi al perimetro. I connettori southbound come il connettore per OPC UA possono creare schemi di messaggio e aggiungerli al Registro di sistema dello schema oppure è possibile caricare schemi nell'interfaccia utente Web dell'esperienza operativa.

I flussi di dati usano schemi di messaggio per trasformare il messaggio nel formato previsto dall'endpoint di destinazione.

Per altre informazioni, vedere Informazioni sugli schemi dei messaggi.

Memorizzazione nel buffer dei dati e persistenza del disco

Quando un flusso di dati invia messaggi a un endpoint di destinazione, la destinazione o la rete potrebbe non essere più disponibile. Se il recapito non è stato completato, il flusso di dati non riconosce il messaggio di origine. Il broker MQTT mantiene il messaggio nella coda del sottoscrittore e il flusso di dati ritenta il recapito.

Per informazioni sul comportamento di interruzione della destinazione, sulle code dei sottoscrittori broker, sul buffer dei messaggi su disco, sulla persistenza del broker e sul flusso requestDiskPersistencedi dati, vedere Configurare il buffer dei dati e la persistenza del disco per i flussi di dati.

Contenuto correlato

  • Last updated on