sql >> Database >  >> NoSQL >> MongoDB

MapReduce-aggregatie op basis van attributen buiten het document

Ik deed dit door MapReduce in een opgeslagen javascript te verpakken.

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;
}

Vervelend en rommelig, maar het werkt, en ik kan geen betere bedenken.




  1. Mongoose upsert maakt geen standaard schema-eigenschap

  2. Inleiding tot Apache HBase-snapshots, deel 2:diepere duik

  3. mongodb filtert documenten met lengtegraad, breedtegraad en met een bepaalde afstand

  4. Resque-gebruik visualiseren met Node.js, WebSockets en Redis