Supervisar los cambios en los datos

Overview

En esta guía, aprenderá a usar un flujo de cambios para supervisar los cambios en tiempo real en su base de datos. Un flujo de cambios es una función de MongoDB Server que permite que su aplicación se suscriba a los cambios en los datos de una colección, base de datos o implementación.

Al utilizar el controlador C++, puede crear una instancia de 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, llame al método watch(). La instancia en la que llama al método watch() determina el alcance de los eventos que el flujo de cambios escucha. Puede llamar al método watch() en las siguientes clases:

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

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

• mongocxx::collection:Monitorear 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")))));

Al actualizar la colección, la aplicación de flujo de cambios imprime el cambio a medida que se produce. El evento de cambio impreso se parece al siguiente:

{ "_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

Puede pasar una instancia 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 puede configurar llamando a sus métodos de configuración correspondientes:

• add_fields:Agrega nuevos campos a los documentos

• match:Filtra los documentos

• project: Proyecta un subconjunto de los campos del documento

• redact:Restringe el contenido de los documentos

• group: Agrupa documentos mediante una expresión específica

• merge: Envía los resultados a una colección

El siguiente ejemplo establece el campo match de una instancia mongocxx::pipeline y luego pasa la canalización al método watch(). Esto 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 watch() el comportamiento

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::find:

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 obtener más información sobre los flujos de cambio, consulte Flujos de cambio en el manual de MongoDB Server.