Udostępnij przez


Omówienie danych wejściowych dla usługi Azure Stream Analytics

Zadania usługi Azure Stream Analytics łączą się z co najmniej jednym wejściem danych. Każde dane wejściowe definiuje połączenie z istniejącym źródłem danych. Usługa Stream Analytics akceptuje dane przychodzące z kilku rodzajów źródeł zdarzeń, w tym Event Hubs, IoT Hub i Blob Storage. Dane wejściowe są odwoływane za pomocą nazwy w zapytaniu przesyłającym strumieniowo SQL, które piszesz dla każdego zadania. W zapytaniu możesz łączyć wiele danych wejściowych, w celu połączenia danych lub porównania danych przesyłanych strumieniowo z danymi referencyjnymi, i przekazać wyniki do wyjść.

Usługa Stream Analytics oferuje pierwszą klasę integracji z czterema rodzajami zasobów jako danymi wejściowymi:

Te zasoby wejściowe mogą znajdować się w tej samej subskrypcji platformy Azure co zadanie usługi Stream Analytics, albo mogą pochodzić z innej subskrypcji.

Za pomocą witryny Azure Portal, programu Azure PowerShell, interfejsu API .NET, interfejsu API REST, programu Visual Studio i programu Visual Studio Code można tworzyć, edytować i testować dane wejściowe zadań usługi Stream Analytics.

Uwaga / Notatka

Zdecydowanie zalecamy używanie narzędzi Stream Analytics dla programu Visual Studio Code w celu uzyskania najlepszego lokalnego środowiska programistycznego. Istnieją znane luki w funkcjach w narzędziach usługi Stream Analytics dla programu Visual Studio 2019 (wersja 2.6.3000.0) i nie będzie ona ulepszana w przyszłości.

Wejścia strumieniowe i referencyjne

Kiedy dane są przesyłane do źródła danych, są przetwarzane przez zadanie Stream Analytics i przetwarzane w czasie rzeczywistym. Dane wejściowe są podzielone na dwa typy:

  • Dane wejściowe strumienia danych
  • Dane referencyjne wejściowe.

Dane wejściowe strumienia danych

Strumień danych to niezwiązana sekwencja zdarzeń w czasie. Zadania usługi Stream Analytics muszą zawierać co najmniej jeden strumień danych jako wejście. Usługi Event Hubs, IoT Hub, Azure Data Lake Storage Gen2 i Blob storage są obsługiwane jako źródła strumieniowego wprowadzania danych. Usługa Event Hubs służy do zbierania strumieni zdarzeń z wielu urządzeń i usług. Strumienie te mogą obejmować kanały aktywności mediów społecznościowych, informacje o handlu akcjami lub dane z czujników. Usługi IoT Hubs są zoptymalizowane pod kątem zbierania danych z połączonych urządzeń w scenariuszach Internetu rzeczy (IoT). Magazyn Blob może być używany jako źródło danych wejściowych do strumieniowego pozyskiwania danych zbiorczych, takich jak pliki dziennika.

Aby uzyskać więcej informacji na temat danych wejściowych przesyłanych strumieniowo, zobacz Przesyłanie strumieniowe danych jako dane wejściowe do usługi Stream Analytics.

Dane wejściowe referencyjne

Usługa Stream Analytics obsługuje również dane wejściowe znane jako dane referencyjne. Dane referencyjne są całkowicie statyczne lub zmieniają się powoli. Zwykle służy do wykonywania korelacji i wyszukiwania. Możesz na przykład połączyć dane ze strumienia danych z danymi referencyjnymi, podobnie jak łączenie SQL w celu wyszukania statycznych wartości. Usługi Azure Blob Storage, Azure Data Lake Storage Gen2 i Azure SQL Database są obecnie obsługiwane jako źródła danych wejściowych dla danych referencyjnych. Dane referencyjne obiektów blob źródłowych mają limit do 300 MB, w zależności od złożoności zapytania i przydzielonych jednostek strumieniowych. Aby uzyskać więcej informacji, zobacz sekcję Ograniczenia rozmiaru w dokumentacji danych referencyjnych.

Aby uzyskać więcej informacji na temat referencyjnych danych wejściowych, zobacz Using reference data for lookups in Stream Analytics (Używanie danych referencyjnych do wyszukiwania w usłudze Stream Analytics).

Dalsze kroki