Développez des tâches Stream Analytics Edge à l’aide des outils Visual Studio

Dans cet article, vous apprenez à utiliser les outils Stream Analytics pour Visual Studio afin de créer, déboguer et créer des jobs Stream Analytics Edge. Après avoir créé et testé le travail, vous allez sur le portail Azure pour le déployer sur vos appareils.

Prérequis pour développer des emplois Edge

Vous devez remplir les prérequis suivants pour compléter les étapes de cet article :

  1. Installez Visual Studio 2019, Visual Studio 2015 ou Visual Studio 2013 Mise à jour 4. Les outils Stream Analytics prennent en charge les éditions Enterprise (Ultimate/Premium), Professional et Community, mais pas l’édition Express.

  2. Suivez les instructions d’installation pour installer Stream Analytics Tools pour Visual Studio.

Créer un projet Stream Analytics Edge

Créez le projet Edge qui contient la définition de votre poste.

  1. Depuis Visual Studio, sélectionnez Fichier>Nouveau>Projet. Accédez à la liste Modèles située à gauche, puis développez Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Saisissez un nom, un emplacement et un nom de solution pour votre projet, puis sélectionnez OK.

    Capture d’écran de la boîte de dialogue New Project pour créer une application Azure Stream Analytics Edge dans Visual Studio.

  2. Après que Visual Studio ait créé le projet, allez dans l’Explorer de la solution pour voir la hiérarchie des dossiers.

    Capture d’écran de Explorateur de solutions montrant la hiérarchie des dossiers d’un projet Stream Analytics Edge dans Visual Studio.

Choisissez le bon abonnement

Connectez Visual Studio à l’abonnement Azure où vous souhaitez créer le poste.

  1. Depuis le menu Vue de Visual Studio, sélectionnez Explorateur serveur.

  2. Sélectionnez et maintenez (ou faites clic droit) sur Azure, sélectionnez Connecter à Microsoft Azure Abonnement, puis connectez-vous avec votre compte Azure.

Définir des entrées

Configurez l’entrée Edge Hub à partir de laquelle le job lit les événements en streaming.

  1. Dans l’Explorateur de solutions, développez le nœud Entrées. Vous voyez une entrée nomméeEdgeInput.json. Ouvrez-le pour voir ses paramètres.

  2. Définir le type de source sur flux de données. Ensuite, réglez la source sur Edge Hub, le format de sérialisation des événements sur Json, et l’encodage sur UTF8. Optionnellement, renommer l’alias d’entrée, mais le laisser tel quel pour cet exemple. Si vous renommez l’alias d’entrée, utilisez le nom que vous spécifiez lors de la définition de la requête. Sélectionnez Enregistrer pour enregistrer les paramètres. Capture d’écran des paramètres de configuration d’entrée du Stream Analytics Edge Hub dans Visual Studio.

Définir des sorties

Configurez la sortie Edge Hub sur laquelle le travail écrit les résultats.

  1. Dans l’Explorateur de solutions, développez le nœud Outputs. Vous voyez une sortie nomméeEdgeOutput.json. Ouvrez-le pour voir ses paramètres.

  2. Définissez le Récepteur pour sélectionner Edge Hub, puis définissez le format de sérialisation d’événement sur Json, la valeur d’encodage sur UTF8 et le format sur Tableau. Éventuellement, renommer l’alias de sortie, mais le laisser tel quel pour cet exemple. Si vous renommez l’alias de sortie, utilisez le nom que vous spécifiez lorsque vous définissez la requête. Sélectionnez Enregistrer pour enregistrer les paramètres. Capture d’écran des paramètres de configuration de sortie du Stream Analytics Edge Hub dans Visual Studio.

Examiner les opérations non prises en charge

Les travaux Stream Analytics déployés dans les environnements Stream Analytics IoT Edge prennent en charge la plupart des références du langage de requête Stream Analytics. Cependant, les opérations suivantes ne sont pas prises en charge pour les tâches Stream Analytics Edge :

  1. PARTITION PAR
  2. TIMESTAMP BY OVER
  3. UDF JavaScript
  4. Agrégats définis par l’utilisateur (UDA)
  5. GetMetadataPropertyValue
  6. Utiliser plus de 14 agrégats en une seule étape

