Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
✅ Azure Stream Analytics ✅ Fabric Eventstream
Les fenêtres bascules sont une série d’intervalles de temps fixes, non superposés et contigus. 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)] )
Remarque
La fenêtre bascule 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. La durée de la fenêtre doit être une constante flottante positive.
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 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, 12h00 – 13h00) incluent les événements qui se sont produits exactement à 13h00, mais n’incluent pas les événements qui se sont produits à 12h00 (ces événements font partie de la fenêtre 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 relatives au temps
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 avez une fenêtre de 5 minutes comprise entre 12h00 et 12h05, tous les événements avec timestamp supérieur à 12h00 et jusqu’à 12h05 inclus seront inclus dans cette fenêtre. La sortie de la fenêtre sera 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.