$group

La fase de $group agregación de Amazon DocumentDB le permite agrupar documentos según una expresión específica y realizar varias operaciones acumulativas en los datos agrupados. Esto puede resultar útil para tareas como el cálculo de totales, promedios u otras estadísticas basadas en los datos agrupados.

Parámetros

• _id: especifica la expresión con la que se deben agrupar los documentos de entrada. Puede ser un nombre de campo, una expresión calculada o una combinación de ambos.

• accumulator expressions: (opcional) Una o más expresiones acumuladoras que se deben aplicar a los datos agrupados. Estas expresiones utilizan los operadores acumuladores mencionados anteriormente.

Ejemplo (MongoDB Shell)

El siguiente ejemplo agrupa a los clientes por ciudad y calcula el importe total del pedido para cada ciudad.

Crea documentos de muestra

db.customers.insertMany([
  { name: "John Doe", city: "New York", orders: [{ amount: 100 }, { amount: 200 }] },
  { name: "Jane Smith", city: "Los Angeles", orders: [{ amount: 150 }, { amount: 300 }] },
  { name: "Bob Johnson", city: "New York", orders: [{ amount: 75 }, { amount: 125 }] },
  { name: "Samantha Lee", city: "Chicago", orders: [{ amount: 50 }, { amount: 100 }] }
]);

Ejemplo de consulta

db.customers.aggregate([
  {
    $group: {
      _id: "$city",
      totalOrders: { $sum: { $sum: "$orders.amount" } }
    }
  }
]);

Salida

[
  { _id: 'Chicago', totalOrders: 150 },
  { _id: 'Los Angeles', totalOrders: 450 },
  { _id: 'New York', totalOrders: 500 }
]

Ejemplos de código

Para ver un ejemplo de código sobre el uso del $group comando, elige la pestaña del idioma que quieres usar:

Node.js

const { MongoClient } = require('mongodb');

async function groupByCity() {
  const uri = 'mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false';
  const client = new MongoClient(uri);

  try {
    await client.connect();
    const db = client.db('test');
    const result = await db.collection('customers').aggregate([
      { $unwind: '$orders' },
      {
        $group: {
          _id: '$city',
          totalOrders: { $sum: '$orders.amount' }
        }
      }
    ]).toArray();

    console.log(result);
  } catch (err) {
    console.error('Error during aggregation:', err);
  } finally {
    await client.close();
  }
}

groupByCity();

Python

from pymongo import MongoClient

def group_by_city():
    client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false')
    
    try:
        db = client.test
        result = list(db.customers.aggregate([
            {'$unwind': '$orders'},
            {
                '$group': {
                    '_id': '$city',
                    'totalOrders': {'$sum': '$orders.amount'}
                }
            }
        ]))
        print(result)
    except Exception as e:
        print(f"Error during aggregation: {e}")
    finally:
        client.close()

group_by_city()