Ablakfüggvények (Azure Stream Analytics)

A valós idejű eseményeket feldolgozó alkalmazásokban gyakori, hogy bizonyos bizonyos időtartományba eső események részhalmazaion hajtanak végre valamilyen készletalapú számítást (összesítést) vagy más műveletet. Mivel az idő fogalma alapvető fontosságú az összetett eseményfeldolgozó rendszerekhez, fontos, hogy a rendszer lekérdezési logikájának időösszetevőjével egyszerű módon dolgozzunk. Az Azure Stream Analyticsben az események ezen részhalmazai az ablakokon keresztül vannak definiálva, hogy idő szerint csoportosítsa őket. Ez a cikk ismerteti az ablakokat és azok definiálásának módját, azonosítja a támogatott ablaktípusokat, és ismerteti, hogyan használhatja az ablakokat a különböző operátorokkal.

A Windows ismertetése

Az ablakok eseményadatokat tartalmaznak az idősor mentén, és lehetővé teszik különböző műveletek végrehajtását az adott ablakban lévő eseményeken. Előfordulhat például, hogy egy adott ablakban szeretné összegzni a hasznos adatmezők értékeit az alábbi ábrán látható módon.

Minden ablakművelet eseményt ad ki az ablak végén. Az Azure Stream Analytics ablakai az ablak kezdő időpontjában nyílnak meg, és az ablak végén bezáródnak. Ha például 5 perces időszaka van 12:00 és 12:05 között, az összes 12:00-nál nagyobb és 12:05-ös időbélyegzőt tartalmazó esemény ebben az ablakban jelenik meg. Az ablak kimenete egyetlen esemény lesz az ablak befejezési időpontjának megfelelő időbélyeggel használt összesítő függvény alapján. Az ablak kimeneti eseményének időbélyege a SELECT utasításban kivetíthető egy alias használatával a System.Timestamp() tulajdonság használatával. Minden ablak automatikusan a nulladik órához igazítja magát. Egy 5 perces átfedésmentes ablak például a következőhöz igazítja magát: (12:00-12:05] , (12:05-12:10], ...stb.

Egy ablakművelet után az esemény időbélyege eltér az eredeti eseményidő attribútumtól (az érkezési időtől vagy a TIMESTAMP BY oszloptól). Az események aktuális, frissített időbélyege mindig elérhető a system.timestamp() használatával.

Megjegyzés

A GROUP BY záradékban minden ablakot használni kell.

Az ablakoknak öt típusa van:

1. Átfedésmentes ablak (Azure Stream Analytics)

2. Hopping Window (Azure Stream Analytics)

3. Csúszóablak (Azure Stream Analytics)

4. Munkamenetablak (Azure Stream Analytics)

5. Pillanatkép ablak (Azure Stream Analytics)

Az ablak maximális mérete minden esetben 7 nap.

A Windows (Azure Stream Analytics) függvénnyel több idő alatt összesítheti az ablakokat ugyanabban a GROUP BY utasításban.

Lásd még:

Beépített függvények (Azure Stream Analytics)
Összesítő függvények (Azure Stream Analytics)
Elemzési függvények (Azure Stream Analytics)
Tömbfüggvények (Stream Analytics)
Konverziós függvények (Azure Stream Analytics)
Dátum- és időfüggvények (Azure Stream Analytics)
Rekordfüggvények (Azure Stream Analytics)