Przesyłanie strumieniowe danych w usłudze Azure SQL Edge
Ważne
Usługa Azure SQL Edge zostanie wycofana 30 września 2025 r. Aby uzyskać więcej informacji i opcji migracji, zobacz powiadomienie o wycofaniu.
Uwaga
Usługa Azure SQL Edge nie obsługuje już platformy ARM64.
Usługa Azure SQL Edge udostępnia natywną implementację funkcji przesyłania strumieniowego danych o nazwie Przesyłanie strumieniowe języka Transact-SQL (T-SQL). Zapewnia ona przesyłanie strumieniowe danych w czasie rzeczywistym, analizę i przetwarzanie zdarzeń w celu analizowania i przetwarzania dużych ilości danych szybkiego przesyłania strumieniowego z wielu źródeł jednocześnie. Przesyłanie strumieniowe T-SQL jest tworzone przy użyciu tego samego aparatu przesyłania strumieniowego o wysokiej wydajności, który obsługuje usługę Azure Stream Analytics na platformie Microsoft Azure. Funkcja obsługuje podobny zestaw funkcji oferowanych przez usługę Azure Stream Analytics działających na urządzeniach brzegowych.
Podobnie jak w przypadku usługi Stream Analytics przesyłanie strumieniowe T-SQL rozpoznaje wzorce i relacje w informacjach wyodrębnionych z kilku źródeł wejściowych IoT, w tym urządzeń, czujników i aplikacji. Te wzorce umożliwiają wyzwalanie akcji i inicjowanie przepływów pracy. Można na przykład utworzyć alerty, podawać informacje do rozwiązania do raportowania lub wizualizacji albo przechowywać dane do późniejszego użycia.
Przesyłanie strumieniowe T-SQL może pomóc:
- Analizowanie strumieni danych telemetrycznych w czasie rzeczywistym z urządzeń IoT.
- Korzystaj z analizy danych generowanych w czasie rzeczywistym z pojazdów autonomicznych i bez kierowcy.
- Używaj zdalnego monitorowania i konserwacji predykcyjnej zasobów przemysłowych lub produkcyjnych o wysokiej wartości.
- Używaj wykrywania anomalii i rozpoznawania wzorców odczytów czujników IoT w rolnictwie lub farmie energetycznej.
Jak działa przesyłanie strumieniowe T-SQL?
Przesyłanie strumieniowe T-SQL działa dokładnie w taki sam sposób jak usługa Azure Stream Analytics. Na przykład używa koncepcji zadań przesyłania strumieniowego do przetwarzania przesyłania strumieniowego danych przesyłanych strumieniowo w czasie rzeczywistym.
Zadanie usługi Stream Analytics składa się z następujących elementów:
Dane wejściowe strumienia: definiuje połączenia ze źródłem danych w celu odczytu strumienia danych. Usługa Azure SQL Edge obecnie obsługuje następujące typy danych wejściowych strumienia:
- Koncentrator brzegowy
- Kafka (Obsługa danych wejściowych platformy Kafka jest obecnie dostępna tylko w wersjach intel/AMD64 usługi Azure SQL Edge).
Dane wyjściowe strumienia: definiuje połączenia ze źródłem danych w celu zapisania strumienia danych. Usługa Azure SQL Edge obecnie obsługuje następujące typy danych wyjściowych strumienia
- Koncentrator brzegowy
- SQL (Dane wyjściowe SQL mogą być lokalną bazą danych w wystąpieniu usługi Azure SQL Edge lub zdalnym programem SQL Server lub usługą Azure SQL Database).
Zapytanie strumienia: definiuje przekształcenia, agregacje, filtrowanie, sortowanie i sprzężenia, które mają być stosowane do strumienia wejściowego, zanim zostaną zapisane w danych wyjściowych strumienia. Zapytanie strumienia jest oparte na tym samym języku zapytań, co używany przez usługę Stream Analytics. Aby uzyskać więcej informacji, zobacz Język zapytań usługi Stream Analytics.
Ważne
Przesyłanie strumieniowe T-SQL, w przeciwieństwie do usługi Stream Analytics, nie obsługuje obecnie używania danych referencyjnych do wyszukiwania ani używania funkcji UDF i UDA w zadaniu strumienia.
Uwaga
Przesyłanie strumieniowe T-SQL obsługuje tylko podzbiór obszaru powierzchni języka obsługiwanego przez usługę Stream Analytics. Aby uzyskać więcej informacji, zobacz Język zapytań usługi Stream Analytics.
Ograniczenia
Następujące ograniczenia i ograniczenia dotyczą przesyłania strumieniowego T-SQL.
- Tylko jedno zadanie przesyłania strumieniowego może być aktywne w dowolnym momencie. Zadania, które są już uruchomione, muszą zostać zatrzymane przed uruchomieniem innego zadania.
- Każde wykonanie zadania przesyłania strumieniowego jest jednowątkowe. Jeśli zadanie przesyłania strumieniowego zawiera wiele zapytań, każde zapytanie jest oceniane w kolejności szeregowej.
- Po zatrzymaniu zadania przesyłania strumieniowego w usłudze Azure SQL Edge może wystąpić pewne opóźnienie, zanim będzie można uruchomić następne zadanie przesyłania strumieniowego. To opóźnienie jest wprowadzane, ponieważ podstawowy proces przesyłania strumieniowego musi zostać zatrzymany w odpowiedzi na żądanie zatrzymania zadania, a następnie ponownie uruchomiony w odpowiedzi na żądanie uruchomienia zadania.
- Przesyłanie strumieniowe T-SQL do 32 partycji dla strumienia kafka. Próby skonfigurowania wyższej liczby partycji powoduje wystąpienie błędu.