✅ Azure Stream Analytics ✅ Fabric Eventstream
연속 창은 고정 크기, 겹치지 않는 연속 시간 간격의 시리즈입니다. 다음 다이어그램에서는 일련의 이벤트가 있는 스트림과 10초 연속 창에 매핑되는 방법을 보여 줍니다.
문법
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
비고
연속 창은 위의 두 가지 방법으로 사용할 수 있습니다. Hopping Window와의 일관성을 위해 Duration 함수를 모든 유형의 창과 함께 사용하여 창 크기를 지정할 수도 있습니다. 창 기간은 양의 부동 소수 자릿수 상수여야 합니다.
주장들
timeunit
windowsize의 시간 단위입니다. 다음 표에서는 유효한 모든 timeunit 인수를 나열합니다.
| Timeunit | 약어 |
|---|---|
| 하루 | dd, d |
| 시 | ㅎㅎ |
| 분 | mi, n |
| 초 | ss, s |
| 밀리초 | 밀리초(ms) |
| 마이크로초 | mcs |
windowsize
창의 크기를 설명하는 큰 정수입니다. windowsize는 정적이며 런타임에 동적으로 변경할 수 없습니다.
창의 최대 크기는 7일입니다.
offsetsize
기본적으로 연속 창은 창의 끝에 포함되며 시작 부분에서만 사용할 수 있습니다. 예를 들어 오후 12:00 – 오후 1:00 창에는 정확히 오후 1시에 발생한 이벤트가 포함되지만 12:00PM에 발생한 이벤트는 포함되지 않습니다(이러한 이벤트는 오전 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의 창은 창 시작 시간에 열리고 창 종료 시간에 닫힙니다. 예를 들어 오전 12:00부터 오전 12:05까지 5분 간격이 있는 경우 타임스탬프가 오전 12:00보다 크고 최대 타임스탬프 오전 12:05까지 포함되는 모든 이벤트가 이 창에 포함됩니다. 창의 출력은 창 종료 시간과 동일한 타임스탬프와 함께 사용되는 집계 함수를 기반으로 하는 단일 이벤트가 됩니다. 별칭을 사용하여 System.Timestamp() 속성을 사용하여 SELECT 문에 창의 출력 이벤트의 타임스탬프를 프로젝션할 수 있습니다.