Vensterfuncties

✅ Azure Stream Analytics ✅ Fabric Eventstream

In toepassingen die realtimegebeurtenissen verwerken, is het gebruikelijk om bepaalde op set gebaseerde berekeningen (aggregatie) of andere bewerkingen uit te voeren voor subsets van gebeurtenissen die binnen een bepaalde periode vallen. Omdat het concept van tijd een fundamentele noodzaak is voor complexe gebeurtenisverwerkingssystemen, is het belangrijk om een eenvoudige manier te hebben om te werken met het tijdonderdeel van querylogica in het systeem. In Azure Stream Analytics worden deze subsets van gebeurtenissen gedefinieerd via Windows om groeperingen op tijd weer te geven. In dit artikel worden vensters beschreven en hoe deze worden gedefinieerd, worden de typen vensters geïdentificeerd die worden ondersteund en wordt uitgelegd hoe u vensters met verschillende operators kunt gebruiken.

Informatie over Windows

Een venster bevat gebeurtenisgegevens langs een tijdlijn en stelt u in staat om verschillende bewerkingen uit te voeren op de gebeurtenissen in dat venster. U kunt bijvoorbeeld de waarden van nettoladingvelden in een bepaald venster optellen, zoals wordt weergegeven in de volgende afbeelding.

Elke vensterbewerking voert een gebeurtenis uit aan het einde van het venster. De vensters van Azure Stream Analytics worden geopend op de begintijd van het venster en gesloten op de eindtijd van het venster. Als u bijvoorbeeld een periode van 5 minuten hebt van 12:00 tot 12:05 uur, worden alle gebeurtenissen met een tijdstempel groter dan 12:00 uur en tot tijdstempel 12:05 uur opgenomen in dit venster. De uitvoer van het venster is één gebeurtenis op basis van de statistische functie die wordt gebruikt met een tijdstempel die gelijk is aan de eindtijd van het venster. De tijdstempel van de uitvoergebeurtenis van het venster kan worden geprojecteerd in de SELECT-instructie met behulp van de eigenschap System.Timestamp() met behulp van een alias. Elk venster wordt automatisch uitgelijnd op het nuluur. Een tumblingvenster van 5 minuten wordt bijvoorbeeld uitgelijnd op (12:00-12:05] , (12:05-12:10], ..., enzovoort.

Na een vensterbewerking wijkt de tijdstempel van een gebeurtenis af van het oorspronkelijke kenmerk gebeurtenistijd (ofwel de aankomsttijd of de kolom die wordt gebruikt met TIMESTAMP BY). De huidige, bijgewerkte tijdstempel van een gebeurtenis kan altijd worden geopend met system.timestamp().

Er zijn vijf typen vensters:

1. Tumblingvenster

2. Hopping-venster

3. Schuifvenster

4. Sessievenster

5. Momentopnamevenster

De maximale grootte van het venster in alle gevallen is 7 dagen.

U kunt meerdere tijdvensters samenvoegen in dezelfde GROUP BY-instructie met behulp van de Windows-functie .

Zie ook

ingebouwde functies
statistische functies
Analytische functies
Matrixfuncties (Stream Analytics)
Conversiefuncties
datum- en tijdfuncties
Recordfuncties