சேஞ்ச் ஸ்ட்ரீம்ஸ் என்றால் என்ன?

Question

Accepted Answer

**சேஞ்ச் ஸ்ட்ரீம்ஸ்** பயன்பாடுகளை MongoDB தரவில் **நிஜ-நேரச் சேர்க்கைகளுக்கு குழுசேற செயல்பட** அனுமதிக்கிறது — ஆவணங்கள் செருகப்படும்போது, புதுப்பிக்கப்படும்போது அல்லது நீக்கப்படும்போது அறிவிப்புகளைப் பெறுகிறது. டேட்டாபேசைப் பாக்கவேண்டிய அவசியமின்றி, வினைத்திறன் சார்ந்த, நிகழ்வு-চালிப்புக் கூறுகளை (நிஜ-நேர புதுப்பிப்புக்கள், ஒத்திசைத்தல், ட்ரிகர்கள்) செயல்படுத்த உதவுகிறது. பிரতிபலிப்பு தொகுப்பு oplog இல் கட்டப்பட்டுள்ளது.

## சேர்க்கைகளைக் கணிக்கக்

```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 கூறு, எனவே அவற்றைப் புரிந்துகொள்வது இற்றைய பயன்பாடுகளுக்கு நிகரிய தரத்தான அறிவு.

மூல மதிப்பு பயன்பாடுகளை **தரவு சேர்க்கைகளுக்கு நிஜ-நேரத்தில் வினைபுரிய** செயல்படுத்துவது — ஆவணங்கள் செருகப்படும்போது, புதுப்பிக்கப்படும்போது அல்லது நீக்கப்படும்போது தள்ளும் அறிவிப்புகளைப் பெறுவது — இது முக்கியமான திறன்களை சக்திப்பெறுத்துகிறது: **நிஜ-நேர கூறுகள்** (தரவு மாறுகையில் websockets வழியாக வாடிக்கையாளர்களுக்கு நிகரிய புதுப்பிப்புகளைத் தள்ளுவது — ஒத்தியோக பயன்பாடுகள், கணிப்பிடல்கள், அறிவிப்புகளுக்கான பொதுவான தேவை), **ஒத்திசைத்தல்** (தேக்கம், Elasticsearch போன்ற தேடல் சுட்டுகள், அல்லது தரவு மாறுகையில் MongoDB உடன் நிலையான வைப்பாதல்கள் வைக்க), **நிகழ்வு-சக்திப்பெற்ற கட்டமைப்பு** (தரவு சேர்க்கைகளில் பணிப்புரை, அறிவிப்புக்கள், அல்லது செயல்பாடு தூண்டுதல்), மற்றும் **தணிக்கை**.

மূல நன்மை இவை அனைத்தையும் **கணிப்பு இல்லாமல்** செய்வது — சேஞ்ச் ஸ்ட்ரீம்ஸ் தரவுத்தளத்தை *தள்ள* அனுமதிக்கிறது பயன்பாட்டிற்கு உடனடி மற்றும் திறமையாக, "என்ன மாறிய?" என்பதை மீண்டும் கணிப்பிடுவதற்கான வீணான, அதிக-பதிமான வடிவத்தை மாற்றுவது (இது தரவுத்தளத்தை ஏற்றுவிக்கிறது மற்றும் தாமதத்தைக் கொண்டுள்ளது).

சேகரணைகளைக் கணிப்பது, சேர்க்கைகளை வடிகட்டுவது (தொடர்புடைய செயல்பாடுகள்/ஆவணங்கள் மட்டுமே), மற்றும் இழப்பிற்குப் பிறகு மீண்டும் தொடர்வது (மீண்டும் தொடர்தல் டோகன்களைப் பயன்படுத்தி நிலையான செய்ய) சமகாலீன பயன்பாட்டைக் கவர்கிறது.

சேஞ்ச் ஸ்ட்ரீம்ஸ் ஒரு பிரதிபலிப்பு தொகுப்பு தேவை என்பதை அறிதல் பொருத்தமுடையது.

நிஜ-நேர வினைத்திறன் மற்றும் கணினிகளைப் பொருத்துவது ஏறிக் கொண்டிருக்கும் பயன்பாட்டுத் தேவைகள் ஆகியவை, மற்றும் சேஞ்ச் ஸ்ட்ரீம்ஸ் MongoDB தரவு சேர்க்கைகளுக்கு வினைபுரிய ஒரு திறமையான, தள்ளல்-வாய்ப்பான வழியை வழங்குவதால் (கணிப்பிற்கு மிக உன்னத), சேஞ்ச் ஸ்ட்ரீம்களைப் புரிந்துகொள்வது — அவை என்ன செய்கிறது, அவற்றின் பயன்பாடுக் கிடைகள் (நிஜ-நேர கூறுகள், ஒத்திசைத்தல், நிகழ்வு-சக்திப்பெற்ற செயல்பாடு), மீண்டும் தொடர்தல்/வடிகட்டுதல் திறன்கள், மற்றும் கணிப்பிற்கு மேல் நன்மை — இற்றைய, வினைத்திறன் சார்ந்த MongoDB பயன்பாடுகளைக் கட்டுவதற்கான மூல்यवان நிகரிய தரத்தான அறிவு, தரவு சேர்க்கைகளுக்கு நிஜ-நேரத்தில் வினைபுரிய பொதுவான தேவைக்கான ஒரு பயனுள்ள கூறு, மற்றும் MongoDB உடன் நிகழ்வு-சக்திப்பெற்ற மற்றும் நிஜ-நேர பயன்பாட்டு வடிவங்களைப் புரிந்துகொள்ளும் ஒரு பொருள்.