Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
✅ Azure Stream Analytics ✅ Fabric Eventstream
A csapódó ablakok rögzített méretű, nem átfedésben lévő és egybefüggő időintervallumok sorozatát képezik. Az alábbi ábra egy eseménysorozatot ábrázoló streamet mutat be, és azt, hogy hogyan vannak leképezve 10 másodperces bukóablakokba.
Szemantika
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
Megjegyzés:
A átfedésmentes ablak a fenti két módon használható. A hoppingablakkal való konzisztencia engedélyezéséhez az Időtartam függvény minden ablaktípussal használható az ablak méretének megadásához. Az ablak időtartamának pozitív lebegőpontos állandónak kell lennie.
Érvek
timeunit
Az ablakosítás időegysége. Az alábbi táblázat az összes érvényes időegység-argumentumot felsorolja.
| Timeunit | Rövidítések |
|---|---|
| nap | dd, d |
| óra | Hh |
| perc | mi, n |
| második | ss, s |
| Ezredmásodperc | Ms |
| mikroszekundum | Mcs |
windowsize
Egy nagy egész szám, amely az ablak méretét írja le. Az ablakosítás statikus, és futásidőben nem módosítható dinamikusan.
Az ablak maximális mérete 7 nap.
eltolás
Alapértelmezés szerint a bukóablakok az ablak végén vannak, és az elején kizárólagosak – például 12:00 és 13:00 között – az ablak pontosan 13:00-kor történt eseményeket tartalmazza, de nem tartalmazzák a 12:00-kor történt eseményeket (ezek az események 11:00 és 12:00 óra között lesznek).
Az Eltolás paraméter segítségével módosíthatja ezt a viselkedést, és belefoglalhatja az eseményeket az ablak elejébe, és kizárhatja a végén történteket.
Példák
SELECT System.Timestamp() AS WindowEnd, TollId, COUNT(*)
FROM Input TIMESTAMP BY EntryTime
GROUP BY TollId, TumblingWindow(Duration(hour, 1), Offset(millisecond, -1))
SELECT 'reset' AS command
INTO
alert
FROM
temperature TIMESTAMP BY timeCreated
GROUP BY TumblingWindow(second,15)
HAVING Avg(machine.temperature) > 25
Időelmértékek
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 ablaka van 12:00 és 12:05 között, az összes olyan esemény, amelynek időbélyege meghaladja a 12:00-t, és a 12:05-ig terjedő időbélyeg is szerepel ebben az ablakban. Az ablak kimenete egyetlen esemény lesz az összesítő függvény alapján, amely az ablak befejezési időpontjának megfelelő időbélyeggel rendelkezik. Az ablak kimeneti eseményének időbélyege a SELECT utasításban kivetíthető a System.Timestamp() tulajdonság használatával alias használatával.