2013-02-19 75 views
2

我已经从文档中读取了在MongoDB上聚合时不可能使用地理空间索引。有没有其他的选择?我试图运行一个查询,抓取特定半径内的所有活动,然后根据活动发生的次数对它们进行分组/排序。有没有解决这个问题的方法?MongoDB - 具有聚合的地理空间索引

+0

你找到了答案,但以防万一的piplining聚集我用这个:http://docs.mongodb.org/manual/reference /运营商/聚集/ geoNear / – Maziyar 2013-10-30 16:11:08

回答

2

您可以在地理查询中使用map-reduce。这是基于geo_mapreduce.js一个例子(从mongodb的jstests):

// setup test collection 
var act_date = new Date(2010,06,07); 
for (i = 1; i <= 10; i++) { 
    db.activity.insert({ "geo" : { "lat" : 32.68331909, "long" : 69.41610718 }, "date":act_date, "activity" : 9 * i }); 
    db.activity.insert({ "geo" : { "lat" : 35.01860809, "long" : 70.92027283 }, "date":act_date, "activity" : 3 }); 
    db.activity.insert({ "geo" : { "lat" : 31.11639023, "long" : 64.19970703 }, "date":act_date, "activity" : 11 }); 
    db.activity.insert({ "geo" : { "lat" : 32.64500046, "long" : 69.36251068 }, "date":act_date, "activity" : 9 }); 
    db.activity.insert({ "geo" : { "lat" : 33.23638916, "long" : 69.81360626 }, "date":act_date, "activity" : 22 }); 
    act_date.setDate(act_date.getDate() + 1); 
} 

db.activity.ensureIndex({ "geo" : "2d" }); 
center = [ 32.68, 69.41 ]; 
radius = 10/111; // 10km; 1 arcdegree ~= 111km 
geo_query = { geo : { '$within' : { '$center' : [ center, radius ] } } }; 

// map function 
m = function() { 
    emit(this.date, { "activity" : this.activity }); 
}; 

// reduce function 
r = function(key, values) { 
    var total = 0; 
    for (var i = 0; i < values.length; i++) { 
     total += values[i].activity; 
    } 
    return {"activity":total }; 
}; 

// mapreduce with geo query 
res = db.activity.mapReduce(m, r, { out : { inline : 1 }, query : geo_query }); 
// sort results 
res.results.sort(function(a, b){return b.value.activity - a.value.activity}) 
for (var i=0; i < res.results.length; i++) { 
    print("Date: " + res.results[i]._id + " Activity: " 
         + res.results[i].value.activity) 
}