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

이 섹션에 제시된 단계에 따라 먼저 콘솔을 사용하여 귀하의 첫 번째 Kinesis Data Analytics 애플리케이션을 생성할 수 있습니다.

참고

시작하기 연습을 수행하기 전에 Amazon Kinesis Data Analytics for SQL 애플리케이션: 작동 방식 섹션을 복습하는 것이 좋습니다.

이 시작하기 연습을 위해 콘솔을 이용하여 애플리케이션 코드가 있는 템플릿이나 데모 스트림으로 작업할 수 있습니다.

• 데모 스트림을 사용하기로 선택하는 경우, 콘솔이 kinesis-analytics-demo-stream이라는 Kinesis 데이터 스트림을 귀하의 계정에 생성합니다.

  Kinesis Data Analytics 애플리케이션에는 스트리밍 소스가 필요합니다. 이 소스의 경우, 이 설명서의 몇몇 SQL 예가 데모 스트림 kinesis-analytics-demo-stream을 사용합니다. 콘솔은 다음과 같이 이 스트림에 샘플 데이터(시뮬레이션된 주식 거래 레코드)를 지속적으로 추가하는 스크립트를 실행합니다.

  

  이 연습에서는 kinesis-analytics-demo-stream을 애플리케이션의 스트리밍 소스로 사용할 수 있습니다.

  참고

  데모 스트림은 계정에 남아 있습니다. 이 설명서에서 다른 예를 테스트하는 데 사용할 수 있습니다. 그러나 콘솔을 벗어나면 콘솔이 사용하는 스크립트가 데이터 채우기를 중단합니다. 필요한 경우, 콘솔이 스트림 채우기 재시작 옵션을 제공합니다.

• 예 애플리케이션 코드가 있는 템플릿을 사용하기로 선택하는 경우, 데모 스트림에 대한 간단한 분석을 수행할 수 있도록 콘솔이 제공하는 템플릿 코드를 활용합니다.

이 기능들을 사용하여 다음과 같인 첫 번째 애플리케이션을 신속하게 설정합니다.

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

    

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

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

    

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

    

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

   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 Data Analytics SQL 참조를 참조하십시오.

    

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

중요

이 연습에서는 미국 동부 (버지니아 북부) 지역(us-east-1)을 사용하여 애플리케이션을 설정합니다. 지원되는 AWS 리전 중 어느 것이나 사용할 수 있습니다.

다음 단계

단계 3.1: 애플리케이션 만들기