Change streams huruhusu programu kujiandikisha kwa mabadiliko ya wakati halisi katika data ya MongoDB — kupokea arifa wakati nyaraka zinapoingizwa, kusasishwa, au kufutwa. Huwezesha vipengele vya reactive na vinavyoendeshwa na matukio (sasisho za wakati halisi, syncing, triggers) bila kuuliza database mara kwa mara (polling). Vimejengwa juu ya oplog ya replica set.
changeStream = db.().();
changeStream.(, {
.(change.);
.(change.);
});
Change stream hutoa tukio kwa kila mabadiliko (insert/update/delete), ikiwa na maelezo kuhusu kilichobadilika — ili programu iitikie kwa wakati halisi.
// 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 });
Unaweza kuchuja mabadiliko (kuangalia operesheni au nyaraka fulani tu) na kuendelea baada ya kukatika kwa muunganisho (kwa kutumia resume token) — kufanya change streams ziwe imara.
✓ 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)
❌ 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 streams ni kipengele cha thamani cha MongoDB kwa kujenga programu za wakati halisi, reactive, na zinazoendeshwa na matukio, hivyo kuvielewa ni maarifa ya manufaa ya kiwango cha senior kwa programu za kisasa zinazohitaji uitikiaji wa data wa moja kwa moja.
Thamani kuu ni kuwezesha programu kuitikia mabadiliko ya data kwa wakati halisi — kupokea arifa za push wakati nyaraka zinapoingizwa, kusasishwa, au kufutwa — ambazo huwezesha uwezo muhimu: vipengele vya wakati halisi (kusukuma sasisho za moja kwa moja kwa clients kupitia websockets wakati data inabadilika — hitaji la kawaida kwa programu za ushirikiano, dashboards, arifa), syncing (kuweka caches, search indexes kama Elasticsearch, au mifumo mingine ikiwa thabiti na MongoDB kadri data inavyobadilika), usanifu unaoendeshwa na matukio (kuanzisha workflows, arifa, au uchakataji kwa mabadiliko ya data), na auditing.
Faida muhimu ni kufanya haya yote bila polling — change streams huruhusu database kusukuma mabadiliko kwa programu papo hapo na kwa ufanisi, kuchukua nafasi ya mfumo wa kupoteza rasilimali na wenye latency ya juu wa kuuliza mara kwa mara "ni nini kilichobadilika?" (ambao huongeza mzigo kwa database na una ucheleweshaji).
Kuelewa jinsi ya kuangalia collections, kuchuja mabadiliko (operesheni/nyaraka muhimu tu), na kuendelea baada ya kukatika (kwa kutumia resume tokens kwa uimara) kunashughulikia matumizi ya kivitendo.
Kujua kwamba change streams zinahitaji replica set pia ni muhimu.
Kwa kuwa uitikiaji wa wakati halisi na kuweka mifumo ikiwa thabiti ni mahitaji muhimu zaidi ya programu, na kwa kuwa change streams hutoa njia yenye ufanisi inayotegemea push ya kuitikia mabadiliko ya data ya MongoDB (bora zaidi kuliko polling), kuelewa change streams — zinavyofanya, matumizi yake (vipengele vya wakati halisi, syncing, uchakataji unaoendeshwa na matukio), uwezo wa resume/filter, na faida juu ya polling — ni maarifa ya thamani ya kiwango cha senior kwa kujenga programu za MongoDB za kisasa na reactive, kipengele cha manufaa kwa hitaji la kawaida la kuitikia mabadiliko ya data kwa wakati halisi na mada inayoonyesha uelewa wa mifumo ya programu inayoendeshwa na matukio na ya wakati halisi na MongoDB.