Функции окна

✅ Поток событий Azure Stream Analytics ✅ Fabric

В приложениях, обрабатывающих события в режиме реального времени, обычно выполняется некоторые вычисления на основе набора (агрегирование) или другие операции с подмножествами событий, которые попадают в течение некоторого периода времени. Поскольку концепция времени является основной необходимостью для сложных систем обработки событий, важно иметь простой способ работы с компонентом времени логики запросов в системе. В Azure Stream Analytics эти подмножества событий определяются через окна для представления групп по времени. В этой статье описаны окна и их определение, определение типов поддерживаемых окон и описание того, как можно использовать окна с различными операторами.

Общие сведения о Windows

Окно содержит данные о событиях на временной шкале и позволяет выполнять различные операции с событиями в этом окне. Например, может потребоваться суммировать значения полей полезных данных в заданном окне, как показано на следующем рисунке.

Каждая операция окна выводит событие в конце окна. Окна Azure Stream Analytics открываются во время начала окна и закрываются во время окончания окна. Например, если у вас есть 5-минутное окно с 12:00 до 12:05, все события со меткой времени больше 12:00 и до метки времени 12:05 включительно будут включены в это окно. Выходные данные окна будут одним событием на основе агрегатной функции, используемой с меткой времени, равной времени окончания окна. Метка времени выходного события окна может быть проецирована в инструкции SELECT с помощью свойства System.Timestamp() с помощью псевдонима. Каждое окно автоматически выравнивается с нулевым часом. Например, 5-минутное переворачивающееся окно выровняется с (12:00-12:05], (12:05-12:10], ...и т. д.

После операции окна метка времени события будет отличаться от исходного атрибута времени события ( время прибытия или столбец, используемый с TIMESTAMP BY). Текущая обновленная метка времени события всегда может быть доступна с помощью system.timestamp().

Существует пять типов окон:

1. Переворачивающееся окно

2. Окно прыжка

3. Скользящее окно

4. Окно сеанса

5. Окно моментального снимка

Максимальный размер окна во всех случаях составляет 7 дней.

Вы можете агрегировать несколько окон времени в одной инструкции GROUP BY с помощью функции Windows .

См. также

Встроенные функции
агрегатные функции
Аналитические функции
Функции массива (Stream Analytics)
функции преобразования
Функции даты и времени
Функции записи данных