Vensterfuncties (Azure Stream Analytics)

  • Artikel

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 tijd een fundamentele noodzaak is voor complexe gebeurtenisverwerkingssystemen, is het belangrijk om een eenvoudige manier te hebben om te werken met de tijdcomponent van querylogica in het systeem. In Azure Stream Analytics worden deze subsets van gebeurtenissen gedefinieerd via vensters om groeperingen op tijd weer te geven. In dit artikel worden vensters beschreven en hoe deze worden gedefinieerd, worden de typen vensters beschreven 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.

Tumblingvenster van Stream Analytics-querytaal

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 tijdsvenster van 5 minuten hebt van 00:00 tot 12:05 uur, worden alle gebeurtenissen met een tijdstempel groter dan 12:00 uur en tot en met tijdstempel 12:05 in dit venster opgenomen. 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 nulste uur. 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 gebeurtenistijdkenmerk (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().

Notitie

Alle vensters moeten worden gebruikt in een GROUP BY-component.

Er zijn vijf typen vensters:

  1. Tumblingvenster (Azure Stream Analytics)

  2. Hopping Window (Azure Stream Analytics)

  3. Sliding Window (Azure Stream Analytics)

  4. Sessievenster (Azure Stream Analytics)

  5. Momentopnamevenster (Azure Stream Analytics)

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

U kunt over meerdere tijdvensters in dezelfde GROUP BY-instructie aggregeren met behulp van de functie Windows (Azure Stream Analytics).

Zie ook

Ingebouwde functies (Azure Stream Analytics)
Statistische functies (Azure Stream Analytics)
Analytische functies (Azure Stream Analytics)
Matrixfuncties (Stream Analytics)
Conversiefuncties (Azure Stream Analytics)
Datum- en tijdfuncties (Azure Stream Analytics)
Recordfuncties (Azure Stream Analytics)