SQL エディタの使用 - Amazon Kinesis Data Analytics for SQL Applications デベロッパーガイド

慎重に検討した結果、アプリケーションの 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 エディタの使用

次に、SQLエディタのセクションとそれぞれの仕組みについて説明します。SQL エディタでは、独自のコードを自分で作成することも、テンプレートSQLから追加 を選択することもできます。SQL テンプレートは、一般的な Amazon Kinesis Data Analytics アプリケーションの記述に役立つサンプルSQLコードを提供します。このガイドのサンプルアプリケーションでは、これらのテンプレートの一部を使用します。詳細については、「Kinesis Data Analytics for SQL の例」を参照してください。

リアルタイム分析タブとアプリケーション内ストリームを示すSQLエディタのスクリーンショット。

[Source Data] タブ

[Source data] タブは、ストリーミングソースを識別します。また、このソースでマッピングされ、アプリケーション入力設定として提供されるアプリケーション内入力ストリームを識別します。

ストリーミングソースが強調表示されたソースデータタブを示すSQLエディタのスクリーンショット。

Amazon Kinesis Data Analytics は以下のタイムスタンプを提供しているため、入力設定で明示的にマッピングを指定する必要はありません。

  • ROWTIME – アプリケーション内ストリームの各行には、 という特別な列がありますROWTIME。この列は、Kinesis Data Analytics が最初のアプリケーション内ストリームに行を挿入したときのタイムスタンプです。

  • Approximate_Arrival_Time – ストリーミングソースのレコードには Approximate_Arrival_Timestamp 列が含まれています。これは、ストリーミングソースが正常に関連レコードを受信して保存したときに設定されるおおよその到達タイムスタンプです。Kinesis Data Analytics はこの列を Approximate_Arrival_Time としてアプリケーション内入力ストリームにフェッチします。Amazon Kinesis Data Analytics は、ストリーミングソースにマッピングされたアプリケーション内入力ストリームでのみこの列を提供します。

これらのタイムスタンプ値は時間ベースのウィンドウクエリで役に立ちます。詳細については、「ウィンドウクエリ」を参照してください。

[Real-Time Analytics] タブ

[Real-time analytics] タブに、アプリケーションコードによって作成されるすべてのアプリケーション内ストリームが表示されます。このストリームのグループには、Amazon Kinesis Data Analytics がすべてのアプリケーションで提供するエラーストリーム (error_stream) が含まれます。

アプリケーション内ストリームが強調表示されたリアルタイム分析タブを示すSQLエディタのスクリーンショット。

[送信先] タブ

[送信先] タブでは、アプリケーション出力を設定して、外部宛先へのアプリケーション内ストリームを維持することができます。任意のアプリケーション内ストリームのデータを外部宛先で永続化するように出力を設定できます。詳細については、「アプリケーション出力の設定」を参照してください。