Testowanie zapytania usługi Stream Analytics lokalnie względem danych wejściowych strumienia na żywo za pomocą Visual Studio Code

  • Artykuł

Testowanie zapytania usługi Stream Analytics lokalnie względem danych wejściowych strumienia na żywo jest kluczowym krokiem w zapewnieniu dokładności i wydajności logiki zapytań. Rozszerzenie usługi Azure Stream Analytics (ASA) dla Visual Studio Code (VS Code) zapewnia narzędzia niezbędne do bezproblemowego przeprowadzania tego testowania. Ten artykuł przeprowadzi Cię przez kroki konfigurowania środowiska, konfigurowania danych wejściowych strumienia na żywo i wykonywania zapytania lokalnie w celu dokładnego testowania.

Wymagania wstępne

Definiowanie danych wejściowych strumienia na żywo

  1. Kliknij prawym przyciskiem myszy folder Inputs w projekcie usługi Stream Analytics i wybierz pozycję ASA: Dodaj dane wejściowe. Zrzut ekranu rozszerzenia VSCode z dodawaniem danych wejściowych za pomocą menu rozwijanego. LUB naciśnij klawisze Ctrl+Shift+P , aby otworzyć paletę poleceń i wprowadzić ciąg ASA: Dodaj dane wejściowe. Następnie wybierz skrypt zapytania do przetwarzania strumienia wejściowego. Zrzut ekranu rozszerzenia VSCode z dodawaniem danych wejściowych za pomocą palety poleceń.

  2. Wybierz typ źródła danych wejściowych na żywo z listy rozwijanej Wybierz z subskrypcji platformy Azure i wprowadź nazwę źródła danych wejściowych. Zrzut ekranu rozszerzenia VSCode przedstawiający serię kroków konfiguracji danych wejściowych centrum zdarzeń.

  3. W folderze Input zostanie wyświetlony nowy plik JSON. Otwórz plik i wybierz z subskrypcji , aby ułatwić skonfigurowanie danych wejściowych usługi Event Hubs. Zrzut ekranu rozszerzenia VSCode przedstawiający wejściowe pliki JSON.

  4. Wybierz pozycję Podgląd danych , aby sprawdzić, czy dane wejściowe na żywo zostały pomyślnie skonfigurowane. Zrzut ekranu przedstawiający rozszerzenie VSCode wyświetlające podgląd danych wejściowych na żywo.

Uruchamianie zapytania lokalnie

Otwórz plik zapytania, wybierz pozycję Uruchom lokalnie lub przycisk Odtwórz na pasku menu, aby otworzyć okno opcji Uruchamianie lokalne na potrzeby konfigurowania lokalnego trybu uruchamiania.

Zrzut ekranu przedstawiający rozszerzenie VSCode wybierające pozycję

Wybierz pozycję Użyj danych wejściowych na żywo i lokalnych danych wyjściowych , aby uruchomić zadanie lokalnie względem strumienia wejściowego na żywo i wygenerować wyniki wyjściowe w folderze lokalnym. Następnie wybierz pozycję Uruchom , aby uruchomić zadanie lokalnie.

Zrzut ekranu rozszerzenia VSCode wybierającego tryb odtwarzania dla przebiegu lokalnego.

Możesz zobaczyć, że okno lokalnego testu jest otwarte i odświeżane co 3 sekundy. Wyniki wyjściowe są przechowywane w formacie JSON w folderze LocalRunOutputs .

Zrzut ekranu przedstawiający rozszerzenie VSCode z lokalnym oknem testu.

Określanie partycji wejściowych na potrzeby testowania lokalnego

Aby uniknąć pozyskiwania wszystkich danych z usługi Event Hubs, możesz określić określone partycje dla usługi Event Hubs podczas testowania lokalnego.

  1. Wybierz pozycję Uruchom lokalnie , aby otworzyć okno opcji uruchamiania lokalnego.
  2. W obszarze Wybierz sekcję Partycje wejściowe i wybierz pozycję Niestandardowe.
  3. Wprowadź określone numery partycji, z których chcesz pozyskać dane na potrzeby testowania lokalnego.

Zrzut ekranu rozszerzenia VSCode określający partycje centrum zdarzeń.

Określając partycje, możesz skupić się na testowaniu logiki zapytań bez martwienia się o dużą ilość danych. Ta funkcja umożliwia wydajniejsze i ukierunkowane testowanie zadania usługi Stream Analytics.

Przesyłanie zadania do platformy Azure

Po zakończeniu testowania zapytania lokalnie możesz przesłać projekt usługi Stream Analytics na platformę Azure i rozpocząć uruchamianie zadania w chmurze.

  1. Wybierz opcję Prześlij do platformy Azure lub wybierz przycisk Przekaż w pliku zapytania.
  2. W oknie opcji przesyłania możesz zaktualizować istniejące zadanie na platformie Azure lub utworzyć nowe zadanie przekazywania.
  3. Podaj niezbędne szczegóły, w tym subskrypcję, grupę zasobów i region wdrożenia.

Zrzut ekranu przedstawiający rozszerzenie VSCode przesyłające zadanie na platformę Azure.

Po zakończeniu procesu przesyłania możesz wyświetlić zadanie w chmurze w nowym oknie. Z tego poziomu możesz monitorować jego wydajność i zarządzać konfiguracjami zgodnie z potrzebami. Zadanie można również otworzyć w przeglądarce, klikając link podany w panelu DANE WYJŚCIOWE.

Zrzut ekranu rozszerzenia VSCode przedstawiający zadanie widoku chmury.

Następne kroki