Funkcje obsługi okien (Azure Stream Analytics)

  • Artykuł

W aplikacjach, które przetwarzają zdarzenia w czasie rzeczywistym, często wykonuje się pewne obliczenia oparte na zestawie (agregacja) lub inne operacje na podzestawach zdarzeń, które mieszczą się w pewnym czasie. Ponieważ koncepcja czasu jest podstawową koniecznością dla złożonych systemów przetwarzania zdarzeń, ważne jest, aby mieć prosty sposób pracy ze składnikiem czasu logiki zapytań w systemie. W usłudze Azure Stream Analytics te podzestawy zdarzeń są definiowane za pośrednictwem okien do reprezentowania grupowania według czasu. W tym artykule opisano okna i sposób ich definiowania, identyfikuje obsługiwane typy okien oraz wyjaśniono, jak można używać okien z różnymi operatorami.

Informacje o systemie Windows

Okno zawiera dane zdarzeń wzdłuż osi czasu i umożliwia wykonywanie różnych operacji na zdarzeniach w tym oknie. Na przykład możesz zsumować wartości pól ładunku w danym oknie, jak pokazano na poniższej ilustracji.

Okno wirowania języka zapytań usługi Stream Analytics

Każda operacja okna generuje zdarzenie na końcu okna. Okna usługi Azure Stream Analytics są otwierane w czasie rozpoczęcia okna i zamykane w czasie zakończenia okna. Jeśli na przykład masz 5-minutowe okno od 12:00 do 12:05, wszystkie zdarzenia ze znacznikiem czasu większym niż 12:00 i znacznik czasu 12:05 włącznie będą uwzględniane w tym oknie. Dane wyjściowe okna będą pojedynczym zdarzeniem opartym na funkcji agregującej używanej z sygnaturą czasową równą godzinie zakończenia okna. Sygnatura czasowa zdarzenia wyjściowego okna może być rzutowana w instrukcji SELECT przy użyciu właściwości System.Timestamp() przy użyciu aliasu. Każde okno automatycznie wyrównuje się do godziny zeroth. Na przykład 5-minutowe okno wirowania będzie wyrównywać się do siebie (12:00-12:05] , (12:05-12:10], ...itd.

Po operacji okna sygnatura czasowa zdarzenia różni się od oryginalnego atrybutu czasu zdarzenia ( czasu przybycia lub kolumny używanej z sygnaturą CZASOWĄ WEDŁUG). Bieżący, zaktualizowany znacznik czasu zdarzenia zawsze może być dostępny za pomocą elementu system.timestamp().

Uwaga

Wszystkie okna powinny być używane w klauzuli GROUP BY.

Istnieje pięć typów okien:

  1. Okno wirowania (Azure Stream Analytics)

  2. Okno przeskoku (Azure Stream Analytics)

  3. Okno przewijania (Azure Stream Analytics)

  4. Okno sesji (Azure Stream Analytics)

  5. Okno migawki (Azure Stream Analytics)

Maksymalny rozmiar okna we wszystkich przypadkach wynosi 7 dni.

Można agregować w wielu oknach czasu w tej samej instrukcji GROUP BY przy użyciu funkcji Systemu Windows (Azure Stream Analytics).

Zobacz też

Wbudowane funkcje (Azure Stream Analytics)
Funkcje agregujące (Azure Stream Analytics)
Funkcje analityczne (Azure Stream Analytics)
Funkcje tablicy (Stream Analytics)
Funkcje konwersji (Azure Stream Analytics)
Funkcje daty i godziny (Azure Stream Analytics)
Funkcje rekordów (Azure Stream Analytics)