Change Stream 열기

개요

이 가이드에서는 change stream을 사용하여 데이터의 실시간 변경 사항을 모니터링하는 방법을 배울 수 있습니다. change stream은 애플리케이션이 단일 collection, 데이터베이스 또는 배포에서 데이터 변경 사항을 구독할 수 있도록 하는 MongoDB Server 기능입니다.

다음 조치를 수행하는 데 도움이 되는 change stream을 열 수 있습니다.

• 디바이스가 동작 감지 카메라와 같은 이벤트를 추적하고 React 수 있도록 합니다.

• 주가 변화를 모니터링하는 애플리케이션 만들기

• 특정 작업에 대한 직원 활동 로그 생성

애그리게이션 연산자 세트를 지정하여 애플리케이션이 수신하는 데이터를 필터링하고 변환할 수 있습니다. MongoDB deployment v6.0 이상에 연결된 경우 변경 전후의 문서 데이터를 포함하도록 이벤트를 구성할 수도 있습니다.

change stream을 열고 구성하는 방법을 알아보려면 다음 섹션으로 이동하세요.

• 샘플 데이터

• Change Stream 열기

• change stream에 애그리게이션 연산자 적용

• 사전 이미지 및 사후 이미지 포함하기

• 추가 정보

샘플 데이터

이 가이드의 예에서는 directors collection의 변경 사항을 모니터링합니다. 이 collection에 구조체로 모델링된 다음 문서가 포함되어 있다고 가정합니다.

let docs = vec! [
    Director {
        name: "Todd Haynes".to_string(),
        movies: vec! ["Far From Heaven".to_string(), "Carol".to_string()],
        oscar_noms: 1,
    },
    Director {
        name: "Jane Campion".to_string(),
        movies: vec! ["The Piano".to_string(), "Bright Star".to_string()],
        oscar_noms: 5,
    }
];

Change Stream 열기

change stream을 열어 특정 유형의 데이터 변경 사항을 구독하고 애플리케이션에서 변경 이벤트를 생성할 수 있습니다.

change stream을 열려면 Collection, Database 또는 Client 인스턴스에서 watch() 메서드를 호출합니다.

watch() 메서드를 호출하는 구조체 유형에 따라 change stream이 수신하는 이벤트 범위가 결정됩니다. 다음 표에서는 호출 객체에 따른 watch() 메서드의 동작을 설명합니다.

let mut change_stream = my_coll.watch().await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Document: {:?}", event.full_document);
}

Operation performed: Insert
Document: Some(Director { name: "Wes Anderson", movies: [...], oscar_noms: 7 })

change stream에 애그리게이션 연산자 적용

pipeline() 메서드를 watch() 메서드에 연결하여 변경 스트림이 수신할 변경 이벤트를 지정할 수 있습니다. 집계 파이프라인을 pipeline() 에 매개 변수로 전달합니다.

사용 중인 MongoDB Server 버전에서 지원하는 애그리게이션 연산자를 알아보려면 서버 매뉴얼의 변경 스트림 출력 수정 을 참조하세요.

let mut update_change_stream = my_coll.watch()
    .pipeline(vec![doc! { "$match" : doc! { "operationType" : "update" } }])
    .await?;
while let Some(event) = update_change_stream.next().await.transpose()? {
    println!("Update performed: {:?}", event.update_description);
}

Update performed: Some(UpdateDescription { updated_fields: Document({
"oscar_noms": Int64(2)}), removed_fields: [], truncated_arrays: Some([]) })

사전 이미지 및 사후 이미지 포함하기

다음 데이터를 포함하거나 생략하도록 변경 이벤트를 구성할 수 있습니다.

• 사전 이미지: 작업 전의 문서의 버전을 나타내는 문서(있는 경우)

• 사후 이미지: 작업 후의 문서의 버전을 나타내는 문서(있는 경우)

사전 이미지 또는 사후 이미지가 포함된 변경 스트림 이벤트를 수신하려면 다음 작업을 수행해야 합니다.

• MongoDB deployment에서 collection에 대한 사전 이미지 및 사후 이미지를 활성화합니다.

  팁

  배포에서 사전 및 사후 이미지를 활성화하는 방법에 대한 자세한 내용은 서버 설명서의 Change Streams with Document Pre- and Post-Images(이미지 사전 및 사후 문서화의 Change Streams)를 참조하세요.

  사전 이미지 및 사후 이미지가 활성화된 컬렉션을 생성하도록 드라이버에 지시하는 방법을 알아보려면 이 페이지의 사전 이미지 및 사후 이미지가 활성화된 컬렉션 생성 섹션을 참조하세요.

• 사전 이미지와 사후 이미지 중 하나 또는 둘 다를 검색하도록 change stream을 구성합니다. 이 구성 중에 사전 및 사후 이미지를 요구하거나 사용 가능한 경우에만 포함하도록 드라이버에 지시할 수 있습니다.

  팁

  변경 이벤트에 사전 이미지를 기록하도록 변경 스트림을 구성하려면 이 페이지의 사전 이미지 구성 예시 를 참조하세요.

  변경 이벤트의 사후 이미지를 기록하도록 변경 스트림을 구성하려면 이 페이지의 사후 이미지 구성 예제 를 참조하세요.

let enable = ChangeStreamPreAndPostImages::builder().enabled(true).build();
let result = my_db.create_collection("directors")
    .change_stream_pre_and_post_images(enable)
    .await?;

let pre_image = FullDocumentBeforeChangeType::Required;
let mut change_stream = my_coll.watch()
    .full_document_before_change(pre_image)
    .await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Pre-image: {:?}", event.full_document_before_change);
}

Operation performed: Update
Pre-image: Some(Director { name: "Jane Campion", movies: ["The Piano",
"Bright Star"], oscar_noms: 5 })

let post_image = FullDocumentType::WhenAvailable;
let mut change_stream = my_coll.watch()
    .full_document(post_image)
    .await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Post-image: {:?}", event.full_document);
}

Operation performed: Delete
Post-image: None

추가 정보