ストリーミング処理とは？
すとりーみんぐしょり
ストリーミング処理とは、データを生成と同時に逐次的に処理していく方式のことです。
ストリーミング処理とは、データを一括で蓄積してから処理するのではなく、データが発生したタイミングで即座に読み取り・変換・分析を行うデータ処理方式です。川の流れのようにデータを連続的に扱うことから「ストリーム」と呼ばれます。
仕組みとしては、データソース（センサー、ログ、SNSの投稿など）からデータが到着するたびにパイプラインがそのデータを受け取り、フィルタリングや集計などの処理を施したうえで下流のシステムへと引き渡します。代表的なプラットフォームには Apache Kafka や Apache Flink、Amazon Kinesis などがあります。
ストリーミング処理が活躍する場面の例：
- リアルタイムの不正検知（クレジットカードの異常取引を即時検出）
- IoTセンサーデータの監視（工場設備の異常を即座にアラート）
- SNSのトレンド分析（投稿を受信しながらリアルタイム集計）
- オンラインゲームのスコアランキングのリアルタイム更新
バッチ処理と比較すると、処理の遅延（レイテンシ）が極めて小さい点が最大の強みです。一方で、システム構成が複雑になりやすく、ウィンドウ処理（時間範囲での集計）やステート管理に工夫が必要です。近年はビジネスのリアルタイム意思決定ニーズの高まりとともに採用が急速に広がっています。
使い方・例文
ECサイトでユーザーが商品を閲覧するたびに行動ログをストリーミング処理し、数秒以内にレコメンドエンジンを更新するといった場面で使われます。
この用語をシェア
最終更新: