Fenêtre glissante (Azure Stream Analytics)
En cas d'utilisation d'une fenêtre glissante, le système est invité à examiner logiquement toutes les fenêtres possibles d'une longueur donnée. Étant donné que le nombre de ces fenêtres est infini, Azure Stream Analytics génère plutôt des événements uniquement pour les moments où le contenu de la fenêtre change réellement, c’est-à-dire 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 comment ils sont mappés dans des fenêtres glissantes de 10 secondes.
Syntaxe
{SLIDINGWINDOW | SLIDING} ( timeunit, windowsize )
{SLIDINGWINDOW | SLIDING} ( Duration( timeunit, windowsize ) )
Notes
La fenêtre glissante peut être utilisée des deux manières décrites 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.
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 dans tous les cas est de 7 jours.
Exemples
Cet exemple recherche tous les guichets 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