Funkce vytváření oken (Azure Stream Analytics)
V aplikacích, které zpracovávají události v reálném čase, je běžné provádět určité výpočty na základě sady (agregace) nebo jiné operace s podmnožinou událostí, které spadají do určitého časového období. Vzhledem k tomu, že koncept času je základní nutností složitých systémů zpracování událostí, je důležité mít v systému jednoduchý způsob práce s časovou komponentou logiky dotazu. V Azure Stream Analytics jsou tyto podmnožina událostí definovány prostřednictvím oken, které představují seskupení podle času. Tento článek popisuje okna a způsob 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 daném 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írají se v čase ukončení okna. Pokud máte například 5minutové okno od 0:00 do 12:05, budou v tomto okně zahrnuty všechny události s časovým razítkem větším než 0:00 a časovým razítkem 12:05 včetně. Výstupem okna bude jedna událost založená na agregační funkci použité s časovým razítkem odpovídajícím koncovému času okna. Časové razítko výstupní události okna lze promítnou v příkazu SELECT pomocí vlastnosti System.Timestamp() pomocí aliasu. Každé okno se automaticky zarovná na nulu. 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 funkcí 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:
Maximální velikost okna je ve všech případech 7 dní.
Pomocí funkce Windows (Azure Stream Analytics) můžete agregovat více časových intervalů ve stejném příkazu GROUP BY.
Viz také
Integrované funkce (Azure Stream Analytics)
Aggregate Functions (Azure Stream Analytics)
Analytické funkce (Azure Stream Analytics)
Funkce pole (Stream Analytics)
Conversion Functions (Azure Stream Analytics)
Funkce data a času (Azure Stream Analytics)
Record Functions (Azure Stream Analytics)