Agregación

Comparar las operaciones de agregación y búsqueda

Se pueden utilizar las operaciones de búsqueda para realizar las siguientes acciones:

• Seleccione qué documentos devolver

• Seleccione qué campos devolver

• Ordenar los resultados

Puedes utilizar operaciones de agregación para realizar las siguientes acciones:

• Realizar operaciones de búsqueda

• Cambiar el nombre de los campos

• Calcular campos

• Resumir datos

• Valores del grupo

Limitaciones

Las siguientes limitaciones se aplican al utilizar operaciones de agregación:

• Los documentos devueltos no deben violar la Límite de tamaño de documento BSON de 16 megabytes.

• Las etapas del pipeline tienen un límite de memoria de 100 megabytes por defecto. Puedes superar este límite estableciendo el allowDiskUse opción para true.

Compilar y ejecutar un pipeline de agregación

Para realizar una agregación en los documentos de una colección, pasa una estructura bson_t que represente las etapas del pipeline a la función mongoc_collection_aggregate().

Este ejemplo genera un recuento del número de panaderías en cada distrito de la ciudad de Nueva York. El siguiente código crea una pipeline de agregación que contiene las siguientes etapas:

• Una $match etapa para filtrar los documentos en los que el valor del campo cuisine es "Bakery".

• Una etapa $group para agrupar los documentos coincidentes por el campo borough, produciendo un recuento de documentos para cada valor distinto de ese campo.

const bson_t *doc;
bson_t *pipeline = BCON_NEW("pipeline",
    "[", 
    "{", "$match", "{", "cuisine", BCON_UTF8("Bakery"), "}", "}",
    "{", "$group", "{", 
        "_id", BCON_UTF8("$borough"), "count", "{", "$sum", BCON_INT32(1), "}", "}",
    "}",
    "]");
mongoc_cursor_t *results =
    mongoc_collection_aggregate(collection, MONGOC_QUERY_NONE, pipeline, NULL, NULL);
bson_error_t error;
if (mongoc_cursor_error(results, &error))
{
    fprintf(stderr, "Aggregate failed: %s\n", error.message);
} else {
    while (mongoc_cursor_next(results, &doc)) {
        char *str = bson_as_canonical_extended_json(doc, NULL);
        printf("%s\n", str);
        bson_free(str);
    }
}
bson_destroy(pipeline);
mongoc_cursor_destroy(results);

{ "_id" : "Queens", "count" : { "$numberInt" : "204" } }
{ "_id" : "Staten Island", "count" : { "$numberInt" : "20" } }
{ "_id" : "Missing", "count" : { "$numberInt" : "2" } }
{ "_id" : "Bronx", "count" : { "$numberInt" : "71" } }
{ "_id" : "Brooklyn", "count" : { "$numberInt" : "173" } }
{ "_id" : "Manhattan", "count" : { "$numberInt" : "221" } }

Explica una agregación

Para ver información sobre cómo MongoDB ejecuta su operación, puede ejecutar la operación explain en su pipeline. Cuando MongoDB explica una operación, devuelve planes de ejecución y estadísticas de rendimiento. Un plan de ejecución es una forma potencial en la que MongoDB puede completar una operación. Cuando le indicas a MongoDB que explique una operación, devuelve tanto el plan que MongoDB seleccionó para la operación, como cualquier plan de ejecución rechazado.

El siguiente ejemplo de código ejecuta la misma agregación mostrada en la sección anterior, pero utiliza la función mongoc_client_command_simple() para explicar los detalles de la operación:

bson_t reply;
bson_error_t error;
bson_t *command = BCON_NEW(
    "aggregate", BCON_UTF8("restaurants"),
    "explain", BCON_BOOL(true),
    "pipeline",
    "[",
    "{", "$match", "{", "cuisine", BCON_UTF8("Bakery"), "}", "}",
    "{", "$group", "{",
         "_id", BCON_UTF8("$borough"), "count", "{", "$sum", BCON_INT32(1), "}", "}",
    "}",
    "]");
if (mongoc_client_command_simple(client, "sample_restaurants", command, NULL, &reply, &error)) {
    char *str = bson_as_canonical_extended_json(&reply, NULL);
    printf("%s\n", str);
    bson_free(str);
} else {
    fprintf(stderr, "Command failed: %s\n", error.message);
}
bson_destroy(command);
bson_destroy(&reply);

{
  "explainVersion": "2",
  "queryPlanner": {
      "namespace": "sample_restaurants.restaurants"
      "indexFilterSet": false,
      "parsedQuery": {
        "cuisine": {"$eq": "Bakery"}
      },
      "queryHash": "865F14C3",
      "planCacheKey": "0697561B",
      "optimizedPipeline": true,
      "maxIndexedOrSolutionsReached": false,
      "maxIndexedAndSolutionsReached": false,
      "maxScansToExplodeReached": false,
      "winningPlan": { ... },
      "rejectedPlans": []
      ...
  }
  ...
}

Documentación de la API

Para obtener más información sobre cómo ejecutar operaciones de agregación con el controlador C, consulte la siguiente documentación de API:

• mongoc_collection_aggregate()

• mongoc_client_command_simple()