本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
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 的詳細資訊,請參閱下列內容: