Envoyer des données à un point de terminaison gRPC avec le processeur de données
Important
Opérations Azure IoT (préversion) – activé parc Azure Arc est actuellement en PRÉVERSION. Vous ne devez pas utiliser ce logiciel en préversion dans des environnements de production.
Vous devrez déployer une nouvelle installation d’Azure IoT Operations lorsqu’une version en disponibilité générale est mise à disposition, vous ne pourrez pas mettre à niveau une installation en préversion.
Pour connaître les conditions juridiques qui s’appliquent aux fonctionnalités Azure en version bêta, en préversion ou plus généralement non encore en disponibilité générale, consultez l’Avenant aux conditions d’utilisation des préversions de Microsoft Azure.
Utilisez la destination gRPC pour écrire des données traitées et propres dans un point de terminaison gRPC pour un traitement plus approfondi.
Lorsque vous envoyez des données à un point de terminaison gRPC à partir d’une étape de destination :
- Actuellement, la phase prend uniquement en charge le type RPC unaire.
- Vous ne pouvez utiliser que le format Protobuf . Vous devez utiliser le Protobuf avec l’étape d’appel de gRPC.
- Étant donné que cette étape est une destination de pipeline, la réponse est ignorée.
Prérequis
Pour configurer et utiliser un index de pipeline de destination, vous avez besoin des éléments suivants :
- Instance déployée du processeur de données qui inclut le composant facultatif du processeur de données.
- Serveur gRPC accessible à partir de l’instance du processeur de données.
- L’outil
protoc
permettant de générer le descripteur.
Configuration de l’étape de destination
La configuration gRPC de l’étape de destination JSON définit les détails de l’étape. Pour créer l’index, vous pouvez interagir avec l’interface utilisateur basée sur le formulaire ou fournir la configuration JSON sous l’onglet Avancé :
Nom | Type | Description | Obligatoire | Par défaut | Exemple |
---|---|---|---|---|---|
Nom | chaîne | Nom à afficher dans l’interface utilisateur du processeur de données. | Oui | - | MLCall2 |
Description | string | Description conviviale de l’index de destination. | Non | Call ML endpoint 2 |
|
Server address | Chaîne | Adresse du serveur gRPC | Oui | - | https://localhost:1313 |
Nom RPC | string | Nom RPC à appeler | Oui | - | GetInsights |
Descripteur1 | Chaîne | Descripteur codé en base 64 | Oui | - | CuIFChxnb29nb |
Authentification | string | Type d’authentification à utiliser. None /Metadata . |
Oui | None |
None |
Clé de métadonnées | string | Clé de métadonnées à utiliser lorsque Authentication est défini sur Metadata . |
Non | authorization |
authorization |
Secret | string | La référence secrète à utiliser lorsque Authentication est défini sur Metadata . |
Non | - | mysecret |
Réessayer | Réessayer | La stratégie de nouvelles tentatives à utiliser. | Non | default |
fixed |
Requête API > Chemin du corps | Chemin d’accès | Chemin d’accès à la partie du message du processeur de données qui doit être sérialisé et défini comme corps de la requête. Laissez vide si vous n’avez pas besoin d’envoyer un corps de la demande. | Non | - | .payload.gRPCRequest |
Requête API > Métadonnées > Clé2 | Champ statique/dynamique | Clé de métadonnées à définir dans la requête. | Non | Champ statique/dynamique | |
Requête API > Métadonnées > Valeur2 | Champ statique/dynamique | Valeur des métadonnées à définir dans la requête. | Non | Champ statique/dynamique |
1Descripteur : pour sérialiser le corps de la demande, vous avez besoin d’un descripteur encodé en base 64 du fichier .proto.
Utilisez la commande suivante pour générer le descripteur, remplacez <proto-file>
par le nom de votre fichier .proto :
protoc --descriptor_set_out=/dev/stdout --include_imports <proto-file> | base64 | tr '\n' ' ' | sed 's/[[:space:]]//g'
Utilisez la sortie de la commande précédente comme descriptor
dans la configuration.
2Requête API > Métadonnées : chaque élément du tableau de métadonnées est une paire clé-valeur. Vous pouvez définir dynamiquement la clé ou la valeur en fonction du contenu du message entrant ou sous forme de chaîne statique.