Fenêtre bascule (Azure Stream Analytics)

Les fenêtres bascule sont une série d’intervalles de temps contigus fixes, qui ne se chevauchent pas. Le diagramme suivant illustre un flux avec une série d’événements et la façon dont ils sont mappés dans des fenêtres bascules de 10 secondes.

Syntaxe

{TUMBLINGWINDOW | TUMBLING} ( timeunit  , windowsize, [offsetsize] )  
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit  , windowsize ), [Offset(timeunit  , offsetsize)] )  
  

Notes

La fenêtre bascule peut être utilisée des deux manières ci-dessus. Pour permettre la cohérence avec la fenêtre récurrente, la fonction Durée peut également être utilisée avec tous les types de fenêtres pour spécifier la taille de fenêtre. La durée de la fenêtre doit être une constante float positive.

Arguments

timeunit

Unité de temps pour la taille de fenêtre (windowsize). Le tableau suivant répertorie tous les arguments de timeunit valides.

Timeunit	Abréviations
day	dd, d
hour	hh
minute	mi, n
second	ss, s
milliseconde	ms
microseconde	mcs

windowsize

Grand entier décrivant la taille de la fenêtre. La fenêtre est statique et ne peut pas être modifiée dynamiquement au moment de l’exécution.

La taille maximale de la fenêtre est de 7 jours.

offsetsize

Par défaut, les fenêtres bascules sont inclusives à la fin de la fenêtre et exclusives au début ( par exemple, 12:00 -13:00 la fenêtre inclut les événements qui se sont produits exactement à 13h00, mais n’incluront pas les événements qui se sont produits à 12h00 (ces événements feront partie de la fenêtre de 11h00 à 12h00).

Le paramètre Offset peut être utilisé pour modifier ce comportement et inclure les événements au début de la fenêtre et exclure ceux qui se sont produits à la fin.

Exemples

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

Considérations de durée

Chaque opération de fenêtre génère un événement à la fin de la fenêtre. Les fenêtres d’Azure Stream Analytics sont ouvertes à l’heure de début de la fenêtre et fermées à l’heure de fin de la fenêtre. Par exemple, si vous disposez d’une fenêtre de 5 minutes de 12h00 à 00h05, tous les événements dont l’horodatage est supérieur à 00h00 et l’horodatage jusqu’à 12h05 inclus seront inclus dans cette fenêtre. La sortie de la fenêtre est un événement unique basé sur la fonction d'agrégation utilisée avec un horodatage égal à l'heure de fin de la fenêtre. L’horodatage de l’événement de sortie de la fenêtre peut être projeté dans l’instruction SELECT à l’aide de la propriété System.Timestamp() à l’aide d’un alias.

Voir aussi

Fenêtre récurrente
Fenêtre glissante
Fenêtrage