✅ Azure Stream Analytics ✅ Fabric Eventstream
슬라이딩 윈도우를 사용하는 경우 시스템은 지정된 길이의 가능한 모든 창을 논리적으로 고려하도록 요청받습니다. 이러한 창의 수는 무한하므로 Azure Stream Analytics는 창의 내용이 실제로 변경될 때, 즉 이벤트가 창을 입력하거나 종료할 때 해당 시점에 대해서만 이벤트를 출력합니다.
다음 다이어그램에서는 일련의 이벤트가 있는 스트림과 슬라이딩 윈도우에 10초 동안 매핑되는 방법을 보여 줍니다.
문법
{SLIDINGWINDOW | SLIDING} ( timeunit, windowsize )
{SLIDINGWINDOW | SLIDING} ( Duration( timeunit, windowsize ) )
비고
슬라이딩 윈도우는 위의 두 가지 방법으로 사용할 수 있습니다. Hopping Window와의 일관성을 위해 Duration 함수를 모든 유형의 창과 함께 사용하여 창 크기를 지정할 수도 있습니다.
주장들
timeunit
windowsize의 시간 단위입니다. 다음 표에서는 유효한 모든 timeunit 인수를 나열합니다.
| Timeunit | 약어 |
|---|---|
| 하루 | dd, d |
| 시 | ㅎㅎ |
| 분 | mi, n |
| 초 | ss, s |
| 밀리초 | 밀리초(ms) |
| 마이크로초 | mcs |
windowsize
창의 크기를 설명하는 큰 정수입니다. windowsize는 정적이며 런타임에 동적으로 변경할 수 없습니다.
모든 경우에 창의 최대 크기는 7일입니다.
예시
이 예제에서는 지난 5분 동안 3대 이상의 차량을 서비스한 모든 유료 부스를 찾습니다.
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