Supervisar los cambios en los datos

Overview

En esta guía, puedes aprender a utilizar un flujo de cambios para supervisar los cambios en tiempo real de tu base de datos. Un flujo de cambios es una funcionalidad de MongoDB Server que permite que la aplicación se suscriba a cambios en los datos de una colección, base de datos o implementación.

Cuando utilices el controlador de C++, puedes instanciar un mongocxx::change_stream para monitorear los cambios de datos.

auto db = client["sample_restaurants"];
auto collection = db["restaurants"];

Abre un flujo de cambios

Para abrir un flujo de cambios, llama al método watch(). La instancia en la que se llama al método watch() determina el alcance de los eventos para los que el flujo de cambios escucha. Puedes llamar al método watch() en las siguientes clases:

• mongocxx::client: Supervisa todos los cambios en la implementación de MongoDB

• mongocxx::database:Monitorear los cambios en todas las colecciones de la base de datos

• mongocxx::collectionSupervise los cambios en la colección

El siguiente ejemplo abre un flujo de cambios en la colección restaurants y genera los cambios a medida que ocurren:

auto stream = collection.watch();
while (true) {
    for (const auto& event : stream) {
        std::cout << bsoncxx::to_json(event) << std::endl;
    }
}

Para comenzar a observar los cambios, ejecuta el código anterior. Luego, en una aplicación o shell separado, modifica la colección restaurants. El siguiente ejemplo actualiza un documento que tiene un valor de campo name de Blarney Castle:

auto result = collection.update_one(make_document(kvp("name", "Blarney Castle")), 
                                    make_document(kvp("$set", 
                                    make_document(kvp("cuisine", "Irish")))));

Cuando actualizas la colección, la aplicación del flujo de cambios imprime el cambio a medida que ocurre. El evento de cambio impreso se asemeja al siguiente resultado:

{ "_id" : { "_data" : "..." }, "operationType" : "update", "clusterTime" :
{ "$timestamp" : { ... }, "wallTime" : { "$date" : ... }, "ns" :
{ "db" : "sample_restaurants", "coll" : "restaurants" }, "documentKey" :
{ "_id" : { "$oid" : "..." } }, "updateDescription" : { "updatedFields" :
{ "cuisine" : "Irish" }, "removedFields" : [  ], "truncatedArrays" : [  ] } }

Modificar la salida del flujo de cambios

Puedes pasar una instancia de mongocxx::pipeline como argumento al método watch() para modificar la salida del flujo de cambios. La siguiente lista incluye algunos de los campos mongocxx::pipeline que puedes configurar llamando a sus correspondientes métodos set:

• add_fields: añade nuevos campos a documentos

• matchFiltra los documentos

• project: Proyecta un subconjunto de los campos del documento

• redact:Restringe el contenido de los documentos

• group: Agrupa documentos por una expresión especificada

• merge: Emite los resultados a una colección

El siguiente ejemplo establece el campo match de una instancia mongocxx::pipeline y luego pasa la pipeline al método watch(). Esto le indica al método watch() que solo genere operaciones de actualización:

mongocxx::pipeline pipeline;
pipeline.match(make_document(kvp("operationType", "update")));
auto stream = collection.watch(pipeline);
while (true) {
    for (const auto& event : stream) {
        std::cout << bsoncxx::to_json(event) << std::endl;
    }
}

Modificar el comportamiento de watch()

Puede modificar el comportamiento del método watch() pasando una instancia de la clase mongocxx::options::change_stream como parámetro. La siguiente tabla describe los campos que puede configurar en una instancia mongocxx::options::change_stream:

mongocxx::options::change_stream opts;
opts.full_document("updateLookup");
auto stream = collection.watch(opts);
while (true) {
    for (const auto& event : stream) {
        std::cout << bsoncxx::to_json(event) << std::endl;
    }
}

{ "_id" : { "_data" : "..." }, "operationType" : "update", "clusterTime" :
{ "$timestamp" : { ... } }, "wallTime" : { "$date" : ... },
"fullDocument" : { "_id" : { "$oid" : "..." }, "address" : { "building" : "202-24",
"coord" : [ -73.925044200000002093, 40.559546199999999772 ], "street" :
"Rockaway Point Boulevard", "zipcode" : "11697" }, "borough" : "Queens", "cuisine" :
"Irish", "grades" : [ ... ], "name" : "Blarney Castle", "restaurant_id" : "40366356" },
"ns" : { "db" : "sample_restaurants", "coll" : "restaurants" }, "documentKey" :
{ "_id" : { "$oid" : "..." } }, "updateDescription" : { "updatedFields" :
{ "cuisine" : "Irish" }, "removedFields" : [  ], "truncatedArrays" : [  ] } }

Información Adicional

Para saber más sobre las change streams, consulta Change Streams en el manual de MongoDB Server.