Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
✅ Поток событий Azure Stream Analytics ✅ Fabric
Переворачивающиеся окна — это ряд фиксированных, не перекрывающихся и смежных интервалов времени. На следующей схеме показан поток с рядом событий и их сопоставление с 10-секундными переворачивающимися окнами.
в
Синтаксис
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
Замечание
Переворачивающееся окно можно использовать двумя способами. Чтобы обеспечить согласованность с окном прыжков, функция "Длительность" также может использоваться со всеми типами окон, чтобы указать размер окна. Длительность окна должна быть положительной константой с плавающей запятой.
Аргументы
timeunit
Единица времени для окна. В следующей таблице перечислены все допустимые аргументы timeunit.
| Timeunit | Аббревиатуры |
|---|---|
| день | дд, д |
| час | Чч |
| минута | mi, n |
| секунда | ss, s |
| миллисекунда | мс |
| микросекунда | mcs |
windowsize
Большое целое число, описывающее размер окна. Windowsize является статическим и не может быть динамически изменен во время выполнения.
Максимальный размер окна составляет 7 дней.
смещение
По умолчанию переворачивающиеся окна включены в конец окна и эксклюзивные в начале ( например, 12:00 – 1:00 — окно 1:00 будет включать события, которые произошли ровно в 1:00 вечера, но не будут включать события, которые произошли в 12:00 вечера (эти события будут частью окна 11:00 – 12:00 вечера).
Параметр Offset можно использовать для изменения этого поведения и включения событий в начало окна и исключения тех, которые произошли в конце.
Примеры
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
Рекомендации по времени
Каждая операция окна выводит событие в конце окна. Окна Azure Stream Analytics открываются во время начала окна и закрываются во время окончания окна. Например, если у вас есть 5-минутное окно с 12:00 до 12:05, все события со меткой времени больше 12:00 и до метки времени 12:05 включительно будут включены в это окно. Выходные данные окна будут одним событием на основе агрегатной функции, используемой с меткой времени, равной времени окончания окна. Метка времени выходного события окна может быть проецирована в инструкции SELECT с помощью свойства System.Timestamp() с помощью псевдонима.