慎重に検討した結果、2 つのステップでSQLアプリケーションの Amazon Kinesis Data Analytics を中止することにしました。

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 の停止」を参照してください。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

SQL 入力列へのストリーミングソース要素のマッピング

Amazon Kinesis Data Analytics で、標準 SQL を使用して JSON 形式または CSV 形式でストリーミングデータを処理および分析します。

入力ストリームの設定方法の詳細については、「アプリケーション入力の設定」を参照してください。

SQL 列への JSON データのマッピング

AWS Management Console または Kinesis Data Analytics API を使用して JSON 要素を入力列にマッピングすることができます。

JSON 要素をアプリケーション内の入力ストリームの列にマッピングするには、スキーマで、以下の情報が各列に必要です。

API を使用する場合

ストリーミングソースから入力列に要素をマッピングするには、Kinesis Data Analytics API (CreateApplication) のアクションを使用できます。アプリケーション内ストリームを作成するには、SQL で使用するスキーマ化されたバージョンにデータを変換するスキーマを指定します。この CreateApplication アクションでは、単一のストリーミングソースから入力を受信するようにアプリケーションを設定します。JSON 要素または CSV 列を SQL 列にマッピングするには、「RecordColumnオブジェクトSourceSchema」を RecordColumns 配列内に作成します。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 データに変換されます。

文字列

JSON 入力ストリームの文字列値 (例: "CustomerName":"John Doe") は、SQL データを次のように変換します。

配列またはオブジェクト

JSON 入力ストリームの配列またはオブジェクトは、次のように SQL データに変換されます。

JSON 配列の例については、「JSONPath の操作」を参照してください。

関連トピック