애플리케이션 코드

애플리케이션 코드는 입력을 처리하고 출력을 생성하는 일련의 SQL 문입니다. 이 SQL 문은 애플리케이션 내 스트림과 참조 표로 운영됩니다. 자세한 설명은 Amazon Kinesis Data Analytics for SQL 애플리케이션: 작동 방식 섹션을 참조하십시오.

Kinesis Data Analytics에서 지원되는 SQL 언어 요소에 대한 자세한 설명은 Amazon Kinesis Data Analytics SQL 참조를 참조하십시오.

관계형 데이터베이스에서 INSERT 문을 통해 레코드를 추가하고 SELECT 문을 통해 데이터를 쿼리하는 표 작업을 수행합니다. Amazon Kinesis Data Analytics에서는 스트림을 사용합니다. SQL 문을 작성하여 이들 스트림을 쿼리할 수 있습니다. 하나의 애플리케이션 내 스트림을 쿼리한 결과는 항상 또 다른 애플리케이션 내 스트림으로 전송됩니다. 복잡한 분석을 수행할 때는 여러 개의 애플리케이션 내 스트림을 생성하여 중간 분석 결과를 유지할 수 있습니다. 그리고 끝으로 최종 분석 결과를(하나 이상의 애플리케이션 내 스트림으로부터) 외부 대상에 유지하도록 애플리케이션 출력을 구성합니다. 요약하자면, 애플리케이션 코드 작성의 일반적인 패턴은 다음과 같습니다.

다음 예 애플리케이션 코드는 하나의 애플리케이션 내 스트림(SOURCE_SQL_STREAM_001)으로부터 레코드를 읽고 이를 또 다른 애플리케이션 내 스트림(DESTINATION_SQL_STREAM)에 기록합니다. 다음과 같이 펌프를 사용하여 레코드를 애플리케이션 내 스트림에 삽입할 수 있습니다.

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   change DOUBLE, 
                                                   price DOUBLE);
-- Create a pump and insert into output stream.
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 

  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM ticker_symbol, change,price
    FROM   "SOURCE_SQL_STREAM_001";

애플리케이션 코드는 복수의 SQL 문으로 구성될 수 있습니다. 예시:

애플리케이션 내 스트림을 생성하여 중간 결과를 저장할 수 있습니다. 펌프를 사용하여 데이터를 애플리케이션 내 스트림에 삽입합니다. 자세한 설명은 애플리케이션 내 스트림과 펌프 섹션을 참조하십시오.

애플리케이션 내 참조 표를 추가하는 경우 SQL을 작성하여 애플리케이션 내 스트림 및 참조 표에 있는 데이터를 조인할 수 있습니다. 자세한 설명은 예: 참조 데이터를 Kinesis Data Analytics 애플리케이션에 추가 섹션을 참조하십시오.

애플리케이션의 출력 구성에 따라 Amazon Kinesis Data Analytics는 특정 애플리케이션 내 스트림으로부터 외부 목적지로 데이터를 기록합니다. 애플리케이션 코드가 출력 구성에 지정된 애플리케이션 내 스트림으로 기록하는지 확인합니다.

자세한 정보는 다음 주제를 참조하십시오: