신중한 고려 끝에 두 단계로 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 중단 단원을 참조하십시오.

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

스트리밍 소스 요소를 SQL 입력 열에 매핑하기

Amazon Kinesis Data Analytics에서는 표준 SQL을 사용하여 JSON 또는 CSV 형식의 스트리밍 데이터를 처리하고 분석할 수 있습니다.

입력 스트림 구성 방법에 관한 자세한 정보는 애플리케이션 입력 구성 섹션을 참조하십시오.

JSON 데이터를 SQL 열에 매핑하기

AWS Management Console 또는 Kinesis Data Analytics API를 사용하여 JSON 요소를 입력 열에 매핑할 수 있습니다.

JSON 요소를 애플리케이션 내 입력 스트림에 있는 열에 매핑하려면 각 열에 대해 다음의 정보가 스키마에 필요합니다.

API 사용

스트리밍 소스의 요소를 입력 열로 매핑할 때 Kinesis Data Analytics API CreateApplication 작업을 사용할 수 있습니다. 애플리케이션 내 스트림을 생성하기 위해서는 SQL에 사용되는 스키마화된 버전으로 데이터를 변환할 스키마를 지정합니다. CreateApplication 작업은 단일 스트리밍 소스로부터 입력을 수신하도록 애플리케이션을 구성합니다. JSON 요소 또는 CSV 열을 SQL 열로 매핑하려면 SourceSchema RecordColumns 어레이에서 RecordColumn을 생성합니다. RecordColumn 객체에는 다음의 스키마가 있습니다.

{ 
    "Mapping": "String",
    "Name": "String",
    "SqlType": "String"
}                   
                

RecordColumn 객체에 있는 필드는 다음의 값을 가집니다.

JSON 입력 스키마 예

다음 예는 JSON 스키마에 대한 InputSchema 값의 형식을 보여 줍니다.

"InputSchema": {
    "RecordColumns": [
        {
            "SqlType": "VARCHAR(4)",
            "Name": "TICKER_SYMBOL",
            "Mapping": "$.TICKER_SYMBOL"
        },
        {
            "SqlType": "VARCHAR(16)",
            "Name": "SECTOR",
            "Mapping": "$.SECTOR"
        },
        {
            "SqlType": "TINYINT",
            "Name": "CHANGE",
            "Mapping": "$.CHANGE"
        },
        {
            "SqlType": "DECIMAL(5,2)",
            "Name": "PRICE",
            "Mapping": "$.PRICE"
        }
    ],
    "RecordFormat": {
        "MappingParameters": {
            "JSONMappingParameters": {
                "RecordRowPath": "$"
            }
        },
        "RecordFormatType": "JSON"
    },
    "RecordEncoding": "UTF-8"
}         
            

CSV 입력 스키마 예

다음 예는 CSV(쉼표로 분리된 값) 형식 스키마에 대한 InputSchema 값의 형식을 보여 줍니다.

"InputSchema": {
    "RecordColumns": [
        {
            "SqlType": "VARCHAR(16)",
            "Name": "LastName"
        },
        {
            "SqlType": "VARCHAR(16)",
            "Name": "FirstName"
        },
        {
            "SqlType": "INTEGER",
             "Name": "CustomerId"
        }
    ],
    "RecordFormat": {
        "MappingParameters": {
            "CSVMappingParameters": {
                "RecordColumnDelimiter": ",",
                "RecordRowDelimiter": "\n"
            }
        },
        "RecordFormatType": "CSV"
    },
    "RecordEncoding": "UTF-8"
}
                    
                

JSON 데이터 유형을 SQL 데이터 유형으로 매핑하기

JSON 데이터 유형은 애플리케이션의 입력 스키마에 따라 상응하는 SQL 데이터 유형으로 변환됩니다. 지원되는 SQL 데이터 형식에 관한 자세한 설명은 데이터 유형을 참조하십시오. Amazon Kinesis Data Analytics는 다음 규칙에 따라 JSON 데이터 유형을 SQL 데이터 유형으로 변환합니다.

Null 리터럴

JSON 입력 스트림에 있는 null 리터럴("City":null)은 대상의 데이터 유형에 상관없이 SQL null로 변환됩니다.

부울 리터럴

JSON 입력 스트림에 있는 부울 리터럴("Contacted":true)은 다음과 같이 SQL 데이터로 변환됩니다.

숫자

JSON 입력 스트림에 있는 숫자 리터럴("CustomerId":67321)은 다음과 같이 SQL 데이터로 변환됩니다.

String

JSON 입력 스트림에 있는 문자열 값("CustomerName":"John Doe")은 다음과 같이 SQL 데이터로 변환됩니다.

어레이 또는 객체

JSON 입력 스트림에 있는 어레이 또는 객체가 다음과 같이 SQL 데이터로 변환됩니다.

JSON 어레이의 예는 JSONPath로 작업하기를 참조하십시오.

관련 항목