sql >> Databasteknik >  >> NoSQL >> MongoDB

MapReduce aggregering baserat på attribut som finns utanför dokumentet

Jag gjorde detta genom att slå in MapReduce i något lagrat 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;
}

Irriterande och rörigt, men det fungerar, och jag kan inte tänka mig bättre.




  1. Anslutningssträng i MongoDB (med exempel)

  2. Kombinera flera grupper i en aggregering i mongodb

  3. Hur får man värden från Redis med hjälp av nycklar som innehåller mellanslag?

  4. Hur frågar du *korrekt* Redis från Tornado?