新規プロジェクトでは、Kinesis Data Analytics for SQL よりも 新しい Managed Service for Apache Flink Studio を使用することをお勧めします。Managed Service for Apache Flink Studio は、使いやすさと高度な分析機能を兼ね備えているため、高度なストリーム処理アプリケーションを数分で構築できます。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
AddApplicationInput
注記
このドキュメントの対象は、SQL アプリケーションのみがサポートされる Amazon Kinesis Data Analytics API のバージョン 1 です。バージョン 2 の API では、SQL および Java アプリケーションがサポートされます。バージョン 2 の詳細については、Amazon Kinesis Data Analytics API V2 のドキュメントを参照してください。
Amazon Kinesis アプリケーションにストリーミングソースを追加します。概念については、「アプリケーション入力の設定」を参照してください。
ストリーミングソースは、アプリケーションの作成時に追加することも、アプリケーションの作成後にこのオペレーションを使用して追加することもできます。詳細については、API リファレンスの「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 オペレーションを使用して、現在のアプリケーションバージョンを見つけることができます。
型: 長整数
有効範囲: 最小値は 1 です。最大値は 999999999 です。
必須: はい
- Input
-
追加する入力。
型: Input オブジェクト
必須: はい
レスポンス要素
アクションが成功した場合、サービスは空の HTTP 本文を持つ HTTP 200 レスポンスを返します。
エラー
- CodeValidationException
-
ユーザー指定のアプリケーションコード (クエリ) が無効です。これは単純な構文エラーである可能性があります。
HTTP ステータスコード：400
- ConcurrentModificationException
-
アプリケーションへの同時変更の結果としてスローされる例外。例えば、2 人の個人が同じアプリケーションを同時に編集しようとしています。
HTTP ステータスコード：400
- InvalidArgumentException
-
指定された入力パラメータ値が無効です。
HTTP ステータスコード：400
- ResourceInUseException
-
このオペレーションではアプリケーションを使用できません。
HTTP ステータスコード：400
- ResourceNotFoundException
-
指定されたアプリケーションが見つかりません。
HTTP ステータスコード：400
- UnsupportedOperationException
-
指定されたパラメータがサポートされていないか、指定されたリソースがこのオペレーションに対して有効でないため、リクエストは拒否されました。
HTTP ステータスコード：400
以下の資料も参照してください。
言語固有の AWS SDK のいずれかでこの API を使用する方法の詳細については、以下を参照してください。
