Tworzenie zadań Stream Analytics Edge za pomocą narzędzi Visual Studio

W tym artykule nauczysz się, jak korzystać z narzędzi Stream Analytics dla Visual Studio do tworzenia, debugowania i tworzenia zadań Stream Analytics Edge. Po utworzeniu i przetestowaniu zadania wchodzisz do portalu Azure, aby wdrożyć je na swoich urządzeniach.

Wymagania wstępne do tworzenia stanowisk Edge

Aby wykonać kroki opisane w tym artykule, potrzebujesz następujących warunków wstępnych:

  1. Zainstaluj Visual Studio 2019, Visual Studio 2015 lub Visual Studio 2013 Update 4. Narzędzia Stream Analytics obsługują edycje Enterprise (Ultimate/Premium), Professional i Community, ale nie edycję Express.

  2. Postępuj zgodnie z instrukcjami instalacji , aby zainstalować narzędzia usługi Stream Analytics dla programu Visual Studio.

Stwórz projekt Stream Analytics Edge

Stwórz projekt Edge, który zawiera definicję twojego stanowiska.

  1. Z programu Visual Studio wybierz Plik>Nowy>Projekt. Przejdź do listy Szablony po lewej stronie, a następnie rozwiń Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Wprowadź nazwę, lokalizację i nazwę rozwiązania dla swojego projektu, a następnie wybierz OK.

    Zrzut ekranu okna dialogowego New Project dotyczący tworzenia aplikacji Azure Stream Analytics Edge w Visual Studio.

  2. Po utworzeniu projektu przez Visual Studio przejdź do Eksplorator rozwiązań, aby zobaczyć hierarchię folderów.

    Zrzut ekranu Eksplorator rozwiązań pokazujący hierarchię folderów projektu Stream Analytics Edge w Visual Studio.

Wybierz właściwą subskrypcję

Połącz Visual Studio z subskrypcją Azure, w której chcesz utworzyć zadanie.

  1. W menu Visual Studio View wybierz Eksploratora serwera.

  2. Wybierz i przytrzymaj (lub kliknij prawym przyciskiem myszy) Azure, wybierz Połącz się z subskrypcją Microsoft Azure, a następnie zaloguj się swoim kontem Azure.

Definiowanie danych wejściowych

Skonfiguruj wejście usługi Edge Hub, z którego zadanie odczytuje zdarzenia strumieniowe.

  1. Z Eksplorator rozwiązań rozwiń węzeł Inputs. Widzisz wejście o nazwie EdgeInput.json. Otwórz go, aby zobaczyć ustawienia.

  2. Ustaw typ źródła na Strumień danych. Następnie ustaw Source na Edge Hub, Event Serialization Format na JSON, a Encoding na UTF8. Opcjonalnie można zmienić nazwę Input Alias, ale pozostawić ją tak, jak jest w tym przykładzie. Jeśli zmienisz nazwę aliasu wejściowego, użyj nazwy, którą podajesz podczas definiowania zapytania. Wybierz pozycję Zapisz, aby zapisać ustawienia. Zrzut ekranu ustawień konfiguracji wejścia Edge Hub w Stream Analytics w Visual Studio.

Definiowanie danych wyjściowych

Konfiguruj wyjście Edge Hub, na które dane zadanie zapisuje wyniki.

  1. Z Eksplorator rozwiązań rozwiń węzeł Outputs. Widzisz wyjście o nazwie EdgeOutput.json. Otwórz go, aby zobaczyć ustawienia.

  2. Ustaw Sink na Edge Hub, ustaw format serializacji zdarzeń na JSON, ustaw kodowanie na UTF8, a format na tablicę. Opcjonalnie można zmienić nazwę aliasu wyjściowego, ale pozostawić go bez zmian w tym przykładzie. Jeśli zmienisz nazwę aliasu wyjściowego, użyj nazwy, którą podałeś podczas definiowania zapytania. Wybierz pozycję Zapisz, aby zapisać ustawienia. Zrzut ekranu ustawień konfiguracji wyjściowej Edge Hub w Stream Analytics w Visual Studio.

Przegląd operacji bez wsparcia

Zadania Stream Analytics wdrożone w środowiskach Stream Analytics IoT Edge obsługują większość elementów opisanych w dokumentacji języka zapytań Stream Analytics. Jednak następujące operacje nie są obsługiwane dla zadań Stream Analytics Edge:

  1. PARTYCJONOWANIE WEDŁUG
  2. ZNACZNIK CZASU WEDŁUG
  3. JavaScript UDF
  4. Agregaty zdefiniowane przez użytkownika (UDA)
  5. GetMetadataPropertyValue
  6. Wykorzystanie ponad 14 agregatów w jednym kroku

