Inviare dati a un endpoint gRPC con l'anteprima del processore di dati IoT di Azure
Importante
Anteprima delle operazioni di Azure IoT: abilitata da Azure Arc è attualmente disponibile in ANTEPRIMA. Non è consigliabile usare questo software di anteprima negli ambienti di produzione.
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.
Usare la destinazione gRPC per scrivere dati elaborati e puliti in un endpoint gRPC per un'ulteriore elaborazione.
Quando si inviano dati a un endpoint gRPC da una fase di destinazione:
- Attualmente, la fase supporta solo il tipo RPC unario.
- È possibile usare solo il formato Protobuf . È necessario usare protobuf con la fase di chiamata gRPC.
- Poiché questa fase è una destinazione della pipeline, la risposta viene eliminata.
Prerequisiti
Per configurare e usare una fase della pipeline di destinazione, è necessario:
- Istanza distribuita di Azure IoT Data Processor Preview che include il componente facoltativo responsabile del trattamento dei dati.
- Un server gRPC accessibile dall'istanza del responsabile del trattamento dei dati.
- Strumento
protoc
per generare il descrittore.
Configurare la fase di destinazione
La configurazione JSON della fase di destinazione gRPC definisce i dettagli della fase. Per creare la fase, è possibile interagire con l'interfaccia utente basata su form o specificare la configurazione JSON nella scheda Avanzate :
Nome | Tipo | Descrizione | Richiesto | Valore predefinito | Esempio |
---|---|---|---|---|---|
Nome | string | Nome da visualizzare nell'interfaccia utente del responsabile del trattamento dei dati. | Sì | - | MLCall2 |
Descrizione | stringa | Descrizione descrittiva della fase di destinazione. | No | Call ML endpoint 2 |
|
Server address | String | Indirizzo del server gRPC | Sì | - | https://localhost:1313 |
Nome RPC | string | Nome RPC da chiamare | Sì | - | GetInsights |
Descrittore1 | String | Descrittore codificato in base 64 | Sì | - | CuIFChxnb29nb |
Autenticazione | string | Tipo di autenticazione da usare. None /Metadata . |
Sì | None |
None |
Chiave dei metadati | string | Chiave di metadati da usare quando Authentication è impostata Metadata su . |
No | authorization |
authorization |
Segreto | string | Riferimento al segreto da usare quando Authentication è impostato su Metadata . |
No | - | mysecret |
Riprova | Riprova | Criterio di ripetizione dei tentativi da usare. | No | default |
fixed |
Percorso del corpo della richiesta > API | Percorso | Percorso della parte del messaggio del responsabile del trattamento dei dati che deve essere serializzato e impostato come corpo della richiesta. Lasciare vuoto se non è necessario inviare un corpo della richiesta. | No | - | .payload.gRPCRequest |
Chiavemetadati > richiesta > API 2 | Campo statico/dinamico | Chiave di metadati da impostare nella richiesta. | No | Campo statico/dinamico | |
Valoremetadati > richiesta > API 2 | Campo statico/dinamico | Valore dei metadati da impostare nella richiesta. | No | Campo statico/dinamico |
1Descrittore: per serializzare il corpo della richiesta, è necessario un descrittore con codifica base 64 del file proto.
Usare il comando seguente per generare il descrittore, sostituire <proto-file>
con il nome del file con estensione proto:
protoc --descriptor_set_out=/dev/stdout --include_imports <proto-file> | base64 | tr '\n' ' ' | sed 's/[[:space:]]//g'
Usare l'output del comando precedente come descriptor
nella configurazione.
2Metadati richiesta > API: ogni elemento nella matrice di metadati è una coppia di valori chiave. È possibile impostare la chiave o il valore in modo dinamico in base al contenuto del messaggio in arrivo o come stringa statica.
Contenuto correlato
Commenti e suggerimenti
https://aka.ms/ContentUserFeedback.
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, vedereInvia e visualizza il feedback per