DEAデータの取り込みと変換

あるスポーツ配信サービスはライブ中継中に視聴者のバッファリングイベントを毎秒数万件収集しており、30秒ローリングウィンドウでバッファリング率が10%を超えた配信ノードを検知してCDN設定を自動変更したい。処理遅延5秒以内が要件で、開発チームはApache Flinkに習熟している。最も適切なアーキテクチャは?

A
Amazon Data FirehoseでS3に5秒間隔でバッファリングし、S3イベントトリガーのLambdaで集計してCDN APIを呼び出す
Amazon Data FirehoseはS3書き込みとS3イベントトリガーの連鎖により遅延が累積し、5秒以内のレイテンシー保証が困難になる。
B
Amazon Managed Service for Apache Flinkでローリングウィンドウ集計を実装し、Lambda経由でCDN設定を動的に変更する
✓ 正解
Amazon Managed Service for Apache Flinkはローリングウィンドウをネイティブサポートし、ミリ秒〜秒オーダーの低遅延処理でCDN設定変更まで一貫して処理できる。
C
Kinesis Data StreamsをソースとするLambda関数内で集計ロジックを実装し、CloudFront APIでCDN設定を変更する
LambdaはステートレスなためInvocation間で30秒ローリングウィンドウの集計状態を維持できず、ウィンドウ集計に適さない。
D
Amazon EMRのSpark Structured Streamingでデータを読み込み、ウィンドウ集計結果をLambda関数でCDN APIに転送する
Amazon EMR Spark Structured Streamingは機能的に要件を満たすが、クラスター管理が必要でManaged Flinkより運用負荷が高い。

解説

Amazon Managed Service for Apache Flinkはステートフルなウィンドウ集計をネイティブサポートし、エンドツーエンドの遅延を数秒以内に抑えられる。チームのFlink習熟度を活かしつつサーバーレスで運用負荷を最小化できる。

ドメイン別正答率・予想スコアでリアルタイムに実力把握

無限ノックでDEAを徹底対策。全問AI生成のオリジナル問題。

無料で演習を始める →
DEA の問題一覧に戻る