스키마 편집기로 작업 - Amazon Kinesis Data Analytics for SQL Applications 개발자 안내서
스키마 편집기 기본 화면스트리밍 소스에 대한 스키마 편집

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

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

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

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

스키마 편집기로 작업

Amazon Kinesis Data Analytics 애플리케이션 입력 스트림의 스키마는 스트림에서 나오는 데이터를 애플리케이션에서 SQL 쿼리가 사용할 수 있는 방식을 정의합니다.

스트리밍 입력, 소스 스키마 구성 및 애플리케이션 내 입력 스트림 간의 관계를 보여주는 다이어그램

스키마에는 스트리밍 입력 중 어느 부분을 애플리케이션 입력에 있는 데이터 열로 변환할지 결정하는 선택 기준이 포함되어 있습니다. 이 입력은 다음 중 하나일 수 있습니다.

  • JSON 입력 스트림에 대한 JSONPath 표현식입니다. JSONPath는 JSON 데이터 쿼리를 위한 도구입니다.

  • CSV(쉼표로 분리된 값) 형식의 입력 스트림에 대한 열 번호입니다.

  • 애플리케이션 내 데이터 스트림에 데이터를 표현하기 위한 열 명칭과 SQL 데이터 유형입니다. 데이터 유형에는 문자 또는 이진 데이터의 길이 또한 포함됩니다.

콘솔은 DiscoverInputSchema를 사용해서 스키마 생성을 시도합니다. 스키마 검색이 실패하거나 부정확한 또는 불완전한 스키마를 반환하는 경우, 스키마 편집기를 이용해 스키마를 수동으로 편집해야 합니다.

스키마 편집기 기본 화면

다음 스크린샷은 스키마 편집기의 기본 화면을 보여줍니다.

스키마 편집 페이지의 스크린샷

다음과 같은 편집 작업을 스키마에 적용할 수 있습니다.

  • 열 추가(1): 데이터 항목이 자동으로 감지되지 않는 경우 열을 추가해야 할 수 있습니다.

  • 열 삭제(2): 애플리케이션이 필요로 하지 않는 경우 데이터를 소스 스트림으로부터 제외할 수 있습니다. 이렇게 제외된 경우에도 소스 스트림에 있는 데이터에 영향을 주지 않습니다. 데이터가 제외되는 경우 해당 데이터를 애플리케이션에서 사용할 수 없습니다.

  • 열 명칭 바꾸기 (3): 열 명칭은 공백일 수 없고, 길이가 한 문자 이상이어야 하며, 예약된 SQL 키워드가 포함되어서는 안 됩니다. 명칭은 SQL 일반 식별자의 명명 기준에 부합해야 합니다. 즉, 문자로 시작해야 하고 문자, 밑줄 및 숫자만 포함해야 합니다.

  • 열의 데이터 유형(4) 또는 길이(5) 변경: 열에 대해 호환 가능 데이터 유형을 지정할 수 있습니다. 비호환 데이터 유형을 지정하는 경우 열이 NULL로 채워지거나 애플리케이션 내 스트림이 채워지지 않습니다. 후자의 경우 오류가 오류 스트림에 작성됩니다. 열의 길이를 너무 작게 지정하는 경우 수신 데이터가 잘립니다.

  • 열 선택 기준 변경(6): 열의 데이터 소스를 결정하는 데 사용되는 JSONPath 표현식이나 CSV 열 순서를 편집할 수 있습니다. JSON 스키마의 선택 기준을 변경하려면 행 경로 표현식에 대한 새 값을 입력합니다. CSV 스키마는 열 순서를 선택 기준으로 사용합니다. CSV 스키마에 대한 선택 기준을 변경하려면 열 순서를 변경합니다.

스트리밍 소스에 대한 스키마 편집

스트리밍 소스에 대한 스키마를 편집해야 하는 경우 다음 단계를 따릅니다.

스트리밍 소스에 대한 스키마 편집 방법

  1. 소스 페이지에서 Edit schema(스키마 편집)를 선택합니다.

    주식 데이터가 포함된 포맷된 스트림 샘플 탭의 스크린샷(스키마 편집 버튼이 강조 표시되어 있음)

  2. [Edit schema] 페이지에서 소스 스키마를 편집합니다.

    스키마 편집 페이지의 스크린샷

  3. 형식(Format)에서 JSON 또는 CSV를 선택합니다. JSON 또는 CSV 형식의 경우, 지원되는 인코딩은 ISO 8859-1입니다.

JSON 또는 CSV 형식의 스키마 편집에 대한 자세한 정보는 다음 섹션에 수록된 절차를 참조하십시오.

JSON 스키마 편집

다음 단계에 따라 JSON 스키마를 편집할 수 있습니다.

