Poziom zgodności zadań usługi Azure Stream Analytics
W tym artykule opisano opcję poziomu zgodności w usłudze Azure Stream Analytics.
Stream Analytics to usługa zarządzana z regularnymi aktualizacjami funkcji i stałymi ulepszeniami wydajności. Większość aktualizacji środowiska uruchomieniowego usługi jest automatycznie udostępniana użytkownikom końcowym niezależnie od poziomu zgodności. Jednak gdy nowa funkcja wprowadza zmianę zachowania istniejących zadań lub zmianę sposobu, w jaki dane są używane w uruchomionych zadaniach, wprowadzamy tę zmianę na nowym poziomie zgodności. Istniejące zadania usługi Stream Analytics można zachować bez istotnych zmian, pozostawiając ustawienie poziomu zgodności niższe. Gdy wszystko będzie gotowe do najnowszych zachowań środowiska uruchomieniowego, możesz wyrazić zgodę, podnosząc poziom zgodności.
Wybieranie poziomu zgodności
Poziom zgodności kontroluje zachowanie środowiska uruchomieniowego zadania usługi Stream Analytics.
Usługa Azure Stream Analytics obecnie obsługuje trzy poziomy zgodności:
- 1.2 — najnowsze zachowanie z najnowszymi ulepszeniami
- 1.1 — Poprzednie zachowanie
- 1.0 — Oryginalny poziom zgodności wprowadzony w czasie ogólnej dostępności usługi Azure Stream Analytics kilka lat temu.
Podczas tworzenia nowego zadania usługi Stream Analytics najlepszym rozwiązaniem jest utworzenie go przy użyciu najnowszego poziomu zgodności. Rozpocznij projekt zadania, opierając się na najnowszych zachowaniach, aby uniknąć dodatkowej zmiany i złożoności później.
Ustawianie poziomu zgodności
Poziom zgodności zadania usługi Stream Analytics można ustawić w witrynie Azure Portal lub za pomocą wywołania interfejsu API REST tworzenia zadania.
Aby zaktualizować poziom zgodności zadania w witrynie Azure Portal:
- Użyj witryny Azure Portal , aby zlokalizować zadanie usługi Stream Analytics.
- Zatrzymaj zadanie przed zaktualizowaniem poziomu zgodności. Nie można zaktualizować poziomu zgodności, jeśli zadanie jest w stanie uruchomienia.
- W obszarze Konfigurowanie nagłówka wybierz pozycję Poziom zgodności.
- Wybierz odpowiednią wartość poziomu zgodności.
- Wybierz pozycję Zapisz w dolnej części strony.
Po zaktualizowaniu poziomu zgodności kompilator T weryfikuje zadanie przy użyciu składni odpowiadającej wybranemu poziomowi zgodności.
Poziom zgodności 1.2
Następujące istotne zmiany są wprowadzane na poziomie zgodności 1.2:
Protokół obsługi komunikatów protokołu AMQP
1.2 poziom: Usługa Azure Stream Analytics używa protokołu obsługi komunikatów advanced Message Queueing Protocol (AMQP) do zapisywania w kolejkach i tematach usługi Service Bus. Protokół AMQP umożliwia tworzenie międzyplatformowych aplikacji hybrydowych przy użyciu otwartego standardowego protokołu.
Funkcje geoprzestrzenne
Poprzednie poziomy: Usługa Azure Stream Analytics użyła obliczeń geografii.
1.2 poziom: Usługa Azure Stream Analytics umożliwia obliczanie rzutowanych współrzędnych geograficznych geometrycznych. Nie ma żadnych zmian w podpisie funkcji geoprzestrzennych. Jednak ich semantyka jest nieco inna, umożliwiając dokładniejsze obliczanie niż wcześniej.
Usługa Azure Stream Analytics obsługuje indeksowanie danych referencyjnych geoprzestrzennych. Dane referencyjne zawierające elementy geoprzestrzenne można indeksować w celu szybszego obliczania sprzężenia.
Zaktualizowane funkcje geoprzestrzenne przynoszą pełną wyrazistość formatu geoprzestrzennego dobrze znanego tekstu (WKT). Możesz określić inne składniki geoprzestrzenne, które nie były wcześniej obsługiwane w formacie GeoJson.
Aby uzyskać więcej informacji, zobacz Aktualizacje funkcji geoprzestrzennych w usłudze Azure Stream Analytics — Cloud i IoT Edge.
Równoległe wykonywanie zapytań dla źródeł wejściowych z wieloma partycjami
Poprzednie poziomy: zapytania usługi Azure Stream Analytics wymagały użycia klauzuli PARTITION BY w celu równoległego przetwarzania zapytań między partycjami źródłowymi danych wejściowych.
1.2 poziom: Jeśli logika zapytań może być równoległa w partycjach źródłowych danych wejściowych, usługa Azure Stream Analytics tworzy oddzielne wystąpienia zapytań i uruchamia obliczenia równolegle.
Natywna integracja interfejsu API zbiorczego z danymi wyjściowymi usługi Azure Cosmos DB
Poprzednie poziomy: zachowanie operacji upsert zostało wstawione lub scalane.
1.2 poziom: Natywna integracja interfejsu API zbiorczego z danymi wyjściowymi usługi Azure Cosmos DB maksymalizuje przepływność i efektywnie obsługuje żądania ograniczania przepustowości. Aby uzyskać więcej informacji, zobacz stronę Danych wyjściowych usługi Azure Stream Analytics do usługi Azure Cosmos DB.
Zachowanie operacji upsert jest wstawiane lub zamieniane.
DateTimeOffset podczas zapisywania w danych wyjściowych SQL
Poprzednie poziomy: typy DateTimeOffset zostały dostosowane do czasu UTC.
1.2 poziom: Ustawienie DateTimeOffset nie jest już dostosowywane.
Długi czas zapisywania w danych wyjściowych SQL
Poprzednie poziomy: Wartości zostały obcięte na podstawie typu docelowego.
1.2 poziom: Wartości, które nie mieszczą się w typie docelowym, są obsługiwane zgodnie z zasadami błędów wyjściowych.
Serializacja rekordów i tablic podczas zapisywania w danych wyjściowych SQL
Poprzednie poziomy: Rekordy zostały zapisane jako "Rekord", a tablice zostały zapisane jako "Array".
1.2 poziom: Rekordy i tablice są serializowane w formacie JSON.
Ścisła walidacja prefiksu funkcji
Poprzednie poziomy: Nie było ścisłej walidacji prefiksów funkcji.
1.2 poziom: Usługa Azure Stream Analytics ma ścisłą walidację prefiksów funkcji. Dodanie prefiksu do wbudowanej funkcji powoduje błąd. Na przykład nie jest obsługiwany element myprefix.ABS(…).
Dodanie prefiksu do wbudowanych agregacji powoduje również błąd. Na przykład nie jest obsługiwany element myprefix.SUM(…).
Użycie prefiksu "system" dla wszystkich funkcji zdefiniowanych przez użytkownika powoduje błąd.
Nie zezwalaj tablicy i obiektu na właściwości klucza w karcie wyjściowej usługi Azure Cosmos DB
Poprzednie poziomy: Typy tablic i obiektów były obsługiwane jako właściwość klucza.
1.2 poziom: Typy tablic i obiektów nie są już obsługiwane jako właściwość klucza.
Deserializowanie typu logicznego w formatach JSON, AVRO i PARQUET
Poprzednie poziomy: Deserializuje wartość logiczną usługi Azure Stream Analytics do typu BIGINT — wartości false są mapami na wartość 0 i true na 1. Dane wyjściowe tworzą tylko wartości logiczne w formatach JSON, AVRO i PARQUET, jeśli jawnie konwertujesz zdarzenia na BIT.
Na przykład zapytanie przekazywane, takie jak SELECT value INTO output1 FROM input1 odczytywanie kodu JSON { "value": true } z danych wejściowych Input1, spowoduje zapisanie w danych wyjściowych1 wartości { "value": 1 }JSON.
1.2 poziom: Deserializuje wartość logiczną usługi Azure Stream Analytics do typu BIT. Fałsz mapuje na 0 i true mapuje na 1. Zapytanie przekazywane, takie jak SELECT value INTO output1 FROM input1 odczytywanie kodu JSON { "value": true } z danych wejściowych Input1, spowoduje zapisanie w danych wyjściowych1 wartości { "value": true }JSON. Możesz rzutować wartość, aby wpisać BIT w zapytaniu, aby upewnić się, że są one wyświetlane jako prawda i fałsz w danych wyjściowych dla formatów obsługujących typ logiczny.
Poziom zgodności 1.1
Następujące istotne zmiany są wprowadzane na poziomie zgodności 1.1:
Format XML usługi Service Bus
Poziom 1.0: usługa Azure Stream Analytics używała elementu DataContractSerializer, więc zawartość komunikatu zawierała tagi XML. Na przykład:
@\u0006string\b3http://schemas.microsoft.com/2003/10/Serialization/\u0001{ "SensorId":"1", "Temperature":64\}\u0001
1.1 poziom: zawartość wiadomości zawiera strumień bezpośrednio bez dodatkowych tagów. Na przykład: { "SensorId":"1", "Temperature":64}.
Utrwalanie poufności wielkości liter dla nazw pól
Poziom 1.0: Nazwy pól zostały zmienione na małe litery podczas przetwarzania przez aparat usługi Azure Stream Analytics.
1.1 poziom: ważność wielkości liter jest utrwalana dla nazw pól podczas ich przetwarzania przez aparat usługi Azure Stream Analytics.
Uwaga
Trwałość wielkości liter nie jest jeszcze dostępna dla zadań analitycznych usługi Stream hostowanych przy użyciu środowiska usługi Edge. W związku z tym wszystkie nazwy pól są konwertowane na małe litery, jeśli zadanie jest hostowane w przeglądarce Edge.
FloatNaNDeserializationDisabled
1.0 poziom: polecenie CREATE TABLE nie filtruje zdarzeń za pomocą wartości NaN (not-a-Number). Na przykład Infinity, -Infinity) w typie kolumny FLOAT, ponieważ są one poza udokumentowanym zakresem dla tych liczb.
1.1 poziom: FUNKCJA CREATE TABLE umożliwia określenie silnego schematu. Aparat usługi Stream Analytics sprawdza, czy dane są zgodne z tym schematem. Za pomocą tego modelu polecenie może filtrować zdarzenia za pomocą wartości NaN.
Wyłącz automatyczną konwersję ciągów daty/godziny na typ DateTime w ruchu przychodzącym dla formatu JSON
Poziom 1.0: Analizator JSON automatycznie konwertuje wartości ciągów z informacjami o dacie/godziny/strefie na typ DATETIME w ruchu przychodzącym, dzięki czemu wartość natychmiast traci oryginalne formatowanie i informacje o strefie czasowej. Ponieważ odbywa się to w przypadku ruchu przychodzącego, nawet jeśli to pole nie zostało użyte w zapytaniu, jest konwertowane na czas UTC DateTime.
1.1 poziom: Nie ma automatycznej konwersji wartości ciągu z informacjami o dacie/godzinie/strefie do typu DATETIME. W związku z tym informacje o strefie czasowej i oryginalne formatowanie są przechowywane. Jeśli jednak pole NVARCHAR(MAX) jest używane w zapytaniu w ramach wyrażenia DATETIME (na przykład funkcji DATEADD), jest konwertowane na typ DATETIME w celu wykonania obliczeń i traci oryginalny formularz.