MongoDB MapReduce 就地更新如何

Question

*基本上，我试图根据过去一小时内的分数对对象进行排序。

我正在尝试为数据库中的对象生成每小时的投票总和。投票被嵌入到每个对象中。对象架构如下所示：

{
    _id: ObjectId
    score: int
    hourly-score: int <- need to update this value so I can order by it
    recently-voted: boolean
    votes: {
        "4e4634821dff6f103c040000": { <- Key is __toString of voter ObjectId
            "_id": ObjectId("4e4634821dff6f103c040000"), <- Voter ObjectId
            "a": 1, <- Vote amount
            "ca": ISODate("2011-08-16T00:01:34.975Z"), <- Created at MongoDate
            "ts": 1313452894 <- Created at timestamp
        },
        ... repeat ...
    }
}

这个问题实际上与我几天前问的一个问题有关 在 MongoDB 中建模投票系统的最佳方式

我如何（我可以？）运行 MapReduce 命令来执行以下操作：

1. 仅在最近投票 = true 或每小时的对象上运行-分数> 0.
2. 计算最近一小时内创建的投票总数。
3. 更新每小时分数 = 上面计算的总和，最近投票 = false。

我还阅读了此处，我可以执行通过在 M/R 命令之前运行 db.getMongo().setSlaveOk() 在从数据库上进行 MapReduce。我可以在从属设备上运行reduce并更新主数据库吗？

使用 Mongo MapReduce 是否可以进行就地更新？

Answer 1

你绝对可以做到这一点。我将逐一解答您的问题：

1.
您可以与映射缩减一起指定查询，它会过滤将传递到映射阶段的对象集。在 mongo shell 中，这看起来像（假设 m 和 r 分别是映射器和化简器函数的名称）：

> db.coll.mapReduce(m, r, {query: {$or: [{"recently-voted": true}, {"hourly-score": {$gt: 0}}]}})

2.
第 1 步将让您对过去一小时内至少有一次投票（或将 recently-voted 设置为 true）的所有文档使用映射器，但并非所有投票都在最后小时。因此，您需要在映射器中过滤列表，并且仅发出您想要计数的那些选票：

function m() {
  var hour_ago = new Date() - 3600000;
  this.votes.forEach(function (vote) {
    if (vote.ts > hour_ago) {
      emit(/* your key */, this.vote.a);
    }
  });
}

并减少：

function r(key, values) {
  var sum = 0;
  values.forEach(function(value) { sum += value; });
  return sum;
}

3。
要更新每小时分数表，您可以使用reduceOutput选项进行map-reduce，这将使用发出的值和输出集合中先前保存的值（如果有）调用您的reducer 。该传递的结果将保存到输出集合中。这看起来像：

> db.coll.mapReduce(m, r, {query: ..., out: {reduce: "output_coll"}})

除了重新减少输出之外，您还可以使用 merge ，它将用新创建的文档覆盖输出集合中的文档（但留下任何带有 _id 的文档> 与 mr 作业创建的 _id 不同），replace，这实际上是一个删除并创建操作，并且是默认操作，或者使用 { inline: 1}，这将返回结果直接到 shell 或您的驱动程序。请注意，使用 {inline: 1} 时，您的结果必须符合单个文档允许的大小（在最新的 MongoDB 版本中为 16MB）。

(4.)
您可以在辅助节点（“从属”）上运行 Map-Reduce 作业，但由于辅助节点无法接受写入（这就是它们成为辅助节点的原因），因此您只能在使用内联输出时执行此操作。