ストリームの時間窓集計を実行する

取り込み方式、データの到着順、再処理、配信先、運用負荷の違いを整理する。

各レコードを単独で変換するステートレスなLambda処理だけを使う

ステートレス処理はレコード間の状態を保持せず、単一イベントの変換に向く。

状態を保持するストリーム処理で時間窓を定義する

ステートフルなストリーム処理は時間窓やキーごとの中間状態を扱える。

各イベントをS3へ保存し、毎回全履歴を読み込んで集計する

S3の全履歴読み込みはバッチ分析に向くが、継続する時間窓集計には遅延がある。

イベントをCloudTrailへ送って時間窓集計する

CloudTrailはAWS API操作を記録する監査サービスで、任意イベントの窓集計基盤ではない。