Change stream'ler nedir?

Question

Accepted Answer

**Change stream'ler** uygulamaların **MongoDB verilerindeki gerçek zamanlı değişikliklere abone olmasını** sağlar — belgeler eklendiğinde, güncellendiğinde veya silindiğinde bildirimler alır. Veritabanını yoklamadan reaktif, olay temelli özellikler (gerçek zamanlı güncellemeler, senkronizasyon, tetikleyiciler) etkinleştirir. Replica set oplog üzerinde inşa edilmiştir.

## Değişiklikleri izleme

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

Bir change stream, her değişiklik (ekle/güncelle/sil) için bir olay yayar ve hangi şeylerin değiştiğinin ayrıntılarını içerir — böylece uygulama gerçek zamanlı yanıt verir.

## Filtreleme ve devam ettirme

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

Değişiklikleri **filtreleyebilir** (yalnızca belirli işlemleri veya belgeleri izleyin) ve kesilmeden sonra **devam edebilirsiniz** (bir resume token kullanarak) — change stream'leri dirençli hale getirir.

## Yaygın kullanım durumları

```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 stream'ler vs yoklama

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

## Neden önemli

Change stream'ler **gerçek zamanlı, reaktif, olay temelli uygulamalar** oluşturmak için değerli bir MongoDB özelliğidir, bu nedenle bunları anlamak modern uygulamalar için yararlı üst düzey bilgidir ve canlı veri reaktivitesi gerektirir.

Temel değer, uygulamaların **veri değişikliklerine gerçek zamanlı yanıt vermesini** sağlamaktır — belgeler eklendiğinde, güncellendiğinde veya silindiğinde anında bildirim almak — bu da önemli yetenekleri destekler: **gerçek zamanlı özellikler** (veri değiştiğinde websocket'ler aracılığıyla istemcilere canlı güncellemeler göndermek — işbirlikçi uygulamalar, panolar, bildirimler için yaygın bir ihtiyaç), **senkronizasyon** (önbellekler, Elasticsearch gibi arama dizinleri veya MongoDB'deki veri değiştikçe diğer sistemleri tutarlı tutmak), **olay temelli mimari** (veri değişikliklerinde iş akışları, bildirimler veya işlemi tetiklemek) ve **denetim**.

Temel avantaj, tüm bunları **yoklama olmadan** yapmaktır — change stream'ler veritabanının değişiklikleri uygulamaya anında ve verimli bir şekilde *itin*, tekrar tekrar