3단계: 스타터 Amazon Kinesis Data Analytics 애플리케이션 생성

애플리케이션 생성 – 명칭만 제공하면 됩니다. 콘솔이 애플리케이션을 생성하고 서비스가 애플리케이션 상태를 READY로 설정합니다.

입력 구성 – 먼저 스트리밍 소스인 데모 스트림을 추가합니다. 사용하기 전에 콘솔에서 데모 스트림을 생성해야 합니다. 그런 다음, 콘솔이 데모 스트림에서 레코드 샘플을 무작위로 취하고 생성된 애플리케이션 내 입력 스트림에 대한 스키마를 유추합니다. 콘솔 명칭은 애플리케이션 내 스트림 SOURCE_SQL_STREAM_001입니다.

콘솔은 검색을 API 사용하여 스키마를 유추합니다. 필요할 경우 유추된 스키마를 직접 편집할 수 있습니다. 자세한 설명은 DiscoverInputSchema 섹션을 참조하십시오. Kinesis Data Analytics는 이 스키마를 사용하여 애플리케이션 내 스트림을 생성합니다.

애플리케이션을 시작하면 Kinesis Data Analytics이 여러분을 대신하여 지속적으로 데모 스트림을 읽고 SOURCE_SQL_STREAM_001 애플리케이션 내 입력 스트림에 행을 삽입합니다.

애플리케이션 코드 지정 – 다음 코드를 제공하는 템플릿(연속 필터라고 함)을 사용합니다:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
  (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
 
-- Create pump to insert into output. 
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
   INSERT INTO "DESTINATION_SQL_STREAM"  
      SELECT STREAM ticker_symbol, sector, CHANGE, price
      FROM "SOURCE_SQL_STREAM_001"
      WHERE sector SIMILAR TO '%TECH%';

애플리케이션 코드가 애플리케이션 내 스트림 SOURCE_SQL_STREAM_001을 쿼리합니다. 그러면 코드가 펌프를 사용하여 다른 애플리케이션 내 스트림 DESTINATION_SQL_STREAM에 결과 행을 삽입합니다. 이 코딩 패턴에 대한 자세한 설명은 애플리케이션 코드 섹션을 참조하십시오.

Kinesis Data Analytics에서 지원하는 SQL 언어 요소에 대한 자세한 내용은 Amazon Kinesis 데이터 분석 레퍼런스를 참조하십시오. SQL

출력 구성 – 이 실습에서는 출력을 구성하지 않습니다. 즉, 애플리케이션이 임의의 외부 대상에 생성하는 애플리케이션 내 스트림에 데이터를 유지하지 않는다는 의미입니다. 대신 콘솔에서 쿼리 결과를 확인합니다. 이 설명의 추가 예는 출력을 구성하는 방법을 보여줍니다. 그 중 한 예를 보여주는 예: 간단한 알림 생성 섹션을 참조하십시오.