AddApplicationInput - 阿帕奇 Flink 的 Amazon 託管服務(以前為阿帕奇 Flink 的 Amazon Kinesis Data Analytics)

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

AddApplicationInput

將串流來源新增至以 SQL 為基礎的 Kinesis Data Analytics 應用程式。

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

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

請求語法

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

請求參數

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

ApplicationName

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

類型:字串

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

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

必要:是

CurrentApplicationVersionId

您的應用程式的目前版本。您必須提供ApplicationVersionID或。您可ConditionalToken以使用DescribeApplication作業來尋找目前的應用程式版本。

類型:Long

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

必要:是

Input

Input加入的。

類型:Input 物件

必要:是

回應語法

{ "ApplicationARN": "string", "ApplicationVersionId": number, "InputDescriptions": [ { "InAppStreamNames": [ "string" ], "InputId": "string", "InputParallelism": { "Count": number }, "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "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" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "string" }, "KinesisFirehoseInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "KinesisStreamsInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "NamePrefix": "string" } ] }

回應元素

如果動作成功,則服務傳回 HTTP 200 回應。

服務會傳回下列 JSON 格式的資料。

ApplicationARN

應用程式的 Amazon Resource Name (ARN)。

類型:字串

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

模式:arn:.*

ApplicationVersionId

提供目前的應用程式版本。

類型:Long

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

InputDescriptions

描述應用程式輸入組態。

類型:InputDescription 物件陣列

錯誤

CodeValidationException

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

HTTP 狀態碼:400

ConcurrentModificationException

因應用程式並行修改而擲回的例外狀況。此錯誤可能是因為嘗試修改應用程式而不使用目前的應用程式 ID 所致。

HTTP 狀態碼:400

InvalidArgumentException

指定的輸入參數值無效。

HTTP 狀態碼:400

InvalidRequestException

請求 JSON 對該操作無效。

HTTP 狀態碼:400

ResourceInUseException

該應用程序不適用於此操作。

HTTP 狀態碼:400

ResourceNotFoundException

找不到指定的應用程式。

HTTP 狀態碼:400

另請參閱

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