Apakah change streams?

Question

Accepted Answer

**Change streams** membolehkan aplikasi **melanggan perubahan masa nyata** dalam data MongoDB — menerima pemberitahuan apabila dokumen disisip, dikemas kini, atau dipadam. Ia membolehkan ciri reaktif dan dipacu peristiwa (kemas kini masa nyata, penyegerakan, pencetus) tanpa polling pangkalan data. Dibina di atas oplog replica set.

## Memerhati perubahan

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

Sebuah change stream memancarkan satu peristiwa untuk setiap perubahan (insert/update/delete), dengan butiran tentang apa yang berubah — supaya aplikasi bertindak balas dalam masa nyata.

## Penapisan dan penyambungan semula

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

Anda boleh **menapis** perubahan (hanya perhati operasi atau dokumen tertentu) dan **menyambung semula** selepas pemutusan sambungan (menggunakan resume token) — menjadikan change streams berdaya tahan.

## Kes penggunaan lazim

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

## Mengapa ia penting

Change streams ialah ciri MongoDB yang berharga untuk membina **aplikasi masa nyata, reaktif, dan dipacu peristiwa**, jadi memahaminya adalah pengetahuan peringkat senior yang berguna untuk aplikasi moden yang memerlukan reaktiviti data langsung.

Nilai teras ialah membolehkan aplikasi **bertindak balas terhadap perubahan data dalam masa nyata** — menerima pemberitahuan tolak apabila dokumen disisip, dikemas kini, atau dipadam — yang menggerakkan keupayaan penting: **ciri masa nyata** (menolak kemas kini langsung kepada klien melalui websocket apabila data berubah — keperluan lazim untuk aplikasi kolaboratif, dashboard, pemberitahuan), **penyegerakan** (memastikan cache, search index seperti Elasticsearch, atau sistem lain konsisten dengan MongoDB apabila data berubah), **seni bina dipacu peristiwa** (mencetuskan aliran kerja, pemberitahuan, atau pemprosesan pada perubahan data), dan **pengauditan**.

Kelebihan utama ialah melakukan semua ini **tanpa polling** — change streams membenarkan pangkalan data *menolak* perubahan kepada aplikasi dengan serta-merta dan cekap, menggantikan corak yang membazir dan berlatensi lebih tinggi iaitu kerap bertanya "apa yang berubah?" (yang membebankan pangkalan data dan mempunyai kelewatan).

Memahami cara memerhati collection, menapis perubahan (hanya operasi/dokumen yang relevan), dan menyambung semula selepas pemutusan sambungan (menggunakan resume token untuk daya tahan) merangkumi penggunaan praktikal.

Mengetahui bahawa change streams memerlukan replica set juga relevan.

Memandangkan reaktiviti masa nyata dan memastikan sistem segerak semakin menjadi keperluan aplikasi yang penting, dan memandangkan change streams menyediakan cara berasaskan tolak yang cekap untuk bertindak balas terhadap perubahan data MongoDB (jauh lebih baik berbanding polling), memahami change streams — apa yang dilakukannya, kes penggunaannya (ciri masa nyata, penyegerakan, pemprosesan dipacu peristiwa), keupayaan resume/filter, dan kelebihan berbanding polling — adalah pengetahuan peringkat senior yang berharga untuk membina aplikasi MongoDB moden yang reaktif, satu ciri berguna untuk keperluan lazim bertindak balas terhadap perubahan data dalam masa nyata dan topik yang mencerminkan pemahaman corak aplikasi dipacu peristiwa dan masa nyata dengan MongoDB.