Change Streams

Définition

API qui permet a une application de s'abonner en temps réel aux modifications d'une collection, d'une base ou d'un déploiement entier via watch(), sans lire l'oplog manuellement. Un résume token permet de reprendre le flux exactement ou il s'est arrêté après une coupure.

Analogie

Comme s'abonner aux notifications d'une application plutôt que de rafraîchir la page toutes les secondes pour vérifier s'il y a du nouveau.

Exemple de code

const cursor = db.collection('orders').watch([], {
  fullDocument: 'updateLookup'
});
cursor.on('change', (event) => {
  console.log(event.operationType, event._id);
});

Cas d'usage

Synchroniser des données en temps réel vers un autre système (ETL, cache, notification) sans polling.

Anti-pattern

Termes liés

Sources

• mongodb.com/docs/manual/changeStreams/