アプリケーション出力の設定 - Amazon Kinesis Data Analytics for SQL Applications デベロッパーガイド
を使用した出力の作成 AWS CLI

慎重に検討した結果、アプリケーションの Amazon Kinesis Data Analytics は 2 つのステップ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 Applications の中止」を参照してください。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

アプリケーション出力の設定

アプリケーションコードでは、SQLステートメントの出力を 1 つ以上のアプリケーション内ストリームに書き込みます。オプションで、出力設定をアプリケーションに追加できます。 は、Amazon Kinesis データストリーム、Firehose 配信ストリーム、または AWS Lambda 関数などの外部送信先にアプリケーション内ストリームに書き込まれたすべてを保持します。

アプリケーション出力の永続化に使用できる外部宛先の数には制限があります。詳細については、「制限」を参照してください。

注記

エラーを精査するためにアプリケーション内エラーストリームのデータを永続化する外部宛先は、1 つにすることをお勧めします。

これらの出力設定で、以下を指定します。

  • アプリケーション内ストリーム名 – 外部宛先で永続化するストリームです。

    Kinesis Data Analytics は、出力設定で指定されたアプリケーション内ストリームを検索します。(ストリーム名は大文字と小文字が区別され、正確に一致する必要があることに注意してください)。アプリケーションコードがこのアプリケーション内ストリームを作成することを確認してください。

  • 外部送信先 – Kinesis データストリーム、Firehose 配信ストリーム、または Lambda 関数にデータを保持できます。ストリームまたは関数の Amazon リソースネーム (ARN) を指定します。また、Kinesis Data Analytics がユーザーに代わってストリームまたは関数に書き込むために引き受けることができるIAMロールも指定します。外部送信先に書き込むときに使用するレコード形式 (JSON、CSV) を Kinesis Data Analytics に記述します。

Kinesis Data Analytics でストリーミングまたは Lambda 宛先に書き込むことができない場合、サービスは無限に試行を続けます。これはバックプレッシャーを生み出し、アプリケーションに遅延が生じます。この問題が解決しない場合、アプリケーションは最終的に新しいデータの処理を停止します。Kinesis Data Analytics Metrics をモニタリングし、障害のアラームを設定できます。メトリクスとアラームの詳細については、「Amazon CloudWatch メトリクスの使用」と「Amazon CloudWatch アラームの作成」を参照してください。

AWS Management Consoleを使用してアプリケーション出力を設定できます。コンソールは をAPI呼び出して設定を保存します。

を使用した出力の作成 AWS CLI

このセクションでは、CreateApplication または AddApplicationOutput オペレーションのリクエストボディの Outputs セクションを作成する方法について説明します。

Kinesis ストリーム出力を作成する

次のJSONフラグメントは、Amazon Kinesis データストリーム送信先を作成するためのCreateApplicationリクエスト本文Outputsのセクションを示しています。

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisStreamsOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
 
]

Firehose 配信ストリーム出力の作成

次のJSONフラグメントは、Amazon Data Firehose 配信ストリームの送信先を作成するためのCreateApplicationリクエスト本文Outputsのセクションを示しています。

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisFirehoseOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]

Lambda 関数出力を作成する

次のJSONフラグメントは、 AWS Lambda 関数の送信先を作成するためのCreateApplicationリクエスト本文Outputsのセクションを示しています。

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "LambdaOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]