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

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

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

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

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

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

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

애플리케이션을 생성하려면

  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. SQL 코드를 실행하고 Kinesis Data Analytics 콘솔에서 결과를 검토하십시오.

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

다음 단계

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