Change Streams 열기

예시

이 예제에서는 myColl collection에서 change stream을 열고 change stream 이벤트가 발생할 때 출력하는 방법을 보여 줍니다.

드라이버는 ChangeStreamIterable 유형의 변수에 change stream 이벤트를 저장합니다. 다음 예제에서는 드라이버가 ChangeStreamIterable 객체를 Document 유형으로 채워야 한다고 지정합니다. 결과적으로 드라이버는 개별 change stream 이벤트를 ChangeStreamDocument 객체로 저장합니다.

MongoCollection<Document> collection = database.getCollection("myColl");
ChangeStreamIterable<Document> changeStream = collection.watch();
changeStream.forEach(event ->
        System.out.println("Received a change: " + event));

collection에 대한 삽입 작업은 다음과 같은 출력을 생성합니다.

Received a change: ChangeStreamDocument{
   operationType=insert,
   resumeToken={"_data": "..."},
   namespace=myDb.myColl,
   ...
}

실행 가능한 예시 는 Watch for Changes 사용 예시 페이지를 참조하세요.

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

• MongoCollection.watch()

• MongoDatabase.watch()

• MongoClient.watch()

예시

다음 코드 예제에서는 집계 파이프라인을 적용하여 삽입 및 업데이트 작업에 대해서만 이벤트를 수신하도록 change stream을 구성하는 방법을 보여 줍니다.

MongoCollection<Document> collection = database.getCollection("myColl");
List<Bson> pipeline = Arrays.asList(
        Aggregates.match(Filters.in("operationType", Arrays.asList("insert", "update"))));
ChangeStreamIterable<Document> changeStream = collection.watch(pipeline);
changeStream.forEach(event ->
        System.out.println("Received a change to the collection: " + event));

collection에 대한 업데이트 작업은 다음과 같은 출력을 생성합니다.

Received a change: ChangeStreamDocument{
   operationType=update,
   resumeToken={"_data": "..."},
   namespace=myDb.myColl,
   ...
}

사전 이미지 및 사후 이미지를 활성화하여 collection 만들기

드라이버를 사용하여 사전 이미지 및 사후 이미지 옵션이 활성화된 collection을 생성하려면 ChangeStreamPreAndPostImagesOptions createCollection() 다음 예와 같이 인스턴스를 지정하고 메서드를 호출합니다.

CreateCollectionOptions collectionOptions = new CreateCollectionOptions();
collectionOptions.changeStreamPreAndPostImagesOptions(new ChangeStreamPreAndPostImagesOptions(true));
database.createCollection("myColl", collectionOptions);

MongoDB Shell에서 collMod 명령을 실행하여 기존 컬렉션의 사전 이미지 및 사후 이미지 옵션을 변경할 수 있습니다. 이 작업을 수행하는 방법을 알아보려면 MongoDB Server 매뉴얼의 collMod 항목을 참조하세요.

사전 이미지 구성 예시

다음 코드 예시에서는 사전 myColl 이미지를 포함하고 이벤트를 출력하도록 collection에서 change stream을 구성하는 방법을 보여 줍니다.

MongoCollection<Document> collection = database.getCollection("myColl");
ChangeStreamIterable<Document> changeStream = collection.watch()
        .fullDocumentBeforeChange(FullDocumentBeforeChange.REQUIRED);
changeStream.forEach(event ->
        System.out.println("Received a change: " + event));

앞의 예에서는 FullDocumentBeforeChange.REQUIRED 옵션을 사용하도록 change stream을 구성합니다. 이 옵션은 교체, 업데이트 및 삭제 이벤트에 대해 사전 이미지를 요구하도록 change stream을 구성합니다. 사전 이미지를 사용할 수 없는 경우 드라이버에서 오류가 발생합니다.

문서의 amount 필드 값을 150 에서 2000 로 업데이트한다고 가정해 보겠습니다. 이 변경 이벤트는 다음과 같은 출력을 생성합니다.

Received a change: ChangeStreamDocument{
   operationType=update,
   resumeToken={"_data": "..."},
   namespace=myDb.myColl,
   destinationNamespace=null,
   fullDocument=null,
   fullDocumentBeforeChange=Document{{_id=..., amount=150, ...}},
   ...
}

옵션 목록은 FullDocumentBeforeChange 를 참조하세요. API 문서.

사후 이미지 구성 예시

다음 코드 예시에서는 사전 myColl 이미지를 포함하고 이벤트를 출력하도록 collection에서 change stream을 구성하는 방법을 보여 줍니다.

MongoCollection<Document> collection = database.getCollection("myColl");
ChangeStreamIterable<Document> changeStream = collection.watch()
        .fullDocument(FullDocument.WHEN_AVAILABLE);
changeStream.forEach(event ->
        System.out.println("Received a change: " + event));

앞의 예에서는 FullDocument.WHEN_AVAILABLE 옵션을 사용하도록 change stream을 구성합니다. 이 옵션은 사용 가능한 경우 교체 및 업데이트 이벤트에 대해 수정된 문서의 사후 이미지를 반환하도록 change stream을 구성합니다.

문서의 color 필드 값을 "purple" 에서 "pink" 로 업데이트한다고 가정해 보겠습니다. 변경 이벤트는 다음과 같은 출력을 생성합니다.

Received a change: ChangeStreamDocument{
   operationType=update,
   resumeToken={"_data": "..."},
   namespace=myDb.myColl,
   destinationNamespace=null,
   fullDocument=Document{{_id=..., color=purple, ...}},
   updatedFields={"color": purple},
   ...
}

옵션 목록은 FullDocument 를 참조하세요. API 문서.