단계 2: 애플리케이션 만들기 - SQL 애플리케이션용 Amazon Kinesis Data Analytics for SQL 애플리케이션 개발자 가이드

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

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

주의

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

이 섹션에서는 Amazon Kinesis Data Analytics 애플리케이션을 생성합니다.

  • 에서1단계: 준비 생성한 Kinesis 데이터 스트림을 스트리밍 소스로 사용하도록 애플리케이션 입력을 구성합니다.

  • 콘솔에서 변칙 감지 템플릿을 사용합니다.

애플리케이션을 생성하려면
  1. Kinesis Data Analytics 시작하기 연습의 1, 2, 3단계를 따르십시오 (참조단계 3.1: 애플리케이션 만들기).

    • 소스 구성에서 다음을 수행합니다.

      • 이전 단원에서 생성한 스트리밍 소스를 지정합니다.

      • 콘솔이 스키마를 유추한 후에 스키마를 편집하고 heartRate 열 유형을 INTEGER로 설정합니다.

        대부분의 심박수 값은 정상이며 검색 프로세스는 이 열에 TINYINT 유형을 할당할 가능성이 높습니다. 그러나 높은 심박수를 나타내는 값은 백분율이 매우 낮습니다. 이러한 높은 값이TINYINT 유형에 맞지 않는 경우 Kinesis Data Analytics 이러한 행을 오류 스트림으로 보냅니다. 생성된 모든 심박수 데이터를 수용할 수 있도록 데이터 유형을 INTEGER로 업데이트합니다.

    • 콘솔에서 변칙 감지 템플릿을 사용합니다. 그런 다음 템플릿 코드를 업데이트하여 적절한 열 이름을 부여합니다.

  2. 열 이름을 부여하여 애플리케이션 코드를 업데이트합니다. 결과로 얻은 애플리케이션 코드는 다음과 같이 표시됩니다(이 코드를 복사하여 SQL 편집기에 붙여넣습니다).

    --Creates a temporary stream. CREATE OR REPLACE STREAM "TEMP_STREAM" ( "heartRate" INTEGER, "rateType" varchar(20), "ANOMALY_SCORE" DOUBLE); --Creates another stream for application output. CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( "heartRate" INTEGER, "rateType" varchar(20), "ANOMALY_SCORE" DOUBLE); -- Compute an anomaly score for each record in the input stream -- using Random Cut Forest CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "TEMP_STREAM" SELECT STREAM "heartRate", "rateType", ANOMALY_SCORE FROM TABLE(RANDOM_CUT_FOREST( CURSOR(SELECT STREAM * FROM "SOURCE_SQL_STREAM_001"))); -- Sort records by descending anomaly score, insert into output stream CREATE OR REPLACE PUMP "OUTPUT_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM * FROM "TEMP_STREAM" ORDER BY FLOOR("TEMP_STREAM".ROWTIME TO SECOND), ANOMALY_SCORE DESC;

  3. Kinesis Data Analytics 콘솔에서 SQL 코드를 실행하고 결과를 검토합니다.

    
                            인애플리케이션 스트림의 결과 데이터가 포함된 실시간 분석 탭을 보여주는 콘솔 스크린샷

다음 단계

3단계: 애플리케이션 출력 구성