Elaborare e instradare i dati con flussi di dati
Importante
Anteprima di Operazioni di Azure IoT – Abilitata da Azure Arc è attualmente in anteprima. Non è consigliabile usare questo software di anteprima negli ambienti di produzione.
Sarà necessario distribuire una nuova installazione di Azure IoT Operations quando diventa disponibile una versione disponibile a livello generale. Non sarà possibile aggiornare un'installazione di anteprima.
Vedere le condizioni per l'utilizzo supplementari per le anteprime di Microsoft Azure per termini legali aggiuntivi che si applicano a funzionalità di Azure in versione beta, in anteprima o in altro modo non ancora disponibili a livello generale.
I flussi di dati consentono di connettere varie origini dati e di eseguire operazioni sui dati, semplificando la configurazione dei percorsi per spostare, trasformare e arricchire i dati. Il componente del flusso di dati fa parte di Operazioni IoT di Azure, che viene distribuito come estensione di Azure Arc. La configurazione per un flusso di dati viene eseguita tramite le definizioni di risorse personalizzate (CRD) di Kubernetes.
È possibile scrivere configurazioni per diversi casi d'uso, ad esempio:
- Trasformare i dati e inviarli nuovamente a MQTT
- Trasformare i dati e inviarli al cloud
- Inviare dati al cloud o alla rete perimetrale senza trasformarli
I flussi di dati non sono limitati all'area in cui viene distribuita l'istanza di operazioni IoT. È possibile usare i flussi di dati per inviare dati agli endpoint cloud in aree geografiche diverse.
Funzionalità principali
Ecco le funzionalità principali dei flussi di dati.
Elaborazione e routing dei dati
I flussi di dati consentono l'inserimento, l'elaborazione e il routing dei messaggi ai sink specificati. e nello specifico:
- Origini: da dove vengono inseriti i messaggi
- Destinazioni: dove vengono svuotati i messaggi
- Trasformazioni (facoltative): configurazione per le operazioni di elaborazione dei dati
Funzionalità di trasformazione
Le trasformazioni possono essere applicate ai dati durante la fase di elaborazione per eseguire varie operazioni, tra cui:
- Calcolare nuove proprietà: in base alle proprietà esistenti nel messaggio
- Rinominare le proprietà: per standardizzare o chiarire i dati
- Convertire le unità: convertire valori in unità di misura diverse
- Standardizzare i valori: dimensionare i valori delle proprietà in base a un intervallo definito dall'utente
- Contestualizzare i dati: aggiungere dati di riferimento ai messaggi per arricchirli e ottenere informazioni dettagliate
Configurazione e distribuzione
La configurazione viene specificata usando i CRL di Kubernetes. In base a questa configurazione, l'operatore del 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: usare i CD Kubernetes 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 schemi, una funzionalità fornita dall'anteprima di Registro dispositivi di Azure, è un repository sincronizzato nel cloud e nel perimetro. 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 OPC UA possono creare schemi di messaggio e aggiungerli al Registro schemi o i clienti possono caricare schemi nell'interfaccia utente Web dell'esperienza operativa.
I flussi di dati usano schemi di messaggi sia nei punti di origine che in quello di destinazione. Per le origini, gli schemi dei messaggi possono funzionare come filtri per identificare i messaggi specifici da acquisire per un flusso di dati. Per le destinazioni, gli schemi di messaggio consentono di trasformare il messaggio nel formato previsto dall'endpoint di destinazione.
Per altre informazioni, vedere Informazioni sugli schemi dei messaggi.