Apa itu change streams?

Question

Accepted Answer

**Change streams** memungkinkan aplikasi **berlangganan perubahan data MongoDB secara real-time** — menerima notifikasi ketika dokumen disisipkan, diperbarui, atau dihapus. Mereka mengaktifkan fitur reaktif dan berbasis peristiwa (pembaruan real-time, sinkronisasi, pemicu) tanpa polling database. Dibangun di atas replica set oplog.

## Memantau 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 peristiwa untuk setiap perubahan (insert/update/delete), dengan detail tentang apa yang berubah — sehingga aplikasi bereaksi secara real-time.

## Penyaringan dan melanjutkan kembali

```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 dapat **memfilter** perubahan (hanya memantau operasi atau dokumen tertentu) dan **melanjutkan kembali** setelah terputus (menggunakan resume token) — membuat change streams tahan lama.

## Kasus penggunaan umum

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

## Mengapa ini penting

Change streams adalah fitur MongoDB yang berharga untuk membangun **aplikasi real-time, reaktif, dan berbasis peristiwa**, jadi memahaminya adalah pengetahuan tingkat senior yang berguna untuk aplikasi modern yang membutuhkan reaktivitas data langsung.

Nilai inti adalah memungkinkan aplikasi untuk **bereaksi terhadap perubahan data secara real-time** — menerima notifikasi push ketika dokumen disisipkan, diperbarui, atau dihapus — yang mendukung kemampuan penting: **fitur real-time** (mendorong pembaruan langsung ke klien via websockets ketika data berubah — kebutuhan umum untuk aplikasi kolaboratif, dashboard, notifikasi), **sinkronisasi** (menjaga cache, indeks pencarian seperti Elasticsearch, atau sistem lain tetap konsisten dengan MongoDB saat data berubah), **arsitektur berbasis peristiwa** (memicu alur kerja, notifikasi, atau pemrosesan pada perubahan data), dan **audit**.

Keuntungan utama adalah melakukan semua ini **tanpa polling** — change streams memungkinkan database untuk *mendorong* perubahan ke aplikasi secara instan dan efisien, menggantikan pola yang boros dan latensi tinggi dari berulang kali melakukan query "apa yang berubah?" (yang membebani database dan memiliki penundaan).

Memahami cara memantau koleksi, memfilter perubahan (hanya operasi/dokumen yang relevan), dan melanjutkan kembali setelah putus (menggunakan resume tokens untuk ketahanan) mencakup penggunaan praktis.

Mengetahui bahwa change streams memerlukan replica set juga relevan.

Karena reaktivitas real-time dan menjaga sistem tetap tersinkronisasi adalah kebutuhan aplikasi yang semakin penting, dan karena change streams menyediakan cara yang efisien dan berbasis push untuk bereaksi terhadap perubahan data MongoDB (jauh lebih baik daripada polling), memahami change streams — apa yang mereka lakukan, kasus penggunaan mereka (fitur real-time, sinkronisasi, pemrosesan berbasis peristiwa), kemampuan resume/filter, dan keuntungan dibandingkan polling — adalah pengetahuan tingkat senior yang berharga untuk membangun aplikasi MongoDB modern dan reaktif, fitur berguna untuk kebutuhan umum merespons perubahan data secara real-time dan topik yang mencerminkan pemahaman pola aplikasi berbasis peristiwa dan real-time dengan MongoDB.