Aquí tengo una colección, digamos test , almacenando datos con un campo llamado timestamp de tiempo (en ms). Los documentos en esta colección están densamente insertados con un intervalo de timestamp de tiempo de 60000. Es decir, siempre puedo encontrar uno y solo un documento cuya timestamp de tiempo es 1 minuto antes que la referencia (excepto el primero, por supuesto). Ahora quiero realizar una unión para correlacionar cada documento con aquel cuya timestamp de tiempo es 1 minuto antes. He probado esta agregación:
... $lookup : { from: 'test', let : { lastTimestamp: '$timestamp'-60000 }, pipeline : [ {$match : {timestamp:'$timestamp'}} ], as: 'lastObjArr' }, ... que tiene la intención de encontrar la matriz del mismo documento y establecerlo como el valor de la clave lastObjArr . Pero, de hecho lastObjArr siempre está vacío. ¿Lo que pasó?
definiste una variable llamada "lastTimestamp" y la asignaste con
'$timestamp'-60000 Pero nunca lo usa, cambie su código de la siguiente manera, debería funcionar:
$lookup : { from: 'test', let : { lastTimestamp: '$timestamp'-60000 }, pipeline : [ {$match : {timestamp:'$$lastTimestamp'}} ], as: 'lastObjArr' },Su canalización $lookup está incompleta porque le faltan los operadores matemáticos necesarios. Para empezar, lastObjArr está vacío debido a una serie de factores, uno de ellos es que la expresión
let : { lastTimestamp: '$timestamp'-60000 }, no evalúa correctamente, necesita usar el operador $subtract
let : { lastTimestamp: { $subtract: ['$timestamp', 60000] } }, Además, el paso de canalización $match necesita usar el operador $expr junto con $eq para que funcione la consulta, es decir
$lookup : { from: 'test', let : { lastTimestamp: { $subtract: ['$timestamp', 60000] } }, pipeline : [ { $match : { $expr: { $eq: ['$timestamp', '$$lastTimestamp'] } } } ], as: 'lastObjArr' }