Çfarë janë change streams?

Question

Accepted Answer

**Change streams** i lejojnë aplikacionet të **pajtoheshin me ndryshimet në kohë reale** në të dhënat MongoDB — duke marrë njoftimet kur dokumentet futen, përditësohen ose fshihen. Ato mundësojnë veçori reaktive, bazuar në ngjarje (përditësime në kohë reale, sinkronizim, aktivizues) pa kërkuar në bazën e të dhënave. Ndertuar mbi replica set oplog.

## Monitorimi i ndryshimeve

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

Një change stream nxjerr një ngjarje për çdo ndryshim (fshirje/përditësim/fshirje), me detaje rreth asaj që ndryshoi — kështu që aplikacioni reagon në kohë reale.

## Filtrimi dhe rifillimi

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

Mund të **filtrohet** ndryshime (monitoroni vetëm veprime ose dokumente të caktuara) dhe **rifilloni** pas shkputjeje (duke përdorur një token rifillimi) — duke e bërë change streams rezistent.

## Rastet e përdorimit të zakonshme

```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 përkundër kërkimeve

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

## Pse ka rëndësi

Change streams janë një veçori e vlefshme MongoDB për ndërtimin e **aplikacioneve reaktive, bazuar në kohë reale dhe ngjarje**, kështu që të kuptuarit e tyre është njohuri e dobishme për nivel senior për aplikacionet moderne që kanë nevojë për reaksionin në të dhëna në direkt.

Vlera thelbësore është mundësimi i aplikacioneve të **reagojnë ndaj ndryshimeve në të dhëna në kohë reale** — duke marrë njoftime push kur dokumentet futen, përditësohen ose fshihen — e cila energjizon aftësi të rëndësishme: **veçori në kohë reale** (shtyrja e përditësimeve në direkt tek klientët përmes websocket kur të dhënat ndryshojnë — një nevojë e zakonshme për aplikacione bashkëpunuese, tabelat e kontrollimit, njoftimet), **sinkronizimi** (mbajtja e cache, indekset e kërkimit si Elasticsearch, ose sistemet e tjera në përputhje me MongoDB ndërsa të dhënat ndryshojnë), **arkitektura bazuar në ngjarje** (aktivizimi i rrjedhjeve të punës, njoftimet, ose përpunimin në ndryshimet e të dhënave), dhe **auditimi**.

Avantazhi kryesor është të bëhet e gjitha kjo **pa kërkime** — change streams i lejojnë bazën e të dhënave të *shtyjë* ndryshimet në aplikacion menjëherë dhe në mënyrë efikase, duke zëvendësuar shenjën e trazuar, me latencë më të lartë të pyetjeve të përsëritura "çfarë ndryshoi?" (e cila ngarkon bazën e të dhënave dhe ka vonesë).

T'i kuptohen koleksionet e monitorimit, filtrimit i ndryshimeve (vetëm operacionet/dokumentet përkatëse), dhe rifillimi pas shkputjeve (duke përdorur token rifillimi për rezistencën) mbulojnë përdorimin praktik.

T'i dihet se change streams kërkojnë një replica set është gjithashtu i rëndësishëm.

Meqenëse reaktiviteti në kohë reale dhe mbajtja e sistemeve në sinkronizim janë nevojat e aplikacioneve shumë të rëndësishme, dhe meqenëse change streams ofrojnë një mënyrë efikase, bazuar në shtyrje për të reaguar ndaj ndryshimeve të të dhënave MongoDB (shumë më mirë sesa kërkimet), të kuptuarit e change streams — çfarë bëjnë ato, rastet e tyre të përdorimit (veçori në kohë reale, sinkronizimi, përpunimi i ngjarjeve), aftësitë e rifillimit/filtrimit, dhe avantazhi ndaj kërkimeve — është njohuri e vlefshme për nivel senior për ndërtimin e aplikacioneve moderne, reaktive MongoDB, një veçori e dobishme për nevojën e zakonshme për t'iu përgjigjur ndryshimeve të të dhënave në kohë reale dhe një temë që pasqyron mirëkuptimin e modeleve të aplikacioneve bazuar në ngjarje dhe në kohë reale me MongoDB.