AddApplicationInput - 適用於 SQL 應用程式的 Amazon Kinesis Data Analytics 開發人員指南

針對新專案,我們建議您優先選擇新的 Managed Service for Apache Flink Studio,而非 Kinesis Data Analytics for SQL 應用程式。Managed Service for Apache Flink Studio 易於使用且具備進階分析功能,可讓您在幾分鐘內建置複雜的串流處理應用程式。

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

AddApplicationInput

注意

此文件適用於 Amazon Kinesis Data Analytics API 第 1 版,僅支援 SQL 應用程式。第 2 版的 API 則支援 SQL 和 Java 應用程式。如需第 2 版的詳細資訊,請參閱 Amazon Kinesis Data Analytics API V2 文件

將串流來源新增至您的 Amazon Kinesis 應用程式。如需概念資訊,請參閱設定應用程式輸入

您可以在建立應用程式時新增串流來源,也可以在建立應用程式後使用此作業來新增串流來源。如需詳細資訊,請參閱CreateApplication

任何組態更新,包括使用此操作新增串流資源,都會產生應用程式的新版本。您可以使用此DescribeApplication作業來尋找目前的應用程式版本。

這項操作需要許可來執行 kinesisanalytics:AddApplicationInput 動作。

請求語法

{ "ApplicationName": "string", "CurrentApplicationVersionId": number, "Input": { "InputParallelism": { "Count": number }, "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string", "RoleARN": "string" } }, "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" }, "NamePrefix": "string" } }

請求參數

請求接受採用 JSON 格式的下列資料。

ApplicationName

要新增串流來源的現有 Amazon Kinesis Analytics 應用程式名稱。

類型:字串

長度限制:長度下限為 1。長度上限為 128。

模式:[a-zA-Z0-9_.-]+

必要:是

CurrentApplicationVersionId

您的 Amazon Kinesis Analytics 應用程式的最新版本。您可以使用此DescribeApplication作業來尋找目前的應用程式版本。

類型:Long

有效範圍:最小值為 1。最大值為 999999999。

必要:是

Input

要添加的輸入

類型:Input 物件

必要:是

回應元素

如果動作成功,則服務會傳回具空 HTTP 內文的 HTTP 200 回應。

錯誤

CodeValidationException

使用者提供的應用程式碼 (查詢) 無效。這可能是一個簡單的語法錯誤。

HTTP 狀態碼:400

ConcurrentModificationException

並行修改應用程式的結果拋出例外。例如,有兩個人嘗試同時編輯相同的應用程式。

HTTP 狀態碼:400

InvalidArgumentException

指定的輸入參數值無效。

HTTP 狀態碼:400

ResourceInUseException

應用程式不適用於此作業。

HTTP 狀態碼:400

ResourceNotFoundException

找不到指定的應用程式。

HTTP 狀態碼:400

UnsupportedOperationException

請求被拒絕,因為指定的參數不受支持,或指定的資源對此操作無效。

HTTP 狀態碼:400

另請參閱

如需在其中一個特定語言 AWS SDK 中使用此 API 的詳細資訊,請參閱下列內容: