change stream คืออะไร?

Question

Accepted Answer

**change stream** ให้แอปพลิเคชัน **subscribe การเปลี่ยนแปลงแบบ real-time** ในข้อมูล MongoDB — รับการแจ้งเตือนเมื่อเอกสารถูก insert, update หรือ delete มันเปิดให้ทำฟีเจอร์แบบ reactive และ event-driven (การอัปเดต real-time, การ sync, trigger) โดยไม่ต้อง poll ฐานข้อมูล สร้างขึ้นบน oplog ของ replica set

## การ watch การเปลี่ยนแปลง

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

change stream ส่ง event สำหรับการเปลี่ยนแปลงแต่ละครั้ง (insert/update/delete) พร้อมรายละเอียดว่าอะไรเปลี่ยน — เพื่อให้แอปพลิเคชันตอบสนองแบบ real time

## การ filter และการ resume

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

คุณสามารถ **filter** การเปลี่ยนแปลง (watch เฉพาะบาง operation หรือบางเอกสาร) และ **resume** หลังการขาดการเชื่อมต่อ (ใช้ resume token) — ทำให้ change stream มีความทนทาน

## use case ทั่วไป

```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 กับ 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).
```

## ทำไมจึงสำคัญ

change stream เป็นฟีเจอร์ที่มีคุณค่าของ MongoDB สำหรับการสร้างแอปพลิเคชันแบบ **real-time, reactive และ event-driven** ดังนั้นการเข้าใจมันจึงเป็นความรู้ระดับ senior ที่มีประโยชน์สำหรับแอปพลิเคชันสมัยใหม่ที่ต้องการการตอบสนองต่อข้อมูลแบบ live

คุณค่าหลักคือการเปิดให้แอปพลิเคชัน **ตอบสนองต่อการเปลี่ยนแปลงข้อมูลแบบ real time** — รับการแจ้งเตือนแบบ push เมื่อเอกสารถูก insert, update หรือ delete — ซึ่งขับเคลื่อนความสามารถสำคัญ: **ฟีเจอร์ real-time** (push การอัปเดต live ไปยัง client ผ่าน websocket เมื่อข้อมูลเปลี่ยน — เป็นความต้องการทั่วไปสำหรับแอป collaborative, dashboard, การแจ้งเตือน), **การ sync** (ทำให้ cache, search index เช่น Elasticsearch หรือระบบอื่นสอดคล้องกับ MongoDB เมื่อข้อมูลเปลี่ยน), **สถาปัตยกรรม event-driven** (trigger workflow, การแจ้งเตือน หรือการประมวลผลเมื่อข้อมูลเปลี่ยน) และ **การ audit**

ข้อได้เปรียบสำคัญคือการทำทั้งหมดนี้ **โดยไม่ต้อง poll** — change stream ให้ฐานข้อมูล *push* การเปลี่ยนแปลงไปยังแอปพลิเคชันได้ทันทีและมีประสิทธิภาพ แทนที่ pattern ที่สิ้นเปลืองและมี latency สูงของการ query ซ้ำ ๆ ว่า "อะไรเปลี่ยน?" (ซึ่งสร้างโหลดให้ฐานข้อมูลและมีดีเลย์)

การเข้าใจวิธีการ watch collection, filter การเปลี่ยนแปลง (เฉพาะ operation/เอกสารที่เกี่ยวข้อง) และ resume หลังการขาดการเชื่อมต่อ (ใช้ resume token เพื่อความทนทาน) ครอบคลุมการใช้งานในทางปฏิบัติ

การรู้ว่า change stream ต้องการ replica set ก็เกี่ยวข้องเช่นกัน

เนื่องจากการตอบสนองแบบ real-time และการทำให้ระบบสอดคล้องกันเป็นความต้องการของแอปพลิเคชันที่สำคัญมากขึ้นเรื่อย ๆ และเนื่องจาก change stream ให้วิธีการแบบ push-based ที่มีประสิทธิภาพในการตอบสนองต่อการเปลี่ยนแปลงข้อมูล MongoDB (ดีกว่าการ poll มาก) การเข้าใจ change stream — สิ่งที่มันทำ, use case (ฟีเจอร์ real-time, การ sync, การประมวลผลแบบ event-driven), ความสามารถในการ resume/filter และข้อได้เปรียบเหนือการ poll — จึงเป็นความรู้ระดับ senior ที่มีคุณค่าสำหรับการสร้างแอปพลิเคชัน MongoDB สมัยใหม่แบบ reactive เป็นฟีเจอร์ที่มีประโยชน์สำหรับความต้องการทั่วไปในการตอบสนองต่อการเปลี่ยนแปลงข้อมูลแบบ real time และเป็นหัวข้อที่สะท้อนถึงความเข้าใจใน pattern ของแอปพลิเคชันแบบ event-driven และ real-time กับ MongoDB