javascript - MongoDB mapReduce 每分钟文档计数由附加类别字段分隔

Question

我有一个具有以下架构的 MongoDB 集合:

const MessageSchema = {
 message: {type: String},
 category: {type String, allowedValues: ['a', 'b', 'c', 'd', 'e']},
 createdAt: {type: Date}
}

这些消息文档是在随机时间间隔创建的。我想创建一个图表所需的数据集，该图表绘制每个类别的每分钟消息数(计数)。输出将是一个包含键 time、a.count、b.count、c.count、d.count 和 e.count 的对象数组。生成的数据集应仅考虑上周的数据，而不是更早的数据。

数据集可能非常大。

我想我可以用 db.collection.mapReduce 做到这一点。我找到了一个适用于所有消息的解决方案，但不是按类别分开的。指向正确方向的指针将不胜感激。

Answer 1

当您可以通过简单的聚合做到这一点时，没有理由使用 mapReduce:

db.messages.aggregate([
  {$match: { createdAt: { $gte: ISODate('2018-01-01') } }},
  {$group: {
        _id: {date: {$dateFromParts:{
                year: { $year: "$createdAt" },
                month: { $month: "$createdAt" },
                day: { $dayOfMonth: "$createdAt" },
                hour: { $dayOfMonth: "$createdAt" },
                minute: { $minute: "$createdAt" }
             }},
             category: "$category"
        },
        count: { $sum: 1 }
    }
  }
])