문서 메뉴
문서 홈
/
언어
/
Go
/
Go 드라이버
/
사용 예

데이터 변경 사항 모니터링

Watch() 메서드를 사용하여 MongoCollection, MongoDatabase 또는 MongoClient 에서 change stream을 열 수 있습니다.

예제

팁

이 예제를 실행하는 방법을 알아보려면 사용 예제 를 읽어보세요.

다음 예제에서는 restaurants collection에서 change stream을 열고 삽입된 문서를 인쇄합니다.

coll := client.Database("sample_restaurants").Collection("restaurants")
// Creates instructions to watch for insert operations
pipeline := mongo.Pipeline{bson.D{{"$match", bson.D{{"operationType", "insert"}}}}}
// Creates a change stream that receives change events
cs, err := coll.Watch(context.TODO(), pipeline)
if err != nil {
	panic(err)
}
defer cs.Close(context.TODO())
fmt.Println("Waiting For Change Events. Insert something in MongoDB!")
// Prints a message each time the change stream receives an event
for cs.Next(context.TODO()) {
	var event bson.M
	if err := cs.Decode(&event); err != nil {
		panic(err)
	}
	output, err := json.MarshalIndent(event["fullDocument"], "", "    ")
	if err != nil {
		panic(err)
	}
	fmt.Printf("%s\n", output)
}
if err := cs.Err(); err != nil {
	panic(err)
}

완전히 실행 가능한 예시를 확인합니다.

예상 결과

전체 예제를 실행한 후 다른 shell에서 문서 삽입 사용 예제를 실행합니다. 삽입 작업을 실행하면 다음과 같은 출력이 표시됩니다.

// results truncated
{
  "_id": ...,
  "name": "8282",
  "cuisine": "Korean"
}

중요

작업을 마친 후에는 터미널을 닫아 이 사용 예시를 종료합니다.

추가 정보

변경 스트림을 열고 잠재적인 오류를 처리하는 방법에 대해 자세히 알아보려면 다음을 참조하세요.

API 문서

watch()

← 대량 작업 수행
문서 수 계산 →