Qu'est-ce que les change streams ?

Question

Accepted Answer

**Les change streams** permettent aux applications de **s'abonner aux changements en temps réel** dans les données MongoDB — en recevant des notifications quand des documents sont insérés, modifiés ou supprimés. Ils permettent des fonctionnalités réactives et événementielles (mises à jour en temps réel, synchronisation, déclencheurs) sans interroger la base de données. Construits sur l'oplog du replica set.

## Regarder les changements

```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.
});
```

Un change stream émet un événement pour chaque changement (insertion/modification/suppression), avec des détails sur ce qui a changé — de sorte que l'application réagit en temps réel.

## Filtrage et reprise

```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 });
```

Vous pouvez **filtrer** les changements (ne surveiller que certaines opérations ou documents) et **reprendre** après une déconnexion (en utilisant un jeton de reprise) — rendant les change streams résilients.

## Cas d'usage courants

```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 vs interrogation

```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).
```

## Pourquoi c'est important

Les change streams sont une fonctionnalité MongoDB précieuse pour construire des **applications réactives, événementielles et en temps réel**, comprendre comment les utiliser est donc une connaissance utile de niveau senior pour les applications modernes nécessitant une réactivité des données en direct.

La valeur principale est de permettre aux applications de **réagir aux changements de données en temps réel** — en recevant des notifications push quand des documents sont insérés, modifiés ou supprimés — ce qui active des capacités importantes : **fonctionnalités en temps réel** (pousser les mises à jour en direct vers les clients via websockets quand les données changent — un besoin courant pour les applications collaboratives, les tableaux de bord, les notifications), **synchronisation** (maintenir les caches, les index de recherche comme Elasticsearch, ou d'autres systèmes cohérents avec MongoDB au fur et à mesure que les données changent), **architecture événementielle** (déclencher des workflows, des notifications ou du traitement lors de changements de données), et **audit**.

L'avantage clé est de faire tout cela **sans interrogation** — les change streams permettent à la base de données de *pousser* les changements vers l'application instantanément et efficacement, remplaçant le modèle inefficace et à latence plus élevée d'interrogation répétée « qu'est-ce qui a changé ? » (qui charge la base de données et a un délai).

Comprendre comment regarder des collections, filtrer les changements (uniquement les opérations/documents pertinents), et reprendre après les déconnexions (en utilisant les jetons de reprise pour la résilience) couvre l'utilisation pratique.

Savoir que les change streams nécessitent un replica set est également pertinent.

Comme la réactivité en temps réel et le maintien de la synchronisation des systèmes sont des besoins d'application de plus en plus importants, et puisque les change streams fournissent une façon efficace et basée sur la notification de réagir aux changements de données MongoDB (bien meilleur que l'interrogation), comprendre les change streams — ce qu'ils font, leurs cas d'usage (fonctionnalités en temps réel, synchronisation, traitement événementiel), les capacités de reprise/filtrage, et l'avantage sur l'interrogation — est une connaissance utile de niveau senior pour construire des applications MongoDB modernes et réactives, une fonctionnalité utile pour le besoin courant de réagir aux changements de données en temps réel et un sujet reflétant la compréhension des modèles d'applications événementielles et en temps réel avec MongoDB.