데이터 변경 사항 모니터링

샘플 데이터

이 가이드의 예시에서는 다음 Course 구조체를 courses collection의 문서 모델로 사용합니다.

type Course struct {
	Title      string
	Enrollment int32
}

이 가이드의 예시를 실행하려면 다음 스니펫을 사용하여 이러한 문서를 db 데이터베이스의 courses 컬렉션에 로드합니다.

coll := client.Database("db").Collection("courses")
docs := []interface{}{
	Course{Title: "World Fiction", Enrollment: 35},
	Course{Title: "Abstract Algebra", Enrollment: 60},
}
result, err := coll.InsertMany(context.TODO(), docs)

각 문서에는 각 문서의 title 및 enrollment 필드에 해당하는 과정의 제목 및 최대 등록 수를 비롯한 University 과정에 대한 설명이 포함되어 있습니다.

예시

다음 예시에서는 courses 컬렉션에서 변경 스트림을 열고 모든 변경 사항을 출력합니다.

changeStream, err := coll.Watch(context.TODO(), mongo.Pipeline{})
if err != nil {
	panic(err)
}
defer changeStream.Close(context.TODO())
// Iterates over the cursor to print the change stream events
for changeStream.Next(context.TODO()) {
	fmt.Println(changeStream.Current)
}

별도의 프로그램이나 셸에서 courses 컬렉션을 수정하는 경우 이 코드는 변경 내용이 발생할 때 출력합니다. title 값이 "Advanced Screenwriting"이고 enrollment 값이 20인 문서를 삽입하면 다음과 같은 변경 이벤트가 발생합니다.

map[_id:map[_data:...] clusterTime: {...} documentKey:map[_id:ObjectID("...")]
fullDocument:map[_id:ObjectID("...") enrollment:20 title:Advanced Screenwriting] ns:
map[coll:courses db:db] operationType:insert]

예시

다음 예시에서는 db 데이터베이스에서 변경 스트림을 열지만 새 삭제 작업만 감시합니다.

db := client.Database("db")
pipeline := bson.D{{"$match", bson.D{{"operationType", "delete"}}}}
changeStream, err := db.Watch(context.TODO(), mongo.Pipeline{pipeline})
if err != nil {
	panic(err)
}
defer changeStream.Close(context.TODO())
// Iterates over the cursor to print the delete operation change events
for changeStream.Next(context.TODO()) {
	fmt.Println(changeStream.Current)
}

사전 및 사후 이미지

컬렉션에서 CRUD 작업을 수행하는 경우 기본적으로 해당 변경 이벤트 문서에는 작업에 의해 수정된 필드의 델타만 포함됩니다. Watch() 메서드의 options 매개변수에 설정을 지정하여 델타 외에도 변경 전후의 전체 문서를 볼 수 있습니다.

변경 후 문서의 전체 버전인 문서의 사후 이미지를 보려면 options 매개변수의 FullDocument 필드를 다음 값 중 하나로 설정합니다.

• UpdateLookup: 변경 이벤트 문서에는 변경된 문서 전체의 복사본이 포함됩니다.

• WhenAvailable: 변경 이벤트 문서에는 변경 이벤트에 대해 수정된 문서의 사후 이미지가 있는 경우 해당 문서의 사후 이미지가 포함됩니다.

• Required: 출력은 WhenAvailable과 동일하지만 사후 이미지를 사용할 수 없는 경우 드라이버에서 서버 측 오류가 발생합니다.

변경 전 문서의 전체 버전인 문서의 사전 이미지를 보려면 options 매개변수의 FullDocumentBeforeChange 필드를 다음 값 중 하나로 설정합니다.

• WhenAvailable: 변경 이벤트 문서에는 변경 이벤트에 대한 수정된 문서의 사전 이미지가 있는 경우 해당 문서의 사전 이미지가 포함됩니다.

• Required: 출력은 WhenAvailable과 동일하지만 사전 이미지를 사용할 수 없는 경우 드라이버에서 서버 측 오류가 발생합니다.

예시

다음 예시에서는 courses 컬렉션에서 Watch() 메서드를 호출합니다. options 매개변수의 FullDocument 필드 값을 지정하여 변경된 필드만 출력하는 대신 수정된 전체 문서의 사본을 출력합니다.

opts := options.ChangeStream().SetFullDocument(options.UpdateLookup)
changeStream, err := coll.Watch(context.TODO(), mongo.Pipeline{}, opts)
if err != nil {
	panic(err)
}
defer changeStream.Close(context.TODO())
for changeStream.Next(context.TODO()) {
	fmt.Println(changeStream.Current)
}

title이 "World Fiction"인 문서의 enrollment 값을 35에서 30으로 업데이트하면 다음과 같은 변경 이벤트가 발생합니다.

{"_id": {"_data": "..."},"operationType": "update","clusterTime": {"$timestamp":
{"t":"...","i":"..."}},"fullDocument": {"_id":
{"$oid":"..."},"title": "World Fiction","enrollment":
{"$numberInt":"30"}}, "ns": {"db": "db","coll": "courses"},"documentKey": {"_id":
{"$oid":"..."}}, "updateDescription": {"updatedFields": {"enrollment": {"$numberInt":"30"}},
"removedFields": [],"truncatedArrays": []}}

FullDocument 옵션을 지정하지 않으면 동일한 업데이트 작업이 더 이상 변경 이벤트 문서에 "fullDocument" 값을 출력하지 않습니다.

API 문서

Watch() 메서드에 대해 자세히 알아보려면 다음 API 문서 링크를 참조하세요.

• 컬렉션용 Watch()

• 데이터베이스용 Watch()

• 클라이언트용 Watch()