Quickstart: stwórz zadanie Stream Analytics w Visual Studio

W tym szybkim starcie tworzysz zadanie Stream Analytics, korzystając z narzędzi Azure Stream Analytics dla Visual Studio. Przykładowe zadanie odczytuje dane strumieniowe z urządzenia IoT. Definiujesz zadanie, które oblicza średnią temperaturę, gdy wartość przekracza 27° i zapisuje powstałe zdarzenia wyjściowe do nowego pliku w pamięci blob.

Wymagania wstępne

Zanim zaczniesz, upewnij się, że masz spełnione następujące wymagania.

Uwaga / Notatka

Aby uzyskać najlepsze środowisko programowania lokalnego, użyj narzędzi usługi Stream Analytics dla programu Visual Studio Code. Narzędzia do analizy strumieni dla Visual Studio 2019 (wersja 2.6.3000.0) mają znane luki w funkcjach i nie przechodzą dalszych ulepszeń. Narzędzia visual Studio i Visual Studio Code nie obsługują zadań w regionach Chiny Wschodnie, Chiny Północne, Niemcy Środkowe i Niemcy Północne.

• Konto platformy Azure z aktywną subskrypcją. Jeśli nie masz subskrypcji platformy Azure, utwórz bezpłatne konto.

• Visual Studio 2019 Edycje Enterprise (Ultimate/Premium), Professional i Community działają, ale edycja Express nie.

• Zainstalowane narzędzia Stream Analytics dla Visual Studio.

Przygotowywanie danych wejściowych

Zanim zdefiniujesz zadanie Stream Analytics, przygotuj dane, które później skonfigurujesz jako wejście do zadania. Aby przygotować dane wejściowe, wykonaj następujące kroki:

1. Zaloguj się do witryny Azure Portal.

2. Wybierz Utwórz zasób>Internet rzeczy>IoT Hub.

3. W okienku usługi IoT Hub wprowadź następujące informacje:

   Ustawienie	Sugerowana wartość	Opis
   Subscription	<Twoja subskrypcja>	Wybierz subskrypcję platformy Azure, której chcesz użyć.
   Grupa zasobów	Grupa zasobów asaquickstart	Wybierz pozycję Utwórz nowy i wprowadź nową nazwę grupy zasobów dla swojego konta.
   Nazwa centrum IoT	MyASAIoTHub	Wybierz nazwę dla swojego huba IoT.
   Region	<Wybierz region najbliższy Twoim użytkownikom>	Wybierz lokalizację geograficzną, w której możesz hostować swój hub IoT. Użyj lokalizacji znajdującej się najbliżej Twoich użytkowników.
   Warstwa	Bezpłatna	W tym szybkim startzie wybierz pozycję Bezpłatna, jeśli jest ona nadal dostępna w ramach subskrypcji. Jeśli warstwa Bezpłatna jest niedostępna, wybierz najniższą dostępną warstwę. Aby uzyskać więcej informacji, zobacz Cennik usługi IoT Hub.

   

4. Wybierz opcję Recenzja i utwórz. Przeglądaj informacje o swoim hubie IoT i wybierz Create. Utworzenie hubu IoT może potrwać kilka minut. Monitoruj postęp w okienku Powiadomienia .

5. Po zakończeniu wdrożenia wybierz Przejdź do zasobu , aby przejść do strony huba IoT dla swojego huba IoT.

6. Na stronie usługi IoT Hub wybierz pozycję Urządzenia w obszarze Zarządzanie urządzeniami w menu nawigacji po lewej stronie.

7. Na stronie Urządzenia wybierz pozycję + Dodaj urządzenie na pasku narzędzi.

   

8. Na stronie Tworzenie urządzenia wprowadź nazwę urządzenia, a następnie wybierz pozycję Zapisz.

   

9. Po utworzeniu urządzenia otwórz je z listy urządzeń IoT . Jeśli urządzenie nie jest jeszcze widoczne, odśwież stronę.

   

10. Skopiuj podstawowe parametry połączenia i zapisz je w Notatniku, aby użyć go później.

Twórz magazyn obiektów blob

W tej sekcji tworzysz konto Azure Storage oraz kontener blob, aby przechować zdarzenia wyjściowe z twojej pracy.