JSON 스키마를 편집하려면

  1. 스키마 편집기에서 [Add column]을 선택하여 열을 추가합니다.

    첫 번째 열 위치에서 새 열이 나타납니다. 열 순서를 변경하려면 열 명칭 옆에 있는 위/아래 화살표를 선택합니다.

    새 열에 대해 다음의 정보를 제공합니다.

    • [Column name]에서 명칭을 입력합니다.

      열 명칭은 공백일 수 없고, 길이가 한 문자 이상이어야 하며, 예약된 SQL 키워드가 포함되어서는 안 됩니다. 명칭은 SQL 일반 식별자의 명명 기준에 부합해야 합니다. 즉, 문자로 시작해야 하고 문자, 밑줄 및 숫자만 포함해야 합니다.

    • [Column type]에서 SQL 데이터 유형을 입력합니다.

      열 유형은 지원되는 SQL 데이터 유형이면 됩니다. 새 데이터 유형이 CHAR, VARBINARY 또는 VARCHAR인 경우 [Length]에서 데이터 길이를 지정합니다. 자세한 정보는 데이터 형식을 참조하십시오.

    • [Row path]에서 행 경로를 입력합니다. 행 경로는 JSON 요소로 매핑된 유효한 JSONPath 표현식입니다.

      참고

      기본 [Row path] 값은 가져올 데이터를 포함하는 최상위 구성 요소로 향하는 경로입니다. 기본적으로 이 값은 $입니다. 자세한 설명은 JSONMappingParameters에서 RecordRowPath 섹션을 참조하십시오.

  2. 열을 삭제하려면 열 번호 옆에 있는 x 아이콘을 선택합니다.

    열 번호 옆에 있는 x 아이콘을 보여주는 스키마 편집기의 스크린샷

  3. 열 명칭을 다시 지정하려면 열 명칭에서 새 명칭을 입력합니다. 새 열 명칭은 공백일 수 없고, 길이가 한 문자 이상이어야 하며, 예약된 SQL 키워드가 포함되어서는 안 됩니다. 명칭은 SQL 일반 식별자의 명명 기준에 부합해야 합니다. 즉, 문자로 시작해야 하고 문자, 밑줄 및 숫자만 포함해야 합니다.

  4. 열의 데이터 유형을 변경하려면 [Column type]에서 새 데이터 유형을 선택합니다. 새 데이터 유형이 CHAR, VARBINARY 또는 VARCHAR인 경우 Length(길이)에 데이터 길이를 지정합니다. 자세한 정보는 데이터 형식을 참조하십시오.

  5. [Save schema and update stream]을 선택하여 변경 사항을 저장합니다.

수정된 스키마가 편집기에 표시되는데, 다음과 비슷할 것입니다.

수정된 스키마를 보여주는 스키마 편집기의 스크린샷

스키마에 행이 많은 경우, [Filter by column name]을 사용하여 행을 필터링할 수 있습니다. 예를 들어, Price 열 같이 P로 시작하는 열 명칭을 편집하려면, 열 명칭별 필터링 상자에 P을 입력합니다.

CSV 스키마 편집

다음 단계에 따라 CSV 스키마를 편집할 수 있습니다.

CSV 스키마를 편집하려면

  1. 스키마 편집기의 [Row delimiter]에서 수신 데이터 스트림이 사용할 구분 기호를 선택합니다. 이는 스트림에 있는 데이터 레코드 간의 구분 기호입니다(예: 줄 바꿈 문자).

  2. [Column delimiter]에서 수신 데이터 스트림이 사용할 구분 기호를 선택합니다. 이는 스트림에 있는 데이터 필드 간의 구분 기호입니다(예: 쉼표).

  3. 열을 추가하려면 [Add column]을 선택합니다.

    첫 번째 열 위치에서 새 열이 나타납니다. 열 순서를 변경하려면 열 명칭 옆에 있는 위/아래 화살표를 선택합니다.

    새 열에 대해 다음의 정보를 제공합니다.

    • 열 명칭에 명칭을 입력합니다.

      열 명칭은 공백일 수 없고, 길이가 한 문자 이상이어야 하며, 예약된 SQL 키워드가 포함되어서는 안 됩니다. 명칭은 SQL 일반 식별자의 명명 기준에 부합해야 합니다. 즉, 문자로 시작해야 하고 문자, 밑줄 및 숫자만 포함해야 합니다.

    • 열 유형에서 SQL 데이터 유형을 입력합니다.

      열 유형은 지원되는 SQL 데이터 유형이면 됩니다. 새 데이터 유형이 CHAR, VARBINARY 또는 VARCHAR인 경우 [Length]에서 데이터 길이를 지정합니다. 자세한 정보는 데이터 형식을 참조하십시오.

  4. 열을 삭제하려면 열 번호 옆에 있는 x 아이콘을 선택합니다.

    열 번호 옆에 있는 x 아이콘을 보여주는 스키마 편집기의 스크린샷

  5. 열 명칭을 다시 지정하려면 열 명칭에서 새 명칭을 입력합니다. 새 열 명칭은 공백일 수 없고, 길이가 한 문자 이상이어야 하며, 예약된 SQL 키워드가 포함되어서는 안 됩니다. 명칭은 SQL 일반 식별자의 명명 기준에 부합해야 합니다. 즉, 문자로 시작해야 하고 문자, 밑줄 및 숫자만 포함해야 합니다.

  6. 열의 데이터 유형을 변경하려면 [Column type]에서 새 데이터 유형을 선택합니다. 새 데이터 유형이 CHAR, VARBINARY 또는 VARCHAR인 경우 [Length]에서 데이터 길이를 지정합니다. 자세한 정보는 데이터 형식을 참조하십시오.

  7. [Save schema and update stream]을 선택하여 변경 사항을 저장합니다.

수정된 스키마가 편집기에 표시되는데, 다음과 비슷할 것입니다.

수정된 스키마를 보여주는 스키마 편집기의 스크린샷

스키마에 행이 많은 경우, [Filter by column name]을 사용하여 행을 필터링할 수 있습니다. 예를 들어, Price 열 같이 P로 시작하는 열 명칭을 편집하려면, 열 명칭별 필터링 상자에 P을 입력합니다.