3.2단계: 입력 구성 - SQL 애플리케이션용 Amazon Kinesis Data Analytics for SQL 애플리케이션 개발자 가이드

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

3.2단계: 입력 구성

주의

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

애플리케이션은 스트리밍 소스가 필요합니다. 용이한 시작을 위해 콘솔이 데모 스트림(kinesis-analytics-demo-stream)을 생성할 수 있습니다. 또한 콘솔은 레코드를 스트림에 채우는 스크립트를 실행합니다.

스트리밍 소스를 애플리케이션에 추가하려면
  1. 콘솔의 애플리케이션 허브에서 Connect streaming data(스트리밍 데이터 연결)를 선택합니다.

    
                            예제 앱과 sourceGS에 연결 버튼의 스크린샷
  2. 이어 나타나는 페이지에서 다음을 검토합니다.

    • 애플리케이션의 스트리밍 소스를 지정하는 [Source] 항목입니다. 기존 스트림 소스를 선택하거나 새로 만들 수 있습니다. 이 실습에서는 새 스트림(데모 스트림)을 생성합니다.

       

      기본 설정으로 콘솔은 생성된 인애플리케이션 입력 스트림을 INPUT_SQL_STREAM_001로 명명합니다. 이 실습에서는 처음부터 이 이름을 유지합니다.

       

      • 스트림 참조 이름 — 이 옵션은 생성된 인애플리케이션 입력 스트림의 이름을 표시합니다SOURCE_SQL_STREAM_001. 이 이름을 변경할 수 있지만 이 실습에서는 이 이름을 유지합니다.

         

        입력 구성에서 데모 스트림을 생성된 인애플리케이션 입력 스트림에 매핑합니다. 애플리케이션을 시작하면 Amazon Kinesis Data Analytics Analytics가 계속해서 데모 스트림을 읽고 애플리케이션 내 입력 스트림에 행을 삽입합니다. 이 인애플리케이션 입력을 애플리케이션 코드에서 쿼리합니다.

         

      • 레코드 사전 처리AWS Lambda 기능: 이 옵션은 애플리케이션 코드가 실행되기 전에 입력 스트림의 레코드를 수정하는AWS Lambda 표현식을 지정하는 곳입니다. 이 연습에서는 [Disabled] 옵션을 선택한 상태로 둡니다. Lambda 전처리에 대한 자세한 내용은 단원을 참조하세요Lambda 함수로 데이터 전처리.

    이 페이지에서 모든 정보를 제공하고 나면 콘솔이 업데이트 요청을 전송하여(UpdateApplication 참조) 애플리케이션에 입력 구성을 추가합니다.

  3. [Source ] 페이지에서 [Configure a new stream]을 선택합니다.

  4. [Create demo stream]을 선택합니다. 콘솔은 다음을 수행하여 애플리케이션 입력을 구성합니다.

    • 콘솔에서 이라는 Kinesis Data Streams 를 생성합니다kinesis-analytics-demo-stream.

    • 콘솔은 주식 티커 데이터 샘플을 스트림에 채웁니다.

    • DiscoverInputSchema 입력 작업을 통해 콘솔은 스트림에서 샘플 레코드를 읽어 스키마를 유추합니다. 유추되는 스키마는 생성된 인애플리케이션 입력 스트림에 대한 스키마입니다. 자세한 정보는 애플리케이션 입력 구성을 참조하세요.

    • 콘솔은 유추된 스키마와 스트리밍 소스로부터 읽어 스키마를 유추한 샘플 데이터를 보여줍니다.

    콘솔은 스트리밍 소스에 대한 샘플 레코드를 표시합니다.

    
                            주식 기호, 섹터 및 가격을 표 형식으로 보여주는 포맷된 스트림 샘플 탭

    [Stream sample] 콘솔 페이지에 다음 항목이 표시됩니다.

    • [Raw stream sample] 탭은 스키마 유추를 위해 DiscoverInputSchema API 작업을 통해 샘플링한 원시 스트림 레코드를 보여줍니다.

    • [Formatted stream sample] 탭은 [Raw stream sample] 탭에 있는 데이터의 테이블 버전을 보여 줍니다.

    • [Edit schema]를 선택하면 유추된 스키마를 편집할 수 있습니다. 이 실습에서는 유추된 스키마를 변경하지 않습니다. 스키마 편집에 대한 자세한 내용은 스키마 편집기로 작업 단원을 참조하십시오.

      [Rediscover schema]를 선택하면 콘솔이 DiscoverInputSchema를 다시 실행하고 스키마를 유추하도록 요청할 수 있습니다.

  5. [Save and continue]를 선택합니다.

    이제 애플리케이션에 입력 구성을 추가했습니다. 다음 단계에서는 SQL 코드를 추가하여 데이터 인애플리케이션 입력 스트림에 대한 분석을 수행합니다.

다음 단계

3.3단계: 실시간 분석 추가(애플리케이션 코드 추가)