Gdy tworzysz zadanie Stream Analytics Edge w portalu, kompilator automatycznie ostrzega, jeśli nie korzystasz z obsługiwanego operatora.

Definiowanie zapytania przekształcenia

W programie Visual Studio zdefiniuj następujące zapytanie transformacyjne w edytorze zapytań (plik script.asaql).

SELECT * INTO EdgeOutput
FROM EdgeInput

Sprawdź pracę lokalnie

Aby przetestować zapytanie lokalnie, przesłaj przykładowe dane. Aby pobrać przykładowe dane, pobierz dane rejestracyjne z repozytorium GitHub i zapisz je na swoim lokalnym komputerze.

  1. Aby przesłać dane próbki, należy zaznaczyć i przytrzymać (lub kliknąć prawym przyciskiem myszy) plik EdgeInput.json , a następnie wybrać Dodaj lokalne wejście.

  2. W oknie wyskakującym przeglądaj przykładowe dane z lokalnej ścieżki i wybierz Zapisz.

    Zrzut ekranu lokalnej konfiguracji wejściowej do przesyłania danych próbkowych w Visual Studio.

  3. Visual Studio automatycznie dodaje plik o nazwie local_EdgeInput.json do folderu z wejściem.

  4. Możesz uruchomić go lokalnie lub przesłać do Azure. Aby przetestować zapytanie, wybierz Uruchom lokalnie.

    Zrzut ekranu opcji uruchamiania zadania w usłudze Stream Analytics, pokazujący opcję Uruchom lokalnie w programie Visual Studio.

  5. Okno wiersza poleceń pokazuje status zadania. Po pomyślnym uruchomieniu zadania w ścieżce folderu projektu Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42 zostanie utworzony folder o nazwie 2018-02-23-11-31-42. Przejdź do ścieżki folderu, aby zobaczyć wyniki w lokalnym folderze.

    Możesz też zalogować się do portalu Azure i zweryfikować, że zadanie zostało utworzone.

    Zrzut ekranu folderu z wynikami zadań Stream Analytics pokazujący lokalne wyniki uruchomienia w Visual Studio.

Zgłoś zadanie do Azure

Po przetestowaniu zapytania publikuj zadanie na swojej subskrypcji Azure.

  1. Zanim zgłosisz zadanie do Azure, połącz się ze swoją subskrypcją Azure. Otwórz Server Explorer, wybierz i przytrzymaj (lub kliknij prawym przyciskiem myszy) Azure, wybierz Połącz się z subskrypcją Microsoft Azure, a następnie zaloguj się do swojej subskrypcji Azure.

  2. Aby przesłać zadanie do Azure, przejdź do edytora zapytań i wybierz Wyślij do Azure.

  3. Otwiera się okno wyskakujące (pop-up). Wybierz aktualizację istniejącego stanowiska Stream Analytics Edge lub utworzenie nowego. Gdy aktualizujesz istniejące zadanie, zastępuje on całą konfigurację zadań. W takim scenariuszu publikujesz nową pracę. Wybierz pozycję Utwórz nowe zadanie usługi Azure Stream Analytics, wprowadź nazwę zadania, na przykład MyASAEdgeJob, wybierz wymaganą Subskrypcję, Grupę zasobów i Lokalizację, a następnie wybierz Prześlij.

    Zrzut ekranu okna dialogowego do przesłania zadania Stream Analytics Edge do Azure z Visual Studio.

    Teraz masz pracę w Stream Analytics Edge. Aby dowiedzieć się, jak go wdrażać na swoich urządzeniach, zobacz Uruchamiaj zadania na IoT Edge.

Zarządzaj pracą

Zarządzaj statusem zadania i diagramem zadań z Server Explorer.

  1. Z Stream Analytics w Server Explorer rozwiń subskrypcję i grupę zasobów, w której wdrożyłeś zadanie Stream Analytics Edge. Widzisz MyASAEdgejob ze statusem Utworzony. Rozwiń węzeł zadania, a następnie otwórz go, aby wyświetlić zadanie.

    Zrzut ekranu z Eksploratora Serwera pokazujący opcje zarządzania zadaniami dla pracy Stream Analytics Edge.

  2. W oknie widoku pracy możesz odświeżyć zadanie, usunąć je i otworzyć w portalu Azure.

    Zrzut ekranu okna pracy pokazującego diagram zadań i inne opcje w Visual Studio.

Treści powiązane

  • Last updated on