Partager via

Test local de la requête Stream Analytics par rapport à l’entrée de flux en direct avec Visual Studio Code

Le test local de votre requête Stream Analytics par rapport à l’entrée de flux en direct est une étape cruciale pour garantir l’exactitude et l’efficacité de votre logique de requête. Avec l’extension Azure Stream Analytics (ASA) pour Visual Studio Code (VS Code), vous disposez des outils nécessaires pour effectuer ces tests de manière transparente. Cet article vous guide tout au long des étapes de configuration de votre environnement, de configuration de l’entrée de flux en direct et d’exécution de votre requête localement pour un test approfondi.

Conditions préalables

Définir une entrée de flux en direct

  1. Cliquez avec le bouton droit sur le dossier Inputs dans votre projet Stream Analytics et sélectionnez ASA : Ajouter une entrée. Capture d’écran de l’extension VS Code ajoutant une entrée via le menu déroulant. OU appuyez sur Ctrl+Maj+P pour ouvrir la palette de commandes et entrez ASA : Ajouter une entrée. Choisissez ensuite le script de requête pour le traitement du flux d’entrée. Capture d’écran de l’extension VS Code ajoutant une entrée via la palette de commandes.

  2. Choisissez un type de source d’entrée en direct dans la liste déroulante, sélectionnez-le dans vos abonnements Azure et entrez un nom pour la source d’entrée. Capture d’écran de l’extension VS Code montrant une série d’étapes pour la configuration de l’entrée Event Hub.

  3. Un nouveau fichier JSON est créé dans le dossier Input . Ouvrez le fichier et sélectionnez-le dans vos abonnements pour vous aider à configurer votre entrée Event Hubs. Capture d’écran de l’extension VS Code montrant les fichiers json d’entrée.

  4. Sélectionnez Aperçu des données pour vérifier si l’entrée en direct est correctement configurée. Capture d’écran de l’extension VS Code prévisualisant les données d’entrée en direct.

Exécuter la requête localement

Ouvrez votre fichier de requête, sélectionnez Exécuter localement ou le bouton Lecture dans la barre de menus pour ouvrir une fenêtre d’option d’exécution locale pour configurer le mode d’exécution locale.

Capture d’écran de l’extension VS Code sélectionnant « Exécuter localement » dans l’éditeur de requête.

Choisissez Utiliser l’entrée en direct et la sortie locale pour exécuter le travail localement sur le flux d’entrée en direct et produire les résultats de sortie dans un dossier local. Sélectionnez ensuite Exécuter pour commencer à exécuter le travail localement.

Capture d’écran de l’extension VS Code sélectionnant le mode de lecture pour l’exécution locale.

Vous pouvez voir qu’une fenêtre de test local est ouverte et actualisée toutes les 3 secondes. Les résultats de sortie sont stockés au format JSON dans le dossier LocalRunOutputs .

Capture d’écran de l’extension VS Code montrant la fenêtre de test locale.

Spécifier des partitions d’entrée pour les tests locaux

Pour éviter d’ingérer toutes les données d’Event Hubs, vous pouvez spécifier des partitions spécifiques pour vos Event Hubs lors des tests locaux.

  1. Sélectionnez Exécuter localement pour ouvrir la fenêtre d’option d’exécution locale.
  2. Sous la section Sélectionner les partitions d’entrée, choisissez Personnalisé.
  3. Entrez les numéros de partition spécifiques à partir desquels vous souhaitez ingérer des données pour vos tests locaux.

Capture d’écran de l’extension VS Code spécifiant les partitions du hub d’événements.

En spécifiant les partitions, vous pouvez vous concentrer sur le test de votre logique de requête sans vous soucier d’un grand volume de données. Cette fonctionnalité permet de tester plus efficacement et de manière plus ciblée votre tâche Stream Analytics.

Soumettre un travail à Azure

Une fois que vous avez terminé de tester votre requête localement, vous pouvez soumettre votre projet Stream Analytics à Azure et commencer à exécuter le travail dans le cloud.

  1. Sélectionnez l’option Envoyer à Azure ou sélectionnez le bouton Charger dans le fichier de requête.
  2. Dans la fenêtre des options d’envoi, vous pouvez mettre à jour un travail existant dans Azure ou créer un travail pour le chargement.
  3. Fournissez les détails nécessaires, y compris votre abonnement, votre groupe de ressources et votre région pour le déploiement.

Capture d’écran de l’extension VS Code soumettant un travail à Azure.

Une fois le processus de soumission terminé, vous pouvez afficher votre tâche cloud dans une nouvelle fenêtre. À partir de là, vous pouvez surveiller ses performances et gérer ses configurations selon vos besoins. Vous pouvez également ouvrir la tâche dans votre navigateur en cliquant sur le lien fourni dans le panneau OUTPUT.

Capture d’écran de l’extension VS Code montrant la tâche d’affichage du cloud.

Étapes suivantes

  • Last updated on