例: アプリケーション内エラーストリームの確認 - 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 の中止」を参照してください。

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

例: アプリケーション内エラーストリームの確認

Amazon Kinesis Data Analytics は作成した各アプリケーションのアプリケーション内エラーストリームを提供します。アプリケーションが処理できない行は、このエラーストリームに送信されます。エラーストリームのデータを外部宛先で永続化して、調査できるようにすることを検討してください。

コンソールで次の演習を実行します。これらの例では、検出プロセスで推測されたスキーマを編集して入力設定にエラーを発生させ、次にエラーストリームに送信される行を検証します。

解析エラーの確認

この実習では、解析エラーを確認します。

  1. Kinesis Data Analytics の開始方法の実習に従って Kinesis Data Analytics アプリケーションを作成します。

  2. アプリケーション詳細ページで、[ストリーミングデータの接続] を選択します。

  3. 「使用開始」実習を行った場合は、アカウントにデモストリーム (kinesis-analytics-demo-stream) があります。[ソースへの接続] ページで、このデモストリームを選択します。

  4. Kinesis Data Analytics はデモストリームからサンプルを取得して、作成するアプリケーション内入力ストリームのスキーマを推測します。コンソールの [Formatted stream sample] タブに推測スキーマとサンプルデータが表示されます。

  5. 次に、スキーマを編集して列タイプを変更し、解析エラーを発生させます。[Edit schema] を選択します。

  6. TICKER_SYMBOL の列タイプを VARCHAR(4) から INTEGER に変更します。

    作成されたアプリケーション内スキーマの列のタイプが無効なため、Kinesis Data Analytics は、アプリケーション内ストリームにデータを持ち込むことはできません。代わりに、行がエラーストリームに送信されます。

  7. [Save schema] を選択します。

  8. [Refresh schema samples] を選択します。

    [Formatted stream] 例には行がないことに注意してください。ただし、[Error stream] タブには、エラーメッセージ付きのデータが表示されます。[Error stream] タブに、アプリケーション内エラーストリームに送信されたデータが表示されます。

    列のデータ型を変更したので、Kinesis Data Analytics はアプリケーション内入力ストリームにデータを持ち込むことができませんでした。代わりに、エラーストリームにデータが送信されました。

ゼロ除算エラーの導入

この練習では、ランタイムエラー (ゼロ除算) を導入するようにアプリケーションコードを更新します。結果が書き込まれるはずの DESTINATION_SQL_STREAM アプリケーション内ストリームにではなく、このアプリケーション内エラーストリームに Amazon Kinesis Data Analytics が結果の行を送信することに注意してください。

  1. Kinesis Data Analytics の開始方法の実習に従って Kinesis Data Analytics アプリケーションを作成します。

    [Real-time analytics] タブで次のとおり結果を確認します。

    Sour

  2. アプリケーションコードで SELECT ステートメントを更新してゼロ除算を発生させます。その例を次に示します。

    SELECT STREAM ticker_symbol, sector, change, (price / 0) as ProblemColumn
FROM "SOURCE_SQL_STREAM_001"
WHERE sector SIMILAR TO '%TECH%';

  3. アプリケーションを実行します。

    ゼロ除算ランタイムエラーが発生するため、Kinesis Data Analytics は結果を DESTINATION_SQL_STREAM に書き込む代わりに、アプリケーション内エラーストリームに行を送信します。[リアルタイム分析] タブで、エラーストリームを選択すると、アプリケーション内ストリームの行が表示されます。