다음을 통해 공유


창 함수(Azure Stream Analytics)

실시간 이벤트를 처리하는 애플리케이션에서는 일정 기간 내에 속하는 이벤트의 하위 집합에 대해 일부 집합 기반 계산(집계) 또는 기타 작업을 수행하는 것이 일반적입니다. 시간 개념은 복잡한 이벤트 처리 시스템의 기본 필수 항목이므로 시스템에 쿼리 논리의 시간 구성 요소로 작업할 간단한 방법이 있어야 합니다. Azure 스트림 분석에서는 시간 기준 그룹화를 나타내는 창을 통해 이러한 이벤트 하위 집합이 정의됩니다. 이 문서에서는 창 및 창 정의 방법을 설명하고, 지원되는 창 유형을 식별하고, 다양한 연산자와 함께 창을 사용하는 방법을 설명합니다.

창 이해

창에는 시간 표시줄에 따른 이벤트 데이터가 포함됩니다. 창을 통해 해당 창 내의 이벤트에 대해 다양한 작업을 수행할 수 있습니다. 다음 그림에 나와 있는 것처럼 지정된 창에서 페이로드 필드 값의 합을 계산하려는 경우를 예로 들 수 있습니다.

Stream Analytics 쿼리 언어 텀블링 창

모든 창 작업은 창 끝에 이벤트를 출력합니다. Azure Stream Analytics의 창은 창 시작 시간에 열리고 창 종료 시간에 닫힙니다. 예를 들어 오전 12:00부터 오전 12:05까지 5분 창이 있는 경우 타임스탬프가 오전 12:00보다 크고 타임스탬프가 오전 12:05까지 포함되는 모든 이벤트가 이 창에 포함됩니다. 창의 출력은 창 종료 시간과 같은 타임스탬프에서 사용되는 집계 함수를 기준으로 하는 단일 이벤트입니다. 창의 출력 이벤트의 타임스탬프는 별칭을 사용하여 System.Timestamp() 속성을 사용하여 SELECT 문에 프로젝션할 수 있습니다. 모든 창 자체는 0번째 시간에 자동 정렬됩니다. 예를 들어 5분 연속 창은 (12:00-12:05] , (12:05-12:10] 등)에 맞춰 정렬됩니다.

창 작업 후 이벤트의 타임스탬프는 원래 이벤트 시간 특성( 도착 시간 또는 TIMESTAMP BY에 사용된 열)과 다릅니다. 이벤트의 현재 업데이트된 타임스탬프는 항상 system.timestamp()를 사용하여 액세스할 수 있습니다.

참고

모든 창은 GROUP BY 절에서 사용해야 합니다.

다음과 같은 5가지 유형의 창이 있습니다.

  1. 연속 창(Azure Stream Analytics)

  2. 도약 창(Azure 스트림 분석)

  3. 슬라이딩 윈도우(Azure 스트림 분석)

  4. 세션 창(Azure Stream Analytics)

  5. 스냅샷 창(Azure Stream Analytics)

모든 경우 최대 기간은 7일입니다.

Windows(Azure Stream Analytics) 함수를 사용하여 동일한 GROUP BY 문에서 여러 시간 동안 집계할 수 있습니다.

참고 항목

기본 제공 함수(Azure 스트림 분석)
집계 함수(Azure 스트림 분석)
분석 함수(Azure 스트림 분석)
배열 함수(Stream Analytics)
변환 함수(Azure 스트림 분석)
날짜 및 시간 함수(Azure Stream Analytics)
레코드 함수(Azure Stream Analytics)