윈도우 모드 쿼리 - SQL애플리케이션용 Amazon Kinesis Data Analytics 개발자 가이드

새 프로젝트의 경우 애플리케이션용 Kinesis Data Analytics보다 Apache Flink Studio용 새로운 관리형 서비스를 사용하는 것이 좋습니다. SQL Managed Service for Apache Flink Studio는 사용 편의성과 고급 분석 기능을 결합하여 정교한 스트림 처리 애플리케이션을 몇 분 만에 구축할 수 있도록 합니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

윈도우 모드 쿼리

애플리케이션 코드에서 SQL 쿼리는 애플리케이션 내 스트림에 대해 연속적으로 실행됩니다. 애플리케이션 내 스트림은 애플리케이션을 통해 연속적으로 흐르는 무한 데이터를 나타냅니다. 따라서 연속적으로 업데이트되는 이 입력으로부터 결과 세트를 얻으려면 시간 또는 행을 기반으로 정의된 윈도우를 사용하여 쿼리를 자주 바인딩해야 합니다. 이를 윈도우 모드 SQL이라고도 합니다.

시간 기반 윈도우 모드 쿼리의 경우 시간 기반 윈도우 크기를 지정합니다(예: 1분 윈도우). 이를 위해서는 단순 증가하는 타임스탬프 열이 애플리케이션 내 스트림에 있어야 합니다. (새 행의 타임스탬프가 이전 행보다 크거나 같은 경우.) Amazon Kinesis Data Analytics는 각 애플리케이션 내 스트림에 대해 ROWTIME라는 그러한 타임스탬프 열을 제공합니다. 시간 기반 쿼리를 지정할 때 이 열을 사용할 수 있습니다. 애플리케이션에 대해 몇몇 다른 타임스탬프 옵션을 선택할 수 있습니다. 자세한 설명은 타임스탬프와 ROWTIME 열 섹션을 참조하세요.

행 기반 윈도우 모드 쿼리의 경우 행 수 기준 윈도우 크기를 지정합니다.

애플리케이션의 필요에 따라 텀블링 윈도우, 슬라이딩 윈도우 또는 스태거 윈도우 방식으로 레코드를 처리하도록 쿼리를 지정할 수 있습니다. Kinesis Data Analytics는 다음 창 유형을 지원합니다:

  • 스태거 윈도우: 데이터가 도착하면 열리는 키 참조 시간 기반 윈도우를 이용해 데이터를 집계하는 쿼리. 복수의 중복 윈도우를 허용하는 키. 시간 기반 창을 사용하여 데이터를 집계할 때는 이 방법을 사용하는 것이 좋습니다. 스태거 윈도우는 텀블링 윈도우에 비해 지연 또는 out-of-order 데이터를 감소시키기 때문입니다.

  • 텀블링 윈도우: 정기적으로 열리고 닫히는 개별 시간 기반 윈도우를 이용해 데이터를 집계하는 쿼리.

  • 슬라이딩 윈도우: 고정 시간이나 행 개수 간격을 이용해 데이터를 지속적으로 집계하는 쿼리.