如何在Meteor javascript文件中使用MongoDB mapReduce功能

Question

我目前正在研究GeoSpatial项目，我使用MongoDB作为数据库和Meteor来创建我的应用程序。我在MongoDB上运行了一些查询(使用mapReduce)空间数据，我想把这个代码(查询)放在Meteor (javascript文件)上。我做了一些研究，但我仍然有问题。我不知道如何在流星中编写mapReduce函数。

这是我的mapReduce代码在MongoDB:

var map1 = function() {
var px =-83.215;
var py =41.53;
if(this.geometry.minlon<=px && px<=this.geometry.maxlon && this.geometry.minlat<=py && py<=this.geometry.maxlat)    
{emit(this._id, 1);}
}
var reduce1 = function(key, value) {
return Array.sum(value)
}
db.C1DB.mapReduce(map1, reduce1, {
out: "CollectionName"
})

Answer 1

基本上有两种方法:

• 或使用提到包使用的Raw Collection API。

下面是如何在没有包的情况下完成的工作示例:

C1DB = new Mongo.Collection('c1db');
CollectionName = new Mongo.Collection('CollectionName');
Meteor.methods({
    doMapReduce: function () {
        var mapFn = function () {
            var px = -83.215;
            var py = 41.53;
            if (this.geometry.minlon <= px && px <= this.geometry.maxlon && this.geometry.minlat <= py && py <= this.geometry.maxlat) {
                emit(this._id, 1);
            }
        };
        var reduceFn = function (key, value) {
            return Array.sum(value)
        };
        var rawC1DB = C1DB.rawCollection();
        // convert mapReduce to synchronous function
        var syncMapReduce = Meteor.wrapAsync(rawC1DB.mapReduce, rawC1DB);
        // CollectionName will be overwritten after each mapReduce call
        syncMapReduce(mapFn, reduceFn, {
            out: "CollectionName"
        });
        return CollectionName.find({}).fetch();
    }
});

Answer 2

现在还有一个更干净的包来公开这个功能。

https://github.com/fentas/meteor-mapreduce

它似乎是meteorhacks:aggregate包的一个分支，这很好。