Partager via


Fenêtre glissante

✅ Azure Stream Analytics ✅ Fabric Eventstream

Lorsque vous utilisez une fenêtre glissante, le système est invité à considérer logiquement toutes les fenêtres possibles d’une longueur donnée. Comme le nombre de ces fenêtres serait infini, Azure Stream Analytics génère plutôt des événements uniquement pour ces points dans le temps où le contenu de la fenêtre change réellement, en d’autres termes lorsqu’un événement est entré ou quitte la fenêtre.

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 glissantes de 10 secondes.

Fenêtre glissante Stream Analytics 10 seconde

Syntaxe

{SLIDINGWINDOW | SLIDING} ( timeunit, windowsize )
{SLIDINGWINDOW | SLIDING} ( Duration( timeunit, windowsize ) )

Remarque

La fenêtre glissante peut être utilisée de deux manières ci-dessus. Pour autoriser la cohérence avec la fenêtre saut, la fonction Durée peut également être utilisée avec tous les types de fenêtres pour spécifier la taille de la fenêtre.

Les arguments

timeunit

Unité de temps pour la fenêtre. Le tableau suivant répertorie tous les arguments d’unité de temps valides.

Timeunit Abréviations
jour dd, d
heure Hh
minute mi, n
deuxième ss, s
milliseconde milliseconde
microseconde Mcs

windowsize

Entier volumineux qui décrit 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 dans tous les cas est de 7 jours.

Exemples

Cet exemple recherche toutes les cabines de péage qui ont servi plus de 3 véhicules au cours des 5 dernières minutes :

SELECT DateAdd(minute,-5,System.Timestamp()) AS WinStartTime, System.Timestamp() AS WinEndTime, TollId, COUNT(*)
FROM Input TIMESTAMP BY EntryTime
GROUP BY TollId, SlidingWindow(minute, 5)
HAVING COUNT(*) > 3