Lorsque vous créez un job Stream Analytics Edge dans le portail, le compilateur vous avertit automatiquement si vous n’utilisez pas un opérateur supporté.

Définir la requête de transformation

Depuis Visual Studio, définissez la requête de transformation suivante dans l’éditeur de requêtes (le script.asaql fichier).

SELECT * INTO EdgeOutput
FROM EdgeInput

Testez le travail localement

Pour tester la requête localement, téléchargez les données d’exemple. Pour obtenir des données d’exemple, téléchargez les données d’enregistrement depuis le dépôt GitHub et enregistrez-les sur votre ordinateur local.

  1. Pour télécharger des données d’échantillon, sélectionnez et maintenez (ou faites un clic droit) sur le fichierEdgeInput.json , puis sélectionnez Ajouter une entrée locale.

  2. Dans la fenêtre contextuelle, parcourez les données d’exemple de votre chemin local et sélectionnez Enregistrer.

    Capture d’écran de la configuration locale de saisie pour le téléchargement des données d’échantillons dans Visual Studio.

  3. Visual Studio ajoute automatiquement un fichier nommé local_EdgeInput.json à votre dossier d’entrées.

  4. Vous pouvez soit l’exécuter localement, soit le soumettre à Azure. Pour tester la requête, sélectionnez Exécuter localement.

    Capture d’écran des options d’exécution de tâches Stream Analytics montrant Exécuter localement dans Visual Studio.

  5. La fenêtre de l’invite de commande affiche l’état de la tâche. Lorsque le travail s’exécute avec succès, il crée un dossier qui ressemble 2018-02-23-11-31-42 au chemin Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42de votre dossier de projet . Va dans le chemin du dossier pour voir les résultats dans le dossier local.

    Vous pouvez également vous connecter au portail Azure et vérifier que le poste a été créé.

    Capture d’écran du dossier de résultats du travail Stream Analytics montrant la sortie locale des exécutions dans Visual Studio.

Soumettre le travail à Azure

Après avoir testé la requête, publiez le travail sur votre abonnement Azure.

  1. Avant de soumettre le travail à Azure, connectez-vous à votre abonnement Azure. Ouvrez l’Explorateur de serveur, sélectionnez et maintenez (ou faites clic droit) sur Azure, sélectionnez Connecter à un abonnement Microsoft Azure, puis connectez-vous à votre abonnement Azure.

  2. Pour soumettre la tâche à Azure, allez dans l’éditeur de requêtes et sélectionnez Soumettre à Azure.

  3. Une fenêtre contextuelle s’ouvre. Choisissez de mettre à jour un job existant sur Stream Analytics Edge ou d’en créer un nouveau. Lorsque vous mettez à jour un poste existant, cela remplace toute la configuration du poste. Dans ce scénario, vous publiez un nouvel emploi. Sélectionnez Créer un nouveau poste Azure Stream Analytics, saisissez un nom pour votre poste tel que MyASAEdgeJob, sélectionnez l’abonnement, le groupe de ressources et l’emplacement requis, puis sélectionnez Envoyer.

    Capture d’écran de la boîte de dialogue pour soumettre un travail Stream Analytics Edge vers Azure depuis Visual Studio.

    Vous avez maintenant un poste en Stream Analytics Edge. Pour savoir comment le déployer sur vos appareils, voir Exécuter des tâches sur IoT Edge.

Gérez le travail

Gérez le statut du poste et le schéma du poste depuis l’Explorateur de serveur.

  1. Depuis Stream Analytics dans Server Explorer, élargissez l’abonnement et le groupe de ressources où vous avez déployé le job Stream Analytics Edge. Vous voyez MyASAEdgejob avec le statut Créé. Développez le nœud de tâche, puis ouvrez-le pour afficher la tâche.

    Capture d’écran de Server Explorer montrant les options de gestion de poste pour un job Stream Analytics Edge.

  2. Dans la fenêtre de la vue du poste, vous pouvez rafraîchir le poste, le supprimer et l’ouvrir dans le portail Azure.

    Capture d’écran de la fenêtre de la vue du poste montrant le diagramme du travail et d’autres options dans Visual Studio.

Contenu connexe

  • Last updated on