AWS
Real-time Streaming (Kinesis + Lambda)
Kinesis Data Streams + Lambda + Kinesis Data Firehose + OpenSearch の リアルタイムストリーミング構成。1秒未満のレイテンシでストリームデータを集計・変換し、OpenSearchによる全文検索・リアルタイムダッシュボードを提供します。
アーキテクチャ構成図
プロデューサー
アプリ / IoTデバイス / ClickStream
Kinesis Data Streams
シャード分割・順序保証
Lambda / Kinesis Data Analytics
ウィンドウ集計
Kinesis Data Firehose
S3 / Redshift / OpenSearch配信
Amazon OpenSearch Service
全文検索・可視化
CloudWatch / Grafana
モニタリング
↑ リクエスト / データの流れ（上から下）
採用サービス構成
- ストリーミング
- Kinesis Data Streams
- 処理
- Lambda / Kinesis Data Analytics
- デリバリー
- Kinesis Data Firehose
- 検索
- Amazon OpenSearch Service
代表的なユースケース
- ✓決済不正検知 (リアルタイムスコアリング)
- ✓サービス監視ダッシュボード (1秒更新)
- ✓クリックストリーム分析
- ✓IoTセンサーデータのリアルタイム集計
このパターンを選ぶ判断基準
1秒未満のリアルタイム集計やウィンドウ処理が必要な場合。Kinesis Data Analyticsを使えばSQLライクなクエリでストリーム処理を記述できます。