Omówienie lokalnego testowania zadań usługi Stream Analytics w Visual Studio Code za pomocą narzędzi ASA

  • Artykuł

Aby przetestować zadania usługi Stream Analytics lokalnie, można użyć narzędzi usługi Azure Stream Analytics (ASA Tools) dla Visual Studio Code. Mówiąc o lokalności, należy wziąć pod uwagę trzy aspekty: kontekst wykonywania zadania (komputer lokalny lub usługa w chmurze platformy Azure), źródła wejściowe i ujścia danych wyjściowych.

W środowisku lokalnym zapytanie jest wykonywane na komputerze lokalnym. W przypadku danych wejściowych dane mogą być pozyskiwane z plików lokalnych lub źródeł na żywo. Wyniki wyjściowe są wysyłane jako pliki do folderu lokalnego lub ujścia na żywo.

Zagadnienia dotyczące danych wejściowych dla przebiegów lokalnych

W programie VS Code można zdefiniować dane wejściowe na żywo i lokalne:

  • Dane wejściowe na żywo to pliki konfiguracji wskazujące wystąpienie obsługiwanych danych wejściowych (strumień i dane referencyjne). Oferują one również podgląd i przykładowe dane do plików JSON.
  • Lokalne dane wejściowe to pliki konfiguracji wskazujące plik lokalny obsługiwanego formatu (JSON/CSV/AVRO). Te pliki mogą być próbkowane z danych wejściowych na żywo lub generowane w inny sposób.

Podczas tworzenia lokalnych danych wejściowych można je dopasować do istniejących danych wejściowych na żywo. W takim przypadku wyśmiewa dane wejściowe na żywo podczas uruchamiania lokalnych danych wejściowych. Jego plik konfiguracji zostanie nazwany po danych wejściowych na żywo, poprzedzony prefiksem Local_. Plik danych używany przez te lokalne dane wejściowe nie powinien być zgodna z formatem formatu i serializacji zdefiniowanym w danych wejściowych na żywo. Ich formaty są niezależne.

Zagadnienia dotyczące danych wyjściowych dla przebiegów lokalnych

Podczas uruchamiania zadania do lokalnych danych wyjściowych wyniki wyjściowe są wysyłane do folderu w projekcie o nazwie LocalRunOutputs. W tym trybie dane wyjściowe nie muszą być zdefiniowane. Jedynym ograniczeniem jest to, że każda INTO instrukcja w zapytaniu wskazuje unikatową nazwę danych wyjściowych. Po uruchomieniu do lokalnych danych wyjściowych zostanie utworzony plik JSON dla każdej unikatowej nazwy wyjściowej.

Tryby uruchamiania lokalnego

Istnieją trzy tryby obsługiwane przez narzędzia ASA w programie VS Code do uruchamiania zadań lokalnie:

  • Uruchamianie lokalne z lokalnymi danymi wejściowymi i lokalnymi danymi wyjściowymi: najlepsze rozwiązanie do tworzenia w trybie offline bez ponoszenia kosztów, testowanie jednostkowe przy użyciu pakietu npm...
  • Uruchamianie lokalne z danymi wejściowymi na żywo i lokalnymi danymi wyjściowymi: najlepsze w przypadku konfiguracji danych wejściowych, deseralizacji i debugowania partycjonowania...
  • Lokalne uruchamianie z danymi wejściowymi na żywo i danymi wyjściowymi na żywo: najlepsze w przypadku konfiguracji danych wyjściowych, serializacji i debugowania błędów konwersji...

Każdy tryb obsługuje inną konfigurację danych wejściowych i wyjściowych:

Wykonanie Tryb Dane wejściowe Dane wyjściowe
VS Code Lokalne dane wejściowe do danych wyjściowych lokalnych Pliki JSON/CSV/AVRO Pliki JSON (odpowiedni format danych wyjściowych na żywo nie jest używany nawet wtedy, gdy istnieje)
VS Code Dane wejściowe na żywo do lokalnych danych wyjściowych Wszystkie karty wejściowe Pliki JSON (odpowiedni format danych wyjściowych na żywo nie jest używany nawet wtedy, gdy istnieje)
VS Code Dane wejściowe na żywo do danych wyjściowych na żywo Wszystkie karty wejściowe Centrum zdarzeń, konto magazynu, Azure SQL
Azure Nie dotyczy Wszystkie karty wejściowe Wszystkie karty wyjściowe

W przypadku uruchamiania zadań lokalnie nie są naliczane żadne koszty z usługi Azure Stream Analytics. Nie jest konieczne utworzenie zasobu usługi Stream Analytics na platformie Azure.

Wprowadzenie

Skorzystaj z tego przewodnika Szybki start, aby dowiedzieć się, jak utworzyć zadanie usługi Stream Analytics przy użyciu narzędzi Visual Studio Code i ASA.

Następnie, aby zapoznać się z samouczkami krok po kroku dotyczącymi przebiegów lokalnych, zobacz:

Następne kroki