在仔細考慮之後，我們決定在兩個步驟中停止 Amazon Kinesis Data Analytics for SQL 應用程式：

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 應用程式終止。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

設定應用程式輸入

您的 Amazon Kinesis Data Analytics 應用程式可以從單一串流來源接收輸入，並選擇性地使用一個參考資料來源。如需詳細資訊，請參閱 Amazon Kinesis Data Analytics for SQL 應用程式：運作方式。本主題中的各節說明應用程式輸入來源。

設定串流來源

當您建立應用程式時，就要指定串流來源。您也可以在建立應用程式後修改輸入。Amazon Kinesis Data Analytics 支援您的應用程式採用下列串流來源：

Kinesis Data Analytics 會持續輪詢串流來源是否有新資料，並根據輸入組態將其導入應用程式內串流。

應用程式碼會查詢應用程式內串流 。作為輸入組態的一部分，您提供以下項目：

您可以在 Amazon Kinesis Data Analytics 主控台中建立應用程式並設定輸入。然後，控制台進行必要的 API 呼叫。在建立新應用程式 API，或將輸入組態新增至現有應用程式時，您可以設定應用程式輸入。如需詳細資訊，請參閱 CreateApplication 及 AddApplicationInput。以下是 Createapplication API 請求主體的輸入配置部分：

 "Inputs": [
        {
            "InputSchema": {
                "RecordColumns": [
                    {
                        "Mapping": "string",
                        "Name": "string",
                        "SqlType": "string"
                    }
                ],
                "RecordEncoding": "string",
                "RecordFormat": {
                    "MappingParameters": {
                        "CSVMappingParameters": {
                            "RecordColumnDelimiter": "string",
                            "RecordRowDelimiter": "string"
                        },
                        "JSONMappingParameters": {
                            "RecordRowPath": "string"
                        }
                    },
                    "RecordFormatType": "string"
                }
            },
            "KinesisFirehoseInput": {
                "ResourceARN": "string",
                "RoleARN": "string"
            },
            "KinesisStreamsInput": {
                "ResourceARN": "string",
                "RoleARN": "string"
            },
            "Name": "string"
        }
    ]

配置參考來源

您也可以選擇將參考資料來源新增至現有的應用程式，以豐富來自串流來源的資料。您必須將參考資料作為物件存放在 S3 儲存貯體中。Amazon Kinesis Data Analytics 會在應用程式啟動時讀取 Amazon S3 物件，並建立應用程式內參考資料表。接著，您的應用程式程式碼就可以將其與應用程式內串流聯結。

您可以使用支援的格式 (CSV、JSON) 將參考資料存放在 Amazon S3 物件中。舉例來說，假設您的應用程式對股票訂單執行分析。假設串流來源採用以下記錄格式：

Ticker, SalePrice, OrderId

AMZN     $700        1003
XYZ      $250        1004
...

在這種情況下，您可以考慮維護一個參考資料來源，以提供每個股票股票代號的詳細資料，例如公司名稱。

Ticker, Company
AMZN, Amazon
XYZ, SomeCompany
...

您可以使用 API 或主控台新增應用程式參考資料來源。Amazon Kinesis Data Analytics 提供下列 API 動作來管理參考資料來源：

如需使用主控台新增任務的詳細資訊，請參閱 範例：將參考資料新增至 Kinesis Data Analytics 應用程式。

注意下列事項：

假設在 Kinesis Data Analytics 建立應用程式內參考資料表之後，您想要重新整理資料。也許你更新了 Amazon S3 物件，或者你想使用不同的 Amazon S3 物件。在此情況下，您可以明確呼叫UpdateApplication，或選擇主控台中的動作、同步化參考資料表。Kinesis Data Analytics 不會自動重新整理應用程式內參考資料表。

您可以建立為參考資料來源的 Amazon S3 物件大小有其限制。如需詳細資訊，請參閱 限制。如果物件大小超過限制，Kinesis Data Analytics 將無法載入資料。應用程式狀態會顯示為執行中，但不會讀取資料。

當新增參考資料來源時，您要提供以下資訊：

以下顯示 AddApplicationReferenceDataSource API 請求中的請求內文。

{
    "applicationName": "string",
    "CurrentapplicationVersionId": number,
    "ReferenceDataSource": {
        "ReferenceSchema": {
            "RecordColumns": [
                {
                    "IsDropped": boolean,
                    "Mapping": "string",
                    "Name": "string",
                    "SqlType": "string"
                }
            ],
            "RecordEncoding": "string",
            "RecordFormat": {
                "MappingParameters": {
                    "CSVMappingParameters": {
                        "RecordColumnDelimiter": "string",
                        "RecordRowDelimiter": "string"
                    },
                    "JSONMappingParameters": {
                        "RecordRowPath": "string"
                    }
                },
                "RecordFormatType": "string"
            }
        },
        "S3ReferenceDataSource": {
            "BucketARN": "string",
            "FileKey": "string",
            "ReferenceRoleARN": "string"
        },
        "TableName": "string"
    }
}