Gegevens verzenden naar een gRPC-eindpunt met de gegevensprocessor
Belangrijk
Azure IoT Operations Preview: ingeschakeld door Azure Arc is momenteel in PREVIEW. Gebruik deze preview-software niet in productieomgevingen.
U moet een nieuwe Installatie van Azure IoT Operations implementeren wanneer er een algemeen beschikbare release beschikbaar wordt gesteld. U kunt geen preview-installatie upgraden.
Raadpleeg de Aanvullende voorwaarden voor Microsoft Azure-previews voor juridische voorwaarden die van toepassing zijn op Azure-functies die in bèta of preview zijn of die anders nog niet algemeen beschikbaar zijn.
Gebruik de gRPC-bestemming om verwerkte en schone gegevens naar een gRPC-eindpunt te schrijven voor verdere verwerking.
Wanneer u gegevens verzendt naar een gRPC-eindpunt vanuit een doelfase:
- Momenteel ondersteunt de fase alleen het Unary RPC-type.
- U kunt alleen de Protobuf-indeling gebruiken. U moet de Protobuf gebruiken met de gRPC-call outfase.
- Omdat deze fase een pijplijnbestemming is, wordt het antwoord verwijderd.
Vereisten
Als u een doelpijplijnfase wilt configureren en gebruiken, hebt u het volgende nodig:
- Een geïmplementeerd exemplaar van de gegevensverwerker dat het optionele gegevensprocessoronderdeel bevat.
- Een gRPC-server die toegankelijk is vanuit het dataprocessorexemplaren.
- Het
protoc
hulpprogramma voor het genereren van de descriptor.
De doelfase configureren
De JSON-configuratie van de gRPC-doelfase definieert de details van de fase. Als u de fase wilt ontwerpen, kunt u communiceren met de gebruikersinterface op basis van formulieren of de JSON-configuratie opgeven op het tabblad Geavanceerd :
Name | Type | Beschrijving | Vereist | Standaardinstelling | Opmerking |
---|---|---|---|---|---|
Naam | tekenreeks | Een naam die moet worden weergegeven in de gebruikersinterface van de gegevensverwerker. | Ja | - | MLCall2 |
Beschrijving | tekenreeks | Een gebruiksvriendelijke beschrijving van de doelfase. | Nee | Call ML endpoint 2 |
|
Server address | String | Het adres van de gRPC-server | Ja | - | https://localhost:1313 |
RPC-naam | tekenreeks | De RPC-naam die moet worden aangeroepen | Ja | - | GetInsights |
Descriptor1 | String | De base 64-gecodeerde descriptor | Ja | - | CuIFChxnb29nb |
Verificatie | tekenreeks | Het verificatietype dat moet worden gebruikt. None /Metadata . |
Ja | None |
None |
Metagegevenssleutel | tekenreeks | De metagegevenssleutel die moet worden gebruikt wanneer Authentication deze is ingesteld op Metadata . |
Nee | authorization |
authorization |
Geheim | tekenreeks | De geheime verwijzing die moet worden gebruikt wanneer Authentication is ingesteld op Metadata . |
Nee | - | mysecret |
Opnieuw proberen | Opnieuw proberen | Het beleid voor opnieuw proberen dat moet worden gebruikt. | Nee | default |
fixed |
Pad naar hoofdtekst van API-aanvraag > | Pad | Het pad naar het gedeelte van het bericht van de gegevensverwerker dat moet worden geserialiseerd en ingesteld als de hoofdtekst van de aanvraag. Laat leeg als u geen aanvraagbody hoeft te verzenden. | Nee | - | .payload.gRPCRequest |
Api-aanvraagmetagegevenssleutel > >2 | Statisch/dynamisch veld | De metagegevenssleutel die moet worden ingesteld in de aanvraag. | Nee | Statisch/dynamisch veld | |
Metagegevenswaarde >van API-aanvraag > 2 | Statisch/dynamisch veld | De metagegevenswaarde die moet worden ingesteld in de aanvraag. | Nee | Statisch/dynamisch veld |
1Descriptor: Als u de aanvraagbody wilt serialiseren, hebt u een base 64-gecodeerde descriptor van het PROTO-bestand nodig.
Gebruik de volgende opdracht om de descriptor te genereren, vervang deze door <proto-file>
de naam van uw PROTO-bestand:
protoc --descriptor_set_out=/dev/stdout --include_imports <proto-file> | base64 | tr '\n' ' ' | sed 's/[[:space:]]//g'
Gebruik de uitvoer van de vorige opdracht als de descriptor
in de configuratie.
2API-aanvraagmetagegevens>: elk element in de metagegevensmatrix is een sleutel-waardepaar. U kunt de sleutel of waarde dynamisch instellen op basis van de inhoud van het binnenkomende bericht of als een statische tekenreeks.