예: 애플리케이션 내 오류 스트림 탐색 - Amazon Kinesis Data Analytics for SQL Applications 개발자 안내서
구문 분석 오류 추가0으로 나누기 오류 추가

신중한 고려 끝에 두 단계로 Amazon Kinesis Data Analytics for SQL applications를 중단하기로 결정했습니다.

1. 2025년 10월 15일부터 SQL 애플리케이션을 위한 새 Kinesis Data Analytics를 생성할 수 없습니다.

2. 2026년 1월 27일부터 애플리케이션이 삭제됩니다. SQL 애플리케이션용 Amazon Kinesis Data Analytics를 시작하거나 작동할 수 없습니다. 해당 시점부터 에 대한 Amazon Kinesis Data AnalyticsSQL에 대한 지원을 더 이상 사용할 수 없습니다. 자세한 내용은 Amazon Kinesis Data Analytics for SQL Applications 중단 단원을 참조하십시오.

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

예: 애플리케이션 내 오류 스트림 탐색

Amazon Kinesis Data Analytics은 생성된 각 애플리케이션에 대해 애플리케이션 내 오류 스트림을 제공합니다. 애플리케이션이 처리할 수 없는 행은 모두 이 오류 스트림으로 전송됩니다. 조사를 위해 오류 스트림 데이터를 외부 대상에 유지하는 것을 고려할 수도 있습니다.

콘솔에서 다음 실습을 수행합니다. 이 예에서 검색 프로세스에서 유추된 스키마를 편집하여 오류를 입력 구성에 추가하고 오류 스트림에 전송된 행을 확인합니다.

구문 분석 오류 추가

이 실습에서는 구문 분석 오류를 추가합니다.

  1. Kinesis Data Analytics 시작하기 연습에 설명된 대로 Kinesis Data Analytics 애플리케이션을 생성합니다.

  2. 애플리케이션 세부 정보 페이지에서 스트리밍 데이터 연결을 선택합니다.

  3. 시작하기 실습을 수행했으면 계정에 데모 스트림(kinesis-analytics-demo-stream)이 있을 것입니다. Connect to source(소스에 연결) 페이지에서 이 데모 스트림을 선택합니다.

  4. Kinesis Data Analytics이 데모 스트림에서 샘플을 취하여 생성된 애플리케이션 내 입력 스트림에 대한 스키마를 유추합니다. 콘솔의 [Formatted stream sample] 탭에서 유추된 스키마와 샘플 데이터를 확인할 수 있습니다.

  5. 다음으로 스키마를 편집하고 열 유형을 수정하여 구문 분석 오류를 추가합니다. Edit schema(스키마 편집)를 선택합니다.

  6. TICKER_SYMBOL 열 유형을 VARCHAR(4)에서 INTEGER로 변경합니다.

    생성된 애플리케이션 내 스키마의 열 유형이 유효하지 않다면, Kinesis Data Analytics이 애플리케이션 내 스트림으로 데이터를 가져올 수 없습니다. 대신 행을 오류 스트림에 전송합니다.

  7. [Save schema]를 선택합니다.

  8. [Refresh schema samples]를 선택합니다.

    [Formatted stream] 샘플에 행이 없다는 점에 유의하십시오. 그러나 [Error stream] 탭에서는 오류 메시지와 함께 데이터를 보여 줍니다. [Error stream] 탭에서는 애플리케이션 내 오류 스트림으로 전송된 데이터를 보여 줍니다.

    열 데이터 유형을 변경했기 때문에 Kinesis Data Analytics가 애플리케이션 내 입력 스트림에서 데이터를 가져올 수 없었습니다. 대신 데이터를 오류 스트림으로 전송했습니다.

0으로 나누기 오류 추가

이 연습에서는 애플리케이션 코드를 업데이트하여 런타임 오류(0으로 나누기)를 추가합니다. Amazon Kinesis Data Analytics는 당초 결과를 쓰여 질 애플리케이션 내 스트림 대신DESTINATION_SQL_STREAM 애플리케이션 내 오류 스트림으로 결과 행을 전송합니다.

  1. Kinesis Data Analytics 시작하기 연습에 설명된 대로 Kinesis Data Analytics 애플리케이션을 생성합니다.

    다음과 같이 [Real-time analytics] 탭에서 결과를 확인합니다.

    Sour

  2. 애플리케이션 코드에서 SELECT 문을 업데이트하여 0으로 나누기를 추가합니다. 예: 

    SELECT STREAM ticker_symbol, sector, change, (price / 0) as ProblemColumn
FROM "SOURCE_SQL_STREAM_001"
WHERE sector SIMILAR TO '%TECH%';

  3. 애플리케이션을 실행합니다.

    0으로 나누기 런타임 오류가 발생하기 때문에 결과를 DESTINATION_SQL_STREAM에 작성하지 않고 Kinesis Data Analytics는 행을 애플리케이션 내 오류 스트림으로 전송합니다. Real-time analytics(실시간 분석) 탭에서 오류 스트림을 선택하면 애플리케이션 내 오류 스트림에서 행을 볼 수 있습니다.