Τι είναι change streams;

Question

Accepted Answer

**Change streams** επιτρέπουν στις εφαρμογές να **εγγραφούν σε real-time αλλαγές** δεδομένων στο MongoDB — λαμβάνοντας ειδοποιήσεις όταν τα έγγραφα εισάγονται, ενημερώνονται ή διαγράφονται. Ενεργοποιούν αντιδραστικές, event-driven δυνατότητες (real-time ενημερώσεις, συγχρονισμό, triggers) χωρίς polling της βάσης δεδομένων. Κατασκευάστηκαν με βάση το replica set 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.
});
```

Ένα change stream εκπέμπει ένα γεγονός για κάθε αλλαγή (insert/update/delete), με λεπτομέρειες σχετικά με το τι άλλαξε — έτσι η εφαρμογή αντιδρά σε πραγματικό χρόνο.

## Φιλτράρισμα και συνέχεια

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

Μπορείτε να **φιλτράρετε** αλλαγές (να παρακολουθείτε μόνο ορισμένες λειτουργίες ή έγγραφα) και να **συνεχίσετε** μετά από μια αποσύνδεση (χρησιμοποιώντας ένα resume token) — κάνοντας τα change streams ανθεκτικά.

## Κοινές περιπτώσεις χρήσης

```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 έναντι 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 streams είναι μια πολύτιμη δυνατότητα του MongoDB για την κατασκευή **real-time, reactive, event-driven εφαρμογών**, επομένως η κατανόησή τους είναι χρήσιμη γνώση σε ανώτερο επίπεδο για σύγχρονες εφαρμογές που χρειάζονται live data reactivity.

Η κύρια αξία είναι η ενδυνάμωση των εφαρμογών να **αντιδρούν σε αλλαγές δεδομένων σε πραγματικό χρόνο** — λαμβάνοντας push ειδοποιήσεις όταν τα έγγραφα εισάγονται, ενημερώνονται ή διαγράφονται — η οποία δίνει δύναμη σε σημαντικές δυνατότητες: **real-time δυνατότητες** (push live ενημερώσεων στους πελάτες μέσω websockets όταν τα δεδομένα αλλάζουν — μια συνηθισμένη ανάγκη για collaborative apps, dashboards, notifications), **συγχρονισμό** (διατήρηση της συνέπειας των caches, search indexes όπως Elasticsearch, ή άλλων συστημάτων με το MongoDB καθώς τα δεδομένα αλλάζουν), **event-driven αρχιτεκτονική** (ενεργοποίηση workflows, ειδοποιήσεων ή επεξεργασίας σε αλλαγές δεδομένων), και **auditing**.

Το κύριο πλεονέκτημα είναι να κάνουν όλα αυτά **χωρίς polling** — τα change streams επιτρέπουν στη βάση δεδομένων να *push* αλλαγές στην εφαρμογή στιγμιαία και αποτελεσματικά, αντικαθιστώντας το σπάταλο, υψηλότερης καθυστέρησης μοτίβο του επαναλαμβανόμενου ερωτήματος "τι άλλαξε;" (το οποίο φορτώνει τη βάση δεδομένων και έχει καθυστέρηση).

Η κατανόηση του πώς να παρακολουθείτε συλλογές, φιλτράρετε αλλαγές (μόνο σχετικές λειτουργίες/έγγραφα), και συνεχίσετε μετά από αποσυνδέσεις (χρησιμοποιώντας resume tokens για ανθεκτικότητα) καλύπτει την πρακτική χρήση.

Η γνώση ότι τα change streams απαιτούν ένα replica set είναι επίσης σχετική.

Επειδή η real-time reactivity και η διατήρηση της συνέπειας των συστημάτων είναι ολοένα και πιο σημαντικές ανάγκες εφαρμογών, και επειδή τα change streams παρέχουν έναν αποτελεσματικό, push-based τρόπο αντίδρασης σε αλλαγές δεδομένων MongoDB (πολύ καλύτερο από το polling), η κατανόηση των change streams — τι κάνουν, οι περιπτώσεις χρήσης τους (real-time δυνατότητες, συγχρονισμό, event-driven επεξεργασία), οι δυνατότητες resume/filter, και το πλεονέκτημα έναντι του polling — είναι πολύτιμη γνώση σε ανώτερο επίπεδο για την κατασκευή σύγχρονων, reactive MongoDB εφαρμογών, μια χρήσιμη δυνατότητα για την κοινή ανάγκη αντίδρασης σε αλλαγές δεδομένων σε πραγματικό χρόνο και ένα θέμα που αντανακλά την κατανόηση των event-driven και real-time μοτίβων εφαρμογών με το MongoDB.