Copiar// Colección: visitas | DB: cobranza_demo db.visitas.aggregate([ { $match: { fecha: { $gte: ISODate("2026-01-20") } }}, { $group: { _id: "$gestor_id", total_visitas: { $sum: 1 }, pagos_efectivos: { $sum: { $cond: [{ $eq: ["$resultado", "pago_efectivo"] }, 1, 0] }}, monto_recuperado: { $sum: { $ifNull: ["$pago_realizado.monto", 0] }} }}, { $lookup: { // ← JOIN imposible en DynamoDB from: "gestores", localField: "_id", foreignField: "_id", as: "gestor" }}, { $unwind: "$gestor" }, { $project: { nombre: "$gestor.nombre", zona: "$gestor.zona", tasa_efectividad: { $multiply: [{ $divide: ["$pagos_efectivos", "$total_visitas"] }, 100] }, score_gestor: { $round: [{ $add: [/* fórmula compuesta */] }, 1] } }}, { $sort: { score_gestor: -1 } }, { $limit: 10 } ])

db.visitas.aggregate([...])
// Tiempo: ~8ms
// Costo: incluido en Atlas
// Joins: nativos con $lookup
// Analítica: en la misma DB

1. DynamoDB Streams → Lambda → S3
   (o Export to S3 nativo)
2. AWS Glue job (transformar)
3. Cargar a Redshift
4. SQL en Redshift
5. Resultado disponible

Tiempo: 1-3 horas
Costo: Lambda+Glue+Redshift+S3
       + ingeniería adicional

Copiar// Inteligencia Colectiva: qué oferta funciona por nivel de riesgo db.visitas.aggregate([ { $match: { resultado: { $in: ["pago_efectivo", "promesa_pago", "rechazo"] }}}, { $lookup: { // enriquecer con nivel de riesgo del deudor from: "deudores", localField: "deudor_id", foreignField: "_id", as: "deudor" }}, { $unwind: "$deudor" }, { $group: { _id: { nivel: "$deudor.credito.nivel_riesgo", oferta: "$oferta_presentada.codigo" }, total: { $sum: 1 }, exitosas:{ $sum: { $cond: [{ $in: ["$resultado", ["pago_efectivo", "promesa_pago"]] }, 1, 0] }} }}, { $project: { nivel_riesgo: "$_id.nivel", oferta: "$_id.oferta", tasa_exito: { $multiply: [{ $divide: ["$exitosas", "$total"] }, 100] } }}, { $sort: { tasa_exito: -1 } }, { $group: { _id: "$nivel_riesgo", mejor_oferta: { $first: "$oferta" }, tasa: { $first: "$tasa_exito" } }} ])

Copiar// GPS del gestor → deudores más cercanos con mayor urgencia db.deudores.aggregate([ { $geoNear: { // ← requiere índice 2dsphere near: { type: "Point", coordinates: [-99.1332, 19.4326] }, distanceField: "distancia_metros", maxDistance: 5000, // 5km radio spherical: true, query: { gestor_asignado: "GEST-00025", "credito.saldo_pendiente": { $gt: 0 } } }}, { $addFields: { score_urgencia: { $add: [ { $multiply: [{ $min: [{ $divide: ["$credito.dias_atraso", 180] }, 1] }, 60] }, { $multiply: [{ $min: [{ $divide: ["$credito.saldo_pendiente", 50000] }, 1] }, 30] } ]} }}, { $sort: { score_urgencia: -1 } }, { $limit: 8 }, { $project: { nombre: 1, coordenadas: "$ubicacion.coordenadas", saldo_pendiente: 1, dias_atraso: 1, nivel_riesgo: "$credito.nivel_riesgo", mejor_oferta: "$perfil_comportamiento.mejor_oferta_historica" }} ])