চেঞ্জ স্ট্রিমস কী?

Question

চেঞ্জ স্ট্রিমস কী?

Accepted Answer

**চেঞ্জ স্ট্রিমস** অ্যাপ্লিকেশনগুলিকে MongoDB ডেটায় **রিয়েল-টাইম পরিবর্তনে সাবস্ক্রাইব করতে** দেয় — যখন ডকুমেন্টগুলি সন্নিবেশ, আপডেট বা মুছে ফেলা হয় তখন বিজ্ঞপ্তি পায়। তারা ডাটাবেসকে পোল না করে প্রতিক্রিয়াশীল, ইভেন্ট-চালিত বৈশিষ্ট্য (রিয়েল-টাইম আপডেট, সিঙ্ক করা, ট্রিগার) সক্ষম করে। রেপ্লিকা সেট অপলগের উপর নির্মিত।

## পরিবর্তনের জন্য পর্যবেক্ষণ করা

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

একটি চেঞ্জ স্ট্রিম প্রতিটি পরিবর্তনের জন্য একটি ইভেন্ট নির্গত করে (সন্নিবেশ/আপডেট/মুছে ফেলা), যা কী পরিবর্তিত হয়েছে সে সম্পর্কে বিবরণ সহ — তাই অ্যাপ্লিকেশন রিয়েল-টাইমে প্রতিক্রিয়া জানায়।

## ফিল্টারিং এবং পুনরায় শুরু করা

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

আপনি পরিবর্তনগুলি **ফিল্টার** করতে পারেন (শুধুমাত্র নির্দিষ্ট ক্রিয়াকলাপ বা ডকুমেন্টগুলি পর্যবেক্ষণ করুন) এবং বিচ্ছিন্নতার পরে **পুনরায় শুরু** করতে পারেন (একটি রিজিউম টোকেন ব্যবহার করে) — চেঞ্জ স্ট্রিমগুলিকে স্থিতিস্থাপক করে তোলে।

## সাধারণ ব্যবহারের ক্ষেত্রে

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

## চেঞ্জ স্ট্রিমস বনাম পোলিং

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

## এটি কেন গুরুত্বপূর্ণ

চেঞ্জ স্ট্রিমগুলি **রিয়েল-টাইম, প্রতিক্রিয়াশীল, ইভেন্ট-চালিত অ্যাপ্লিকেশনগুলি** তৈরির জন্য একটি মূল্যবান MongoDB বৈশিষ্ট্য, তাই লাইভ ডেটা প্রতিক্রিয়াশীলতার প্রয়োজন এমন আধুনিক অ্যাপ্লিকেশনগুলির জন্য সেগুলি বোঝা সিনিয়র-স্তরের জ্ঞান।

মূল মূল্য হল অ্যাপ্লিকেশনগুলিকে **রিয়েল-টাইমে ডেটা পরিবর্তনে প্রতিক্রিয়া জানাতে** সক্ষম করা — যখন ডকুমেন্টগুলি সন্নিবেশ, আপডেট বা মুছে ফেলা হয় তখন পুশ বিজ্ঞপ্তি পাওয়া — যা গুরুত্বপূর্ণ ক্ষমতা চালিত করে: **রিয়েল-টাইম বৈশিষ্ট্যগুলি** (ডেটা পরিবর্তনের সময় ওয়েবসকেটের মাধ্যমে ক্লায়েন্টদের কাছে লাইভ আপডেট পুশ করা — সহযোগী অ্যাপস, ড্যাশবোর্ড, বিজ্ঞপ্তিগুলির জন্য একটি সাধারণ প্রয়োজন), **সিঙ্ক করা** (ক্যাশে, সার্চ ইনডেক্সগুলি Elasticsearch-এর মতো, বা অন্যান্য সিস্টেমগুলি MongoDB-এর সাথে সামঞ্জস্যপূর্ণ রাখা যেমন ডেটা পরিবর্তন হয়), **ইভেন্ট-চালিত আর্কিটেকচার** (ডেটা পরিবর্তনগুলির উপর ওয়ার্কফ্লো, বিজ্ঞপ্তি বা প্রক্রিয়াকরণ ট্রিগার করা), এবং **অডিটিং**।

মূল সুবিধা হল সবকিছু **পোলিং ছাড়াই** করা — চেঞ্জ স্ট্রিমগুলি ডাটাবেসকে তাৎক্ষণিক এবং দক্ষতার সাথে অ্যাপ্লিকেশনে পরিবর্তনগুলি *পুশ* করতে দেয়, বারবার "কী পরিবর্তিত হয়েছে?" জিজ্ঞাসা করার অপচয়কারী, উচ্চতর-লেটেন্সি প্যাটার্নটি প্রতিস্থাপন করে (যা ডাটাবেসকে লোড করে এবং বিলম্ব রয়েছে)।

সংগ্রহগুলি পর্যবেক্ষণ করতে, পরিবর্তনগুলি ফিল্টার করতে (শুধুমাত্র প্রাসঙ্গিক ক্রিয়াকলাপ/ডকুমেন্টগুলি), এবং বিচ্ছিন্নতার পরে পুনরায় শুরু করতে (স্থিতিস্থাপকতার জন্য রিজিউম টোকেন ব্যবহার করে) কীভাবে যায় তা বোঝা ব্যবহারিক ব্যবহার কভার করে।

চেঞ্জ স্ট্রিমগুলির জন্য একটি রেপ্লিকা সেট প্রয়োজন তা জানাও প্রাসঙ্গিক।

যেহেতু রিয়েল-টাইম প্রতিক্রিয়াশীলতা এবং সিস্টেমগুলিকে সিঙ্ক করা ক্রমবর্ধমান গুরুত্বপূর্ণ অ্যাপ্লিকেশন চাহিদা, এবং যেহেতু চেঞ্জ স্ট্রিমগুলি MongoDB ডেটা পরিবর্তনে প্রতিক্রিয়া জানানোর জন্য একটি দক্ষ, পুশ-ভিত্তিক উপায় প্রদান করে (পোলিংয়ের চেয়ে অনেক ভাল), চেঞ্জ স্ট্রিমগুলি বোঝা — তারা কী করে, তাদের ব্যবহারের ক্ষেত্রে (রিয়েল-টাইম বৈশিষ্ট্য, সিঙ্ক করা, ইভেন্ট-চালিত প্রক্রিয়াকরণ), রিজিউম/ফিল্টার ক্ষমতা, এবং পোলিংয়ের সুবিধা — আধুনিক, প্রতিক্রিয়াশীল MongoDB অ্যাপ্লিকেশনগুলি তৈরির জন্য মূল্যবান সিনিয়র-স্তরের জ্ঞান, রিয়েল-টাইমে ডেটা পরিবর্তনগুলিতে প্রতিক্রিয়া জানানোর জন্য সাধারণ প্রয়োজনের জন্য একটি দরকারী বৈশিষ্ট্য এবং MongoDB-এর সাথে ইভেন্ট-চালিত এবং রিয়েল-টাইম অ্যাপ্লিকেশন প্যাটার্ন বোঝার প্রতিফলন একটি বিষয়।