연속 쿼리 - Amazon Kinesis Data Analytics for SQL Applications 개발자 안내서

신중한 고려 후 다음 두 단계로 Amazon Kinesis Data Analytics for SQL applications를 중단하기로 결정했습니다.

1. 2025년 10월 15일부터 SQL 애플리케이션을 위한 새 Kinesis Data Analytics를 생성할 수 없습니다.

2. 2026년 1월 27일부터 애플리케이션이 삭제됩니다. SQL 애플리케이션용 Amazon Kinesis Data Analytics를 시작하거나 운영할 수 없습니다. SQL 해당 시점부터에 대한 Amazon Kinesis Data Analytics에 대한 지원을 더 이상 사용할 수 없습니다. 자세한 내용은 Amazon Kinesis Data Analytics for SQL Applications 중단 단원을 참조하십시오.

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

연속 쿼리

스트림에 대한 쿼리는 스트리밍 데이터에 대해 연속적으로 실행됩니다. 이러한 연속 실행은 애플리케이션이 스트림을 연속적으로 쿼리하고 알림을 생성하는 시나리오를 가능하게 합니다.

시작하기 연습에서는 명칭이 SOURCE_SQL_STREAM_001인 애플리케이션 내 스트림이 있습니다. 그것은 데모 스트림(Kinesis 데이터 스트림)에서 주식 가격을 지속적으로 받습니다. 스키마는 다음과 같습니다:

(TICKER_SYMBOL VARCHAR(4), 
 SECTOR varchar(16), 
 CHANGE REAL, 
 PRICE REAL)

15%가 넘는 주가 변동에 관심이 있다고 가정해 보겠습니다. 애플리케이션 코드에서 다음 쿼리를 사용할 수 있습니다. 이 쿼리는 연속적으로 실행되며 15%를 초과하는 주가 변동이 감지되는 경우 레코드를 방출합니다.

SELECT STREAM TICKER_SYMBOL, PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15

다음 절차를 사용하여 Amazon Kinesis Data Analytics 애플리케이션을 설정하고 이 쿼리를 시험합니다.

쿼리 테스트 방법

  1. 시작하기 연습에 따라 애플리케이션을 생성합니다.

  2. 애플리케이션 코드에서 SELECT 문을 앞의 SELECT 쿼리로 바꿉니다. 그러면 애플리케이션 코드가 다음과 같을 것입니다.

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   price DOUBLE);
-- CREATE OR REPLACE PUMP to insert into output
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
      SELECT STREAM TICKER_SYMBOL, 
                    PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15;