1. W lewym górnym rogu portalu Azure wybierz Utwórz zasób>magazyn>konto magazynu.

2. W okienku Tworzenie konta magazynu wprowadź nazwę konta magazynu, lokalizację i grupę zasobów. Wybierz tę samą lokalizację i grupę zasobów co utworzona usługa IoT Hub. Następnie wybierz pozycję Przejrzyj i utwórz , aby utworzyć konto.

   

3. Po utworzeniu konta magazynowego wybierz kafelek usługi Blob w panelu Przegląd .

   

4. Na stronie Blob Service wybierz pozycję + Kontener na pasku narzędzi.

5. Na stronie Nowy kontener wprowadź nazwę kontenera , na przykład container1. Pozostaw poziom dostępu publicznego jako Prywatny (bez dostępu anonimowego) i wybierz pozycję Utwórz.

   

Tworzenie projektu usługi Stream Analytics

Stwórz projekt Stream Analytics w Visual Studio, aby zdefiniować wejścia, wyjścia i zapytania zadania.

1. Uruchom program Visual Studio.

2. Wybierz Plik>Nowy projekt.

3. Na liście szablonów wybierz Stream Analytics, a następnie Azure Stream Analytics Application.

4. Wpisz nazwę projektu, lokalizację i nazwę rozwiązania, a następnie wybierz Create.

   

5. Zwróć uwagę na elementy w projekcie Azure Stream Analytics.

   

Wybierz wymaganą subskrypcję

Połącz Visual Studio z subskrypcją Azure, która zawiera stworzone przez Ciebie zasoby.

1. W programie Visual Studio w menu Widok wybierz pozycję Eksplorator 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 zadania tak, aby odczytywało dane strumieniowe z utworzonego przez Ciebie huba IoT.

1. W Eksplorator rozwiązań rozwiń węzeł Inputs i otwórz Input.json.

2. Wypełnij konfigurację danych wejściowych usługi Stream Analytics następującymi wartościami:

   Ustawienie	Sugerowana wartość	Opis
   Alias wejściowy	Input	Wpisz nazwę, aby zidentyfikować dane wejściowe zadania.
   Typ źródła	Strumień danych	Wybierz odpowiednie źródło danych wejściowych: strumień danych lub dane referencyjne.
   Źródło	Centrum IoT	Wybierz odpowiednie źródło danych wejściowych.
   Resource	Wybieranie źródła danych z bieżącego konta	Wybierz ręczne wprowadzanie danych lub wybierz istniejące konto.
   Subscription	<Twoja subskrypcja>	Wybierz subskrypcję Azure, która ma utworzony przez Ciebie hub IoT.
   Centrum IoT	MyASAIoTHub	Wybierz lub wprowadź nazwę swojego huba IoT. Nazwy hubów IoT pojawiają się automatycznie, jeśli utworzysz je w tej samej subskrypcji.

3. Pozostaw inne opcje wartości domyślne i wybierz pozycję Zapisz , aby zapisać ustawienia.

   

Definiowanie danych wyjściowych

Skonfiguruj dane wyjściowe zadania, aby zapisywać wyniki do kontenera usługi Blob Storage.

1. W Eksplorator rozwiązań rozwiń węzeł Outputs i otwórz Output.json.

2. Wypełnij konfigurację danych wyjściowych usługi Stream Analytics następującymi wartościami:

   Ustawienie	Sugerowana wartość	Opis
   Alias danych wyjściowych	Wynik	Wprowadź nazwę, aby zidentyfikować wynik zlecenia.
   Zlew	Data Lake Storage Gen 2/Blob Storage	Wybierz odpowiedni ujście.
   Resource	Ręczne podawanie ustawień źródła danych	Wybierz ręczne wprowadzanie danych lub wybierz istniejące konto.
   Subscription	<Twoja subskrypcja>	Wybierz subskrypcję platformy Azure, która ma konto magazynowe danych, które utworzyłeś. Konto magazynowe może znajdować się w tej samej lub innej subskrypcji. Ten przykład zakłada, że utworzyłeś konto pamięci w tej samej subskrypcji.
   Konto magazynu	asaquickstartstorage	Wybierz lub wprowadź nazwę konta magazynu. Nazwy kont magazynowych pojawiają się automatycznie, jeśli utworzysz je w tej samej subskrypcji.
   Pojemnik	container1	Wybierz istniejący kontener utworzony na koncie magazynu.
   Wzorzec ścieżki	We/Wy	Wprowadź nazwę ścieżki pliku, aby ją utworzyć w kontenerze.

