あるサイバーセキュリティ企業は、異常がないかリアルタイムで受信セキュリティイベントをスコアリングし、後で分析するために異常スコアをデータレイクに保存する必要があります。データが取り込まれたときにリアルタイムで異常スコアリングを実行し、その結果をS3に永続化するための最も効率的な設計は何ですか？

このソリューションは、リアルタイム処理と永続化の要件を最も効率的に満たします。Kinesis Data Firehoseはストリームデータを簡単に取り込み、Kinesis Data Analyticsはリアルタイムで異常検出アルゴリズム（Random Cut Forestは異常検出に最適）を適用できます。処理された結果は、再度Kinesis Data Firehoseを介してS3に直接永続化でき、追加のETLやデータ転送ステップが不要です。 EMR上のSpark StreamingとHDFSはリアルタイム処理は可能ですが、HDFSはデータレイクの永続化先としてはS3よりも管理が複雑でコストがかかる可能性があります。S3への取り込み後にAWS BatchやAWS Glueジョブを使用するオプションは、リアルタイム処理ではなくバッチ処理に適しており、要件を満たしません。