O que são change streams?

Question

Accepted Answer

**Change streams** permitem que aplicações **se inscrevam em mudanças em tempo real** nos dados do MongoDB — recebendo notificações quando documentos são inseridos, atualizados ou deletados. Elas habilitam funcionalidades reativas e orientadas a eventos (atualizações em tempo real, sincronização, triggers) sem fazer polling do banco de dados. Construídas no oplog do replica set.

## Observando mudanças

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

Um change stream emite um evento para cada mudança (inserção/atualização/deleção), com detalhes sobre o que foi alterado — para que a aplicação reaja em tempo real.

## Filtragem e retomada

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

Você pode **filtrar** mudanças (observar apenas certas operações ou documentos) e **retomar** após uma desconexão (usando um resume token) — tornando os change streams resilientes.

## Casos de uso comuns

```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 polling

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

## Por que isso importa

Change streams são um recurso valioso do MongoDB para construir **aplicações reativas, orientadas a eventos e em tempo real**, então entendê-los é um conhecimento útil em nível sênior para aplicações modernas que precisam de reatividade de dados ao vivo.

O valor central é permitir que as aplicações **reajam a mudanças de dados em tempo real** — recebendo notificações push quando documentos são inseridos, atualizados ou deletados — o que capacita funcionalidades importantes: **recursos em tempo real** (enviando atualizações ao vivo para clientes via websockets quando os dados mudam — uma necessidade comum para apps colaborativos, dashboards, notificações), **sincronização** (mantendo caches, índices de busca como Elasticsearch ou outros sistemas consistentes com MongoDB conforme os dados mudam), **arquitetura orientada a eventos** (disparando workflows, notificações ou processamento em mudanças de dados) e **auditoria**.

A vantagem principal é fazer tudo isso **sem fazer polling** — change streams permitem que o banco de dados *envie* mudanças para a aplicação instantaneamente e eficientemente, substituindo o padrão ineficiente e de latência mais alta de repetidamente consultar "o que mudou?" (que sobrecarrega o banco de dados e tem atraso).

Compreender como observar coleções, filtrar mudanças (apenas operações/documentos relevantes) e retomar após desconexões (usando resume tokens para resiliência) cobre o uso prático.

Saber que change streams requerem um replica set também é relevante.

Como a reatividade em tempo real e manter sistemas sincronizados são necessidades crescentes de aplicações, e como change streams fornecem uma maneira eficiente baseada em push para reagir a mudanças de dados do MongoDB (muito melhor que polling), entender change streams — o que elas fazem, seus casos de uso (recursos em tempo real, sincronização, processamento orientado a eventos), as capacidades de retomada/filtragem e a vantagem sobre polling — é um conhecimento valioso em nível sênior para construir aplicações MongoDB modernas e reativas, um recurso útil para a necessidade comum de responder a mudanças de dados em tempo real e um tópico que reflete o entendimento de padrões de aplicação orientada a eventos e em tempo real com MongoDB.