3. Pozostaw inne opcje wartości domyślne i wybierz pozycję Zapisz , aby zapisać ustawienia.

   

Definiowanie zapytania przekształcenia

Zdefiniuj zapytanie, które filtruje dane strumieniowe i przesyła wyniki do wyjścia.

1. Otwórz Script.asaql z Eksploratora rozwiązań w programie Visual Studio.

2. Dodaj następujące zapytanie:

   SELECT *
   INTO Output
   FROM Input
   WHERE Temperature > 27
   

Przesyłanie zapytania usługi Stream Analytics na platformę Azure

Złóż zapytanie do Azure, aby utworzyć zadanie Stream Analytics.

1. W Edytorze zapytań wybierz pozycję Prześlij do platformy Azure w edytorze skryptów.

2. W oknie Przesyłanie zadania wybierz pozycję Utwórz nowe zadanie usługi Azure Stream Analytics.

3. Wprowadź nazwę zadania.

4. Wybierz subskrypcję platformy Azure.

5. Wybierz grupę zasobów.

6. Zachowaj wartość domyślną klastra.

7. Wybierz lokalizację , której użyłeś na początku szybkiego startu.

8. Wybierz Prześlij.

   

Uruchamianie symulatora IoT

Uruchom symulator Raspberry Pi, aby przesłać dane z czujnika próbek do huba IoT.

1. Otwórz symulator usługi Azure IoT Online urządzenia Raspberry Pi na nowej karcie lub w nowym oknie przeglądarki.

2. Zastąp symbol zastępczy w wierszu 15 parametrami połączenia urządzenia usługi Azure IoT Hub zapisanymi w poprzedniej sekcji.

3. Wybierz Uruchom. Wynik powinien pokazywać dane z czujnika i wiadomości wysyłane do twojego huba IoT.

   

Uruchamianie zadania usługi Stream Analytics i sprawdzanie danych wyjściowych

Rozpocznij zadanie i sprawdź, czy przetwarza zdarzenia wejściowe i zapisuje wyjście do pamięci blob.

1. Gdy tworzysz swoje zadanie, widok pracy otwiera się automatycznie. Wybierz zielony przycisk strzałki, aby rozpocząć zadanie.

   

2. Zmień tryb uruchamiania danych wyjściowych zadania na JobStartTime i wybierz pozycję Uruchom.

   

3. Status zadania zmienia się na Running, a pojawiają się zdarzenia wejściowe i wyjściowe. Ta zmiana może zająć kilka minut. Wybierz przycisk Odśwież na pasku narzędzi, aby odświeżyć metryki.

   

4. Aby zobaczyć wyniki, w menu Widok wybierz Cloud Explorer i przejdź do konta pamięci w swojej grupie zasobów. W Blob Containers otwórz kontener1, a następnie ścieżkę pliku wyjściowego .

   

Uprzątnij zasoby

Gdy już ich nie potrzebujesz, usuń grupę zasobów, zadanie streamingowe i wszystkie powiązane zasoby. Usunięcie zadania powoduje zatrzymanie naliczania opłat za zużywane przez nie jednostki przesyłania strumieniowego. Jeśli planujesz używać tej pracy w przyszłości, zatrzymaj ją i zrestartuj później, gdy będziesz jej potrzebować. Jeśli nie planujesz ponownie korzystać z tego zadania, wykonaj następujące kroki, aby usunąć wszystkie zasoby stworzone przez ten szybki start:

1. Z lewego menu portalu Azure wybierz Grupy zasobów, a następnie nazwę utworzonego zasobu.
2. Na stronie grupy zasobów wybierz pozycję Usuń, wpisz nazwę zasobu do usunięcia w polu tekstowym, a następnie wybierz pozycję Usuń.

Treści powiązane

• Wyświetlanie zadań usługi Azure Stream Analytics przy użyciu programu Visual Studio
• Tworzenie zadania usługi Stream Analytics przy użyciu witryny Azure Portal
• Stwórz zadanie Stream Analytics za pomocą PowerShell