change stream이란 무엇인가요?

Question

Accepted Answer

**change stream**은 애플리케이션이 MongoDB 데이터의 **실시간 변경을 구독**하게 합니다 — document가 삽입, 갱신, 삭제될 때 알림을 받습니다. 데이터베이스를 폴링하지 않고 반응형, 이벤트 주도 기능(실시간 업데이트, 동기화, 트리거)을 가능하게 합니다. replica set oplog 위에 구축됩니다.

## 변경 감시

```js
// collection의 변경을 감시 — 실시간으로 알림 받기
const changeStream = db.collection("orders").watch();

changeStream.on("change", (change) => {
  console.log(change.operationType);   // "insert", "update", "delete", "replace"
  console.log(change.fullDocument);     // 변경된 document (insert/update용)
  // 반응: websocket으로 push, 캐시 갱신, 워크플로 트리거 등
});
```

change stream은 각 변경(insert/update/delete)에 대해 무엇이 바뀌었는지 상세 정보와 함께 이벤트를 방출합니다 — 그래서 애플리케이션이 실시간으로 반응합니다.

## 필터링과 재개

```js
// aggregation pipeline 필터로 특정 변경만 감시
db.collection("orders").watch([
  { $match: { operationType: "insert", "fullDocument.status": "urgent" } }
]);

// 중단된 지점부터 재개 (연결 끊김에 복원력)
db.collection("orders").watch([], { resumeAfter: lastChangeToken });
```

변경을 **필터링**(특정 연산이나 document만 감시)하고 연결 끊김 후 **재개**(resume token 사용)할 수 있어 — change stream을 복원력 있게 만듭니다.

## 일반적인 사용 사례

```text
✓ 실시간 기능 — 데이터 변경 시 클라이언트에 실시간 업데이트 push (websocket)
✓ 동기화 — 캐시, 검색 index(Elasticsearch), 다른 시스템을 동기 상태로 유지
✓ 이벤트 주도 아키텍처 — 데이터 변경 시 워크플로/알림 트리거
✓ 감사 — 변경 기록; 데이터 수정에 대한 분석
→ 모두 데이터베이스를 반복 폴링하지 않고 (효율적, 실시간)
```

## change stream vs 폴링

```text
❌ 폴링 — "무엇이 바뀌었나?"를 반복 쿼리 → 비효율적, 지연, DB 부하
✅ change stream — 데이터베이스가 변경을 실시간으로 PUSH → 효율적, 즉각적
→ 데이터 변경에 반응하는 올바른 방법 (replica set 필요).
```

## 왜 중요한가

change stream은 **실시간, 반응형, 이벤트 주도 애플리케이션**을 구축하는 데 가치 있는 MongoDB 기능이므로, 이를 이해하는 것은 실시간 데이터 반응성이 필요한 현대 애플리케이션에 유용한 senior 수준 지식입니다.

핵심 가치는 애플리케이션이 **데이터 변경에 실시간으로 반응**하게 하는 것입니다 — document가 삽입, 갱신, 삭제될 때 push 알림을 받음 — 이는 중요한 능력을 가능하게 합니다: **실시간 기능**(데이터 변경 시 websocket을 통해 클라이언트에 실시간 업데이트 push — 협업 앱, 대시보드, 알림에 흔한 요구), **동기화**(데이터가 변경됨에 따라 캐시, Elasticsearch 같은 검색 index, 다른 시스템을 MongoDB와 일관되게 유지), **이벤트 주도 아키텍처**(데이터 변경 시 워크플로, 알림, 처리 트리거), **감사**.

핵심 이점은 이 모든 것을 **폴링 없이** 한다는 것입니다 — change stream은 데이터베이스가 변경을 애플리케이션에 즉각적이고 효율적으로 *push*하게 하여, "무엇이 바뀌었나?"를 반복 쿼리하는 낭비적이고 지연이 높은 패턴(데이터베이스에 부하를 주고 지연이 있음)을 대체합니다.

collection을 감시하고, 변경을 필터링(관련 연산/document만)하고, 연결 끊김 후 재개(복원력을 위한 resume token 사용)하는 방법을 이해하면 실질적 사용을 다룹니다.

change stream이 replica set을 필요로 한다는 것을 아는 것도 관련이 있습니다.

실시간 반응성과 시스템을 동기 상태로 유지하는 것이 점점 중요한 애플리케이션 요구이고, change stream이 MongoDB 데이터 변경에 반응하는 효율적이고 push 기반 방법을 제공하므로(폴링보다 훨씬 나음), change stream — 그것이 하는 일, 사용 사례(실시간 기능, 동기화, 이벤트 주도 처리), 재개/필터 기능, 폴링 대비 이점 — 을 이해하는 것은 현대적이고 반응형인 MongoDB 애플리케이션을 구축하는 데 가치 있는 senior 수준 지식이며, 데이터 변경에 실시간으로 응답하는 흔한 요구에 유용한 기능이자 MongoDB로 이벤트 주도 및 실시간 애플리케이션 패턴에 대한 이해를 반영하는 주제입니다.