Funkce pro práci s okny

✅Eventstream prostředků infrastruktury Azure Stream Analytics ✅

V aplikacích, které zpracovávají události v reálném čase, je běžné provádět některé výpočty založené na sadě (agregace) nebo jiné operace nad podmnožinami událostí, které spadají do určitého časového období. Vzhledem k tomu, že koncept času je zásadní nutností složitých systémů zpracování událostí, je důležité mít jednoduchý způsob, jak pracovat s časovou komponentou logiky dotazů v systému. V Azure Stream Analytics jsou tyto podmnožina událostí definovány prostřednictvím oken, aby představovaly seskupení podle času. Tento článek popisuje okna a jejich definování, identifikuje podporované typy oken a vysvětluje, jak můžete okna používat s různými operátory.

Principy Windows

Okno obsahuje data událostí na časové ose a umožňuje provádět různé operace s událostmi v tomto okně. Můžete například chtít sečíst hodnoty polí datové části v daném okně, jak je znázorněno na následujícím obrázku.

Každá operace okna vypíše událost na konci okna. Okna Služby Azure Stream Analytics se otevřou v počátečním čase okna a zavře se v době ukončení okna. Pokud máte například 5minutové okno od 12:00 do 12:05 do 12:05 a všechny události s časovým razítkem delším než 12:00 a až do časového razítka 12:05 včetně budou zahrnuty v tomto okně. Výstupem okna bude jedna událost založená na agregační funkci použité s časovým razítkem, které se rovná koncovému času okna. Časové razítko výstupní události okna lze projektovat v příkazu SELECT pomocí vlastnosti System.Timestamp() pomocí aliasu. Každé okno se automaticky zarovná k nule. Například 5minutové přeskakující okno se zarovná do (12:00-12:05] , (12:05-12:10], ...atd.

Po operaci okna se časové razítko události bude lišit od původního atributu času události ( buď čas příjezdu , nebo sloupec použitý s TIMESTAMP BY). Aktuální aktualizované časové razítko události je vždy přístupné pomocí system.timestamp().

Poznámka:

Všechna okna by měla být použita v klauzuli GROUP BY.

Existuje pět typů oken:

1. Přeskakující okno

2. Skákání okna

3. Posuvné okno

4. Okno relace

5. Okno snímku

Maximální velikost okna je ve všech případech 7 dní.

Pomocí funkce Windows můžete agregovat více časových oken ve stejném příkazu GROUP BY.

Viz také

předdefinované funkce
Agregační funkce
analytické funkce
Array Functions (Stream Analytics)
Funkce převodu
Funkce Datum a Čas
Funkce záznamu