Condividi tramite

Elaborazione dei messaggi in una soluzione IoT

  • Articolo

Questa panoramica presenta i concetti chiave relativi all'elaborazione dei messaggi inviati dagli asset e dai dispositivi in una tipica soluzione Azure IoT. Ogni sezione include i collegamenti al contenuto che offre ulteriori dettagli e indicazioni.

Il diagramma seguente mostra una visualizzazione generale dei componenti in una tipica soluzione IoT basata su edge. Questo articolo è incentrato sui componenti di elaborazione dei messaggi di una soluzione IoT basata su edge.

Diagramma che mostra l'architettura della soluzione IoT basata su edge di alto livello che evidenzia le aree di elaborazione dei messaggi.

In Azure IoT l'elaborazione dei messaggi si riferisce a processi come il routing e l'arricchimento dei messaggi inviati da asset e dispositivi. Questi processi vengono usati per controllare il flusso dei messaggi tramite la soluzione IoT e per aggiungere informazioni aggiuntive ai messaggi.

Instradare messaggi

Per instradare i messaggi dagli asset a vari endpoint, le operazioni IoT di Azure usano flussi di dati. Gli endpoint di destinazione potrebbero trovarsi nel cloud o nella rete perimetrale. L'elenco degli endpoint di destinazione disponibili include:

Tipo di endpoint Descrizione
MQTT Per la messaggistica bidirezionale con broker MQTT, incluso quello integrato in Azure IoT e Event Grid.
Kafka Per la messaggistica bidirezionale con broker Kafka, tra cui Hub eventi di Azure.
Data Lake Per caricare i dati in account di archiviazione di Azure Data Lake Gen2.
Microsoft Fabric OneLake Per caricare i dati in lakehouse di Microsoft Fabric OneLake.
Esplora dati di Azure Per caricare i dati nei database Esplora dati di Azure.
Archiviazione locale Per l'invio di dati a un volume permanente disponibile in locale, facoltativamente configurabile con Archiviazione di Container Azure abilitata da Azure Arc.

L'interfaccia utente Web dell'esperienza operativa offre un ambiente senza codice per la compilazione e l'esecuzione dei flussi di dati.

Per una maggiore sicurezza nei dati indirizzati agli endpoint, i segreti sincronizzati cloud/edge vengono usati negli endpoint del flusso di dati per l'autenticazione.

Mentre i flussi di dati consentono di configurare il routing al perimetro, è anche possibile definire il routing nel cloud. Se il flusso di dati recapita messaggi a Griglia di eventi di Azure, è possibile usare le relative funzionalità di routing per determinare dove inviare i messaggi.

Per altre informazioni, vedere Elaborare e instradare i dati con i flussi di dati.

Arricchire, trasformare ed elaborare i messaggi

Gli arricchimenti e le trasformazioni possono essere applicati 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

Il registro schemi archivia gli schemi per i messaggi provenienti dagli asset. I flussi di dati usano questi schemi di messaggio per decodificare i messaggi da diversi formati in modo che possano essere elaborati dai flussi di dati.

L'interfaccia utente Web dell'esperienza operativa offre un ambiente senza codice per la compilazione e l'esecuzione delle trasformazioni nei flussi di dati.

Per altre informazioni, vedere Arricchire i dati usando i flussi di dati.

In Azure IoT Operations è possibile distribuire applicazioni perimetrali a disponibilità elevata nel cluster Kubernetes. Le applicazioni perimetrali possono interagire con il broker MQTT predefinito per:

  • Usare la logica di elaborazione dei messaggi personalizzata nei messaggi MQTT.
  • Compilare la logica dell'applicazione personalizzata da eseguire nei dispositivi perimetrali.
  • Eseguire modelli di intelligenza artificiale Edge per l'elaborazione e il processo decisionale in tempo reale all'origine della generazione dei dati, riducendo la latenza e l'utilizzo della larghezza di banda.

Per altre informazioni, vedere Sviluppare applicazioni a disponibilità elevata per il broker MQTT per le operazioni IoT di Azure.

Altri servizi cloud

È possibile usare altri servizi cloud per elaborare i messaggi dagli asset e dai dispositivi.

Gli endpoint del flusso di dati in Operazioni IoT di Azure consentono di connettersi ai servizi cloud per inviare e ricevere dati dagli asset. Un endpoint del flusso di dati è il punto di connessione per il flusso di dati.

Per altre informazioni, vedere:

Nell'hub IoT e IoT Central è possibile instradare i messaggi ad altri servizi. Ad esempio, è possibile inoltrare messaggi ad Analisi di flusso di Azure per analizzare ed elaborare grandi volumi di dati di streaming o a Funzioni di Azure per eseguire il codice in risposta agli eventi. Analisi di flusso è disponibile anche nel runtime di Azure IoT Edge, che consente di elaborare i dati al perimetro anziché nel cloud.

Per altre informazioni, vedere:

Contenuto correlato