1.2標準
Kinesisのクリックイベントを5分窓でユーザー別集計する。
到着したイベントを保持し、窓の終了や遅延イベントを考慮して集計結果を更新する。
最も適切な処理基盤はどれか。
× 不正解
Managed Service for Apache Flinkは状態付きストリーム処理と時間窓を実行できる。遅延イベント、チェックポイント、状態復元を設計する。
詳細解説
正しいAmazon Managed Service for Apache Flink
状態を保持するストリーム処理と時間窓を定義し、継続的に集計できる。
状態を保持するストリーム処理と時間窓を定義し、継続的に集計できる。
誤り単一のS3 SELECTクエリ
保存済みオブジェクトのクエリであり、継続ストリームの時間窓状態を保持しない。
保存済みオブジェクトのクエリであり、継続ストリームの時間窓状態を保持しない。
誤りCloudTrail Lake
監査イベントの分析サービスで、任意のクリックストリームの状態付き窓集計基盤ではない。
監査イベントの分析サービスで、任意のクリックストリームの状態付き窓集計基盤ではない。
誤りS3ライフサイクルルール
オブジェクトの移行・削除を行い、ストリーム集計を実行しない。
オブジェクトの移行・削除を行い、ストリーム集計を実行しない。
実際に確かめる
一時的な検証環境で実行できる例です。
Amazon Managed Service for Apache Flinkの状態管理、時間窓、チェックポイントの公式説明を確認する。期待される結果
バッチクエリと状態付きストリーム集計の違いを説明できる。理解のポイント
- Apache Flink
- 時間窓
- 状態管理
- チェックポイント
確認時の注意
- 確認環境: AWS公式DEA-C01試験ガイドと各サービスの公式ドキュメントの確認
- AWS公式DEA-C01 Domain 1・Task 1.2と各サービスの公式ドキュメントを確認する。
基礎のおさらい
時間窓
イベント時刻・処理時刻、遅延許容、窓の終了条件を明示して集計結果を定義する。
状態復元
チェックポイントと再起動時の状態復元を使い、障害後の重複や欠損を検証する。
問題IDAWS-DEA-039
確認環境AWS公式DEA-C01試験ガイドと各サービスの公式ドキュメントの確認
最終技術確認2026-08-20
誤り・権利侵害を報告