Что такое change streams?

Question

Accepted Answer

**Change streams** позволяют приложениям **подписаться на изменения данных в режиме реального времени** в 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.
});
```

Change stream генерирует событие для каждого изменения (вставка/обновление/удаление), с подробностями о том, что изменилось — чтобы приложение реагировало в реальном времени.

## Фильтрация и возобновление

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

Вы можете **фильтровать** изменения (наблюдать только определённые операции или документы) и **возобновить** работу после разрыва соединения (используя токен возобновления) — делая 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 в сравнении с опросом

```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 для создания **приложений реального времени, реактивных, управляемых событиями**, поэтому понимание их — полезные знания на уровне сеньора для современных приложений, требующих реактивности живых данных.

Основная ценность заключается в том, чтобы позволить приложениям **реагировать на изменения данных в реальном времени** — получать push-уведомления при вставке, обновлении или удалении документов — что обеспечивает важные возможности: **функции реального времени** (отправка живых обновлений клиентам через websockets при изменении данных — частая потребность совместных приложений, панелей управления, уведомлений), **синхронизация** (поддержание кешей, поисковых индексов, таких как Elasticsearch, или других систем в соответствии с MongoDB при изменении данных), **архитектура управляемая событиями** (запуск рабочих процессов, уведомлений или обработки при изменении данных), и **аудит**.

Ключевое преимущество — всё это **без опроса** — change streams позволяют базе данных *отправлять* изменения в приложение мгновенно и эффективно, заменяя расточительный, высокозадержный паттерн повторных запросов «что изменилось?» (который нагружает базу данных и имеет задержку).

Понимание того, как наблюдать коллекции, фильтровать изменения (только релевантные операции/документы) и возобновлять работу после разрывов соединения (используя токены возобновления для устойчивости), охватывает практическое использование.

Знание того, что change streams требуют набора реплик, также актуально.

Поскольку реактивность в реальном времени и поддержание синхронизации систем — это всё более важные потребности приложений, а change streams обеспечивают эффективный, основанный на отправке способ реагирования на изменения данных MongoDB (намного лучше, чем опрос), понимание change streams — что они делают, их варианты использования (функции реального времени, синхронизация, обработка управляемая событиями), возможности возобновления/фильтрации и преимущество перед опросом — это ценные знания на уровне сеньора для создания современных, реактивных приложений MongoDB, полезная функция для частой потребности реагировать на изменения данных в реальном времени и тема, отражающая понимание управляемых событиями и приложений реального времени с MongoDB.