Abrir Change Streams

Ejemplo

El siguiente ejemplo abre un flujo de cambios en la colección directors. El código imprime el tipo de operación y el documento modificado de cada evento de cambio accediendo a los campos operation_type y full_document de cada instancia ChangeStreamEvent:

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

Si inserta un documento en la colección directors en el que el valor name es "Wes Anderson", el código anterior produce el siguiente resultado:

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

Ejemplo

El siguiente ejemplo crea una pipeline de agregación para filtrar operaciones de actualización. Luego, el código pasa el pipeline al método watch(), configurando el flujo de cambios para que solo reciba e imprima eventos de cambios para operaciones de actualización:

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

Si actualizas el documento en el que el valor name es "Todd Haynes" aumentando el valor del campo oscar_noms, el siguiente código produce la siguiente salida:

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

Crea una colección con imagen previa y post-imágenes activadas

Para crear una colección con los documentos de preimagen y documentos post-imagen habilitados, configure esta opción en una instancia de estructura CreateCollectionOptions. Para empezar a crear una instancia CreateCollectionOptions, llama al método CreateCollectionOptions::builder().

Al configurar tu instancia de CreateCollectionOptions, debes utilizar el método builder change_stream_pre_and_post_images(). El siguiente ejemplo utiliza este método constructor para especificar opciones de colección y crea una colección para la que están disponibles imágenes previas y posteriores:

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

Puedes cambiar la opción de preimagen y postimagen en una colección existente ejecutando el comando collMod desde MongoDB Shell o desde tu aplicación. Para aprender cómo realizar esta operación, consulta la guía Ejecutar un comando y la entrada sobre collMod en el manual del servidor.

Ejemplo de Configuración Pre-Imagen

Para configurar un flujo de cambios que devuelva eventos de cambio que contengan la preimagen, especifica una instancia de ChangeStreamOptions. Para comenzar a crear una instancia de ChangeStreamOptions, llama al método ChangeStreamOptions::builder().

Al configurar tu instancia ChangeStreamOptions para que devuelva el documento pre-imagen, debes usar el método constructor full_document_before_change(). El siguiente ejemplo especifica las opciones del flujo de cambios y crea un flujo de cambios que devuelve documentos pre-imagen:

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

El ejemplo anterior pasa un valor de FullDocumentBeforeChangeType::Required al método constructor full_document_before_change(). Esta opción configura el flujo de cambios para que requiera preimágenes para los eventos de cambio de reemplazo, actualización y eliminación. Si la pre-imagen no está disponible, el controlador genera un error.

Si actualizas un documento en el que el valor de name es "Jane Campion", el evento de cambio produce el siguiente resultado:

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

Ejemplo de Configuración Posterior a la Imagen

Para configurar un flujo de cambios que devuelva eventos de cambio que contengan la postimagen, especifica una instancia de la estructura ChangeStreamOptions. Para empezar a construir una instancia de ChangeStreamOptions, llame al método ChangeStreamOptions::builder().

Cuando configures tu instancia de ChangeStreamOptions para devolver el documento post-imagen, debes usar el método full_document() builder. El siguiente ejemplo especifica las opciones de flujo de cambios y crea un flujo de cambios que devuelve documentos post-imagen:

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

El ejemplo anterior pasa un valor de FullDocument::WhenAvailable al método constructor full_document(). Esta opción configura el flujo de cambios para que devuelva posimágenes para eventos de cambio de reemplazo, actualización y eliminación si la posimagen está disponible.

Si elimina el documento en el que el valor de name es "Todd Haynes", el evento de cambio produce la siguiente salida:

Operation performed: Delete
Post-image: None

Documentación de la API

Para obtener más información sobre cualquiera de los métodos o tipos mencionados en esta guía, consulta la siguiente documentación API:

• ver()

• CreateCollectionOptions

• ChangeStreamOptions

• FullDocumentBeforeChangeType

• FullDocumentType