MongoDB
Explica cómo filtrar, seleccionar y calcular campos con $match, $project y $set, ordenando stages para reducir trabajo y mantener claridad.
, y forman el núcleo de muchas pipelines. reduce documentos, define la forma de salida y añade o reemplaza campos conservando el resto.
$match$project$set$match$project$set$match
→ qué documentos continúan
$set
→ qué valores se calculan o corrigen
$project
→ qué forma sale de la etapaAunque parecen sencillos, su ubicación determina índices, cantidad de trabajo, tipos disponibles y legibilidad.
Utiliza sintaxis de query para filtrar:
{
$match: {
businessId,
status: 'confirmed',
confirmedAt: { $gte: start, $lt: end }
}
}Cuando aparece al inicio, puede aprovechar un índice compatible. Debe incluir tenant y restricciones de seguridad igual que una query normal.
1.000.000 documentos
→ $match reduce a 5.000
→ stages posteriores procesan 5.000Moverlo después de $unwind, $lookup o $group puede multiplicar trabajo.
Si filtras un campo creado por $set, el $match debe ir después:
[
{
$set: {
lineTotal: { $multiply: ['$quantity', '$price'] }
}
},
{
$match: {
lineTotal: { $gte: Decimal128('100000.00') }
}
}
]Ese match no puede usar un índice original sobre lineTotal porque el campo se calcula durante la pipeline.
Define qué campos permanecen, se renombran o se calculan.
{
$project: {
_id: 0,
id: { $toString: '$_id' },
customerName: '$customer.nameAtPurchase',
total: 1,
confirmedAt: 1
}
}Puede:
No proyectes fuera un campo que un stage posterior necesita.
$set conserva campos actuales y añade o reemplaza valores:
{
$set: {
subtotal: {
$sum: {
$map: {
input: '$items',
as: 'item',
in: {
$multiply: ['$$item.quantity', '$$item.unitPrice']
}
}
}
},
processedAt: '$$NOW'
}
}Es equivalente a $addFields en propósito general. Elegir uno es principalmente cuestión de claridad y estilo del equipo.
Documento de entrada:
{
_id,
name: 'Café',
price: 10000,
cost: 7000,
internalCode: 'X'
}$set:
{
$set: {
margin: { $subtract: ['$price', '$cost'] }
}
}Salida conserva todos los campos y añade margin.
$project:
{
$project: {
name: 1,
margin: { $subtract: ['$price', '$cost'] }
}
}Salida contiene _id, name y margin, salvo exclusión de _id.
Para expresiones complejas, usa $set en pasos:
[
{
$set: {
subtotal: { $sum: '$items.subtotal' }
}
},
{
$set: {
tax: { $multiply: ['$subtotal', Decimal128('0.19')] }
}
},
{
$set: {
total: { $add: ['$subtotal', '$tax'] }
}
}
]Es más fácil verificar que una expresión profundamente anidada.
Dentro de projections condicionales, $$REMOVE puede omitir un campo:
{
$project: {
name: 1,
discount: {
$cond: [
{ $gt: ['$discount', 0] },
'$discount',
'$$REMOVE'
]
}
}
}Esto distingue omitir de devolver null.
Schema inconsistente:
{ price: '10000' }
{ price: 10000 }
{ price: Decimal128('10000.00') }Conversión controlada:
{
$set: {
normalizedPrice: {
$convert: {
input: '$price',
to: 'decimal',
onError: null,
onNull: null
}
}
}
}Después puedes separar inválidos:
{
$match: {
normalizedPrice: { $ne: null }
}
}No conviertas silenciosamente datos inválidos en cero, porque altera métricas.
$ifNull acepta fallback:
{
$set: {
displayName: {
$ifNull: ['$name', 'Sin nombre']
}
}
}Pero null y missing pueden representar situaciones diferentes. Para auditoría usa $type antes de decidir un default.
{
$set: {
day: {
$dateTrunc: {
date: '$confirmedAt',
unit: 'day',
timezone: 'America/Bogota'
}
}
}
}La zona horaria forma parte del cálculo. Agrupar UTC sin considerar el negocio puede asignar ventas a un día local incorrecto.
Filtrar elementos sin $unwind:
{
$set: {
expensiveItems: {
$filter: {
input: '$items',
as: 'item',
cond: {
$gte: ['$$item.unitPrice', Decimal128('50000.00')]
}
}
}
}
}Esto conserva un documento por orden, a diferencia de $unwind.
Reducir campos temprano puede ayudar, pero el optimizador ya puede eliminar campos innecesarios en algunos casos. No añadas $project inicial únicamente por superstición. Úsalo para claridad, seguridad o una transformación necesaria y verifica el plan.
No permitas que el cliente decida expressions o paths arbitrarios. Una projection dinámica podría exponer:
Construye vistas permitidas en código.
$set puede reemplazar accidentalmente un campo original necesario.
Mezclar inclusión y exclusión genera error salvo _id y casos específicos.
Sin onError, $convert puede detener la pipeline.
Una expression puede devolver null, missing o error según operador.
Las rutas usan dot notation; schemas con nombres problemáticos dificultan acceso.
Calcular antes de filtrar puede impedir index use.
Añade ruido y puede ocultar dependencias.
Multiplica trabajo.
Un campo decimal se reemplaza por double accidentalmente.
Contamina reportes.
Comparten nombre, pero uno es stage de aggregation y otro operador de escritura.
Permite acceso a campos no autorizados.
explain() para el $match inicial.$match controla cardinalidad, $set construye valores y $project define forma. El orden debe reflejar dependencias y rendimiento. Filtrar temprano y convertir tipos explícitamente suele ser correcto, pero toda optimización debe verificarse con el plan y datos reales.
$match puede usar índice?$set y $project?$filter en vez de $unwind?$group y acumuladores.