Change streams(変更ストリーム)とは何ですか?

Question

Accepted Answer

**Change streams**(変更ストリーム)を使うと、アプリケーションは MongoDB のデータの **リアルタイムな変更を購読** できます ── ドキュメントが挿入・更新・削除されたときに通知を受け取れます。これにより、データベースをポーリングすることなく、リアクティブでイベント駆動の機能(リアルタイム更新、同期、トリガー)を実現できます。レプリカセットの oplog の上に構築されています。

## 変更を監視する

```js
// watch a collection for changes — get notified in real time
const changeStream = db.collection("orders").watch();

changeStream.on("change", (change) => {
  console.log(change.operationType);   // "insert", "update", "delete", "replace"
  console.log(change.fullDocument);     // the changed document (for inserts/updates)
  // react: push to websockets, update a cache, trigger a workflow, etc.
});
```

変更ストリームは各変更(挿入/更新/削除)についてイベントを発行し、何が変わったかの詳細を伴います ── そのためアプリケーションはリアルタイムに反応できます。

## フィルタリングと再開

```js
// watch only specific changes with an aggregation pipeline filter
db.collection("orders").watch([
  { $match: { operationType: "insert", "fullDocument.status": "urgent" } }
]);

// resume from where you left off (resilient to disconnections)
db.collection("orders").watch([], { resumeAfter: lastChangeToken });
```

変更を **フィルタリング**(特定の操作やドキュメントのみを監視)したり、切断後に **再開**(resume token を使う)したりできます ── これにより変更ストリームは堅牢になります。

## 一般的なユースケース

```text
✓ REAL-TIME features — push live updates to clients (websockets) when data changes
✓ SYNCING — keep a cache, search index (Elasticsearch), or another system in sync
✓ EVENT-DRIVEN architecture — trigger workflows/notifications on data changes
✓ AUDITING — log changes; analytics on data modifications
→ All WITHOUT polling the database repeatedly (efficient, real-time)
```

## Change streams とポーリングの比較

```text
❌ POLLING — repeatedly query "what changed?" → inefficient, latency, load on the DB
✅ CHANGE STREAMS — the database PUSHES changes to you in real time → efficient, instant
→ The right way to react to data changes (requires a replica set).
```

## なぜ重要なのか

Change streams は **リアルタイムでリアクティブなイベント駆動アプリケーション** を構築するための価値ある MongoDB の機能です。したがって、ライブデータへのリアクティビティを必要とする現代的なアプリケーションにとって、これを理解することは有用なシニアレベルの知識です。

中核的な価値は、アプリケーションが **データの変更にリアルタイムで反応** できるようにすること ── ドキュメントの挿入・更新・削除時にプッシュ通知を受け取ること ── にあり、これが重要な機能を支えます。**リアルタイム機能**(データ変更時に websocket 経由でクライアントにライブ更新をプッシュする ── 共同編集アプリ、ダッシュボード、通知でよくある要件)、**同期**(キャッシュ、Elasticsearch のような検索インデックス、その他のシステムをデータ変更に合わせて MongoDB と一貫させる)、**イベント駆動アーキテクチャ**(データ変更時にワークフロー、通知、処理をトリガーする)、そして **監査** です。

重要な利点は、これらすべてを **ポーリングなしで** 行えることです ── 変更ストリームは、データベースが変更をアプリケーションへ即座かつ効率的に *プッシュ* できるようにし、「何が変わったか?」を繰り返し問い合わせる無駄が多く遅延の大きいパターン(データベースに負荷をかけ、遅延を伴う)を置き換えます。

コレクションの監視方法、変更のフィルタリング(関連する操作/ドキュメントのみ)、切断後の再開(堅牢性のための resume token の利用)を理解しておけば、実践的な使い方をカバーできます。

変更ストリームがレプリカセットを必要とすることを知っておくことも関連します。

リアルタイムのリアクティビティとシステム間の同期はますます重要なアプリケーション要件となっており、変更ストリームは MongoDB のデータ変更に反応する効率的なプッシュベースの手段(ポーリングよりはるかに優れている)を提供します。したがって、change streams ── その役割、ユースケース(リアルタイム機能、同期、イベント駆動処理)、再開/フィルタの機能、そしてポーリングに対する優位性 ── を理解することは、現代的でリアクティブな MongoDB アプリケーションを構築するための価値あるシニアレベルの知識です。これはデータ変更にリアルタイムで応答するというよくある要件に役立つ機能であり、MongoDB を用いたイベント駆動かつリアルタイムなアプリケーションパターンの理解を反映するトピックです。