基于文档外部包含的属性的 MapReduce 聚合

Question

假设我有一个“活动”集合，每个活动都有名称、成本和位置：

{_id : 1 , name: 'swimming', cost: '3.40', location: 'kirkstall'}
{_id : 2 , name: 'cinema', cost: '6.50', location: 'hyde park'}
{_id : 3 , name: 'gig', cost: '10.00', location: 'hyde park'}

我还有一个 people 集合，其中记录了每项活动他们计划进行的次数ayear：

{_id : 1 , name: 'russell', activities : { {1 : 9} , {2 : 4} , {3 : 21} }}

出于多种原因，我不想通过将活动属性放入人员集合中来对活动属性进行非规范化。

首先，这是关于规划的，因此如果活动的成本发生变化，人员集合中的成本也需要发生变化。所以我必须更新所有人员记录。

其次，我可能希望在某个时候向活动集合添加一些其他属性，并且希望避免在这样做时必须将它们添加到人员集合中每个记录中的每个活动中。

但是，现在我想做一个 MapReduce 来找出所有人总共计划了多少活动，并按位置分组。

这意味着在对人员集合进行 MapReduce 期间，我需要知道他们计划的活动的位置。有人能想出一个好方法来做到这一点吗？

我目前最好的办法（这非常垃圾）是创建一个存储的 JavaScript 函数，该函数接受 Activity_ids 数组，查询 Activity 集合，并将 Activity_id 的映射返回到位置。然后我将其粘贴到 map 函数中并从中查找位置。正如我所说，这将是非常垃圾的，因为对 activities 集合的相同查询将为 people 集合中的每个项目运行一次。

Answer 1

我通过将 MapReduce 包装在一些存储的 javascript 中来做到这一点。

function (query) {

  var one = db.people.findOne(query);
  var activity_ids = [];
  for (var k in one.activities){
    activity_ids.push(parseInt(k));
  }

  var activity_location_map = {};
  db.activities.find({id : {$in : activity_ids}}).forEach(function(a){
    activity_location_map[a.id] = a.location;
  });


  return db.people.mapReduce(
    function map(){
      for (var k in this.activities){
        emit({location : activity_location_map[k]} , { total: this.activities[k] });
        emit({location: activity_location_map[k]} , { total: this.activities[k] });
      }
    },
    function reduce(key, values){
      var reduced = {total: 0};
      values.forEach(function(value){
        reduced.total += value.total;
      });

      return reduced;
    },
    {out : {inline: true}, scope : { activity_location_map : activity_location_map }}
  ).results;
}

烦人，而且混乱，但它有效，而且我想不出更好的了。