虽然不能实时执行此操作，但可以使用MongoDB1.8+map/Reduce中的“Reduction”Out选项多次运行map-Reduce将数据合并到一起(请参见http：/www.monGodb.org/Display/DOCS/MapReduce#MapReduce-Outputoptions)。您需要在这两个集合中都有一些可以用作_id的键。

例如，假设您有一个users收藏和comments集合，您希望有一个新的集合，其中包含每个评论的一些用户统计信息。

比方说users集合具有以下字段：_id

首名

LASTNAME

国家

性别

年龄

然后comments集合具有以下字段：_id

用户标识

评语

创造

您可以执行此映射/还原：var mapUsers, mapComments, reduce;db.users_comments.remove();// setup sample data - wouldn't actually use this in productiondb.users.remove();db.comments.remove();db.users.save({firstName:"Rich",lastName:"S",gender:"M",country:"CA",age:"18"});db.users.save({firstName:"Rob",lastName:"M",gender:"M",country:"US",age:"25"});db.users.save({firstName:"Sarah",lastName:"T",gender:"F",country:"US",age:"13"});var users = db.users.find();db.comments.save({userId: users[0]._id, "comment": "Hey, what's up?", created: new ISODate()});db.comments.save({userId: users[1]._id, "comment": "Not much", created: new ISODate()});db.comments.save({userId: users[0]._id, "comment": "Cool", created: new ISODate()});// end sample data setupmapUsers = function() {

var values = {

country: this.country,

gender: this.gender,

age: this.age    };

emit(this._id, values);};mapComments = function() {

var values = {

commentId: this._id,

comment: this.comment,

created: this.created    };

emit(this.userId, values);};reduce = function(k, values) {

var result = {}, commentFields = {

"commentId": '',

"comment": '',

"created": ''

};

values.forEach(function(value) {

var field;

if ("comment" in value) {

if (!("comments" in result)) {

result.comments = [];

}

result.comments.push(value);

} else if ("comments" in value) {

if (!("comments" in result)) {

result.comments = [];

}

result.comments.push.apply(result.comments, value.comments);

}

for (field in value) {

if (value.hasOwnProperty(field) && !(field in commentFields)) {

result[field] = value[field];

}

}

});

return result;};db.users.mapReduce(mapUsers, reduce, {"out": {"reduce": "users_comments"}});db.comments.mapReduce(mapComments, reduce, {"out": {"reduce": "users_comments"}});db.users_comments.find().pretty(); // see the resulting collection

此时，您将有一个名为users_comments它包含合并的数据，现在可以使用该数据。这些减少的集合都有_id在映射函数中发出的键，然后所有的值都是value键-这些值不在这些简化文档的顶层。

这是一个有点简单的例子。您可以使用更多的集合重复这一点，就像您希望继续构建减少的集合一样。您还可以在此过程中对数据进行汇总和汇总。您可能会定义多个REPLE函数，因为聚合和保存现有字段的逻辑变得更加复杂。

您还将注意到，现在每个用户都有一个文档，其中包含了数组中所有该用户的注释。如果我们合并的数据具有一对一的关系，而不是一对多的关系，那么它将是平坦的，您可以简单地使用这样的约简函数：reduce = function(k, values) {

var result = {};

values.forEach(function(value) {

var field;

for (field in value) {

if (value.hasOwnProperty(field)) {

result[field] = value[field];

}

}

});

return result;};

如果你想把users_comments集合，因此它是每个注释的一个文档，另外运行以下命令：var map, reduce;map = function() {

var debug = function(value) {

var field;

for (field in value) {

print(field + ": " + value[field]);

}

};

debug(this);

var that = this;

if ("comments" in this.value) {

this.value.comments.forEach(function(value) {

emit(value.commentId, {

userId: that._id,

country: that.value.country,

age: that.value.age,

comment: value.comment,

created: value.created,

});

});

}};reduce = function(k, values) {

var result = {};

values.forEach(function(value) {

var field;

for (field in value) {

if (value.hasOwnProperty(field)) {

result[field] = value[field];

}

}

});

return result;};db.users_comments.mapReduce(map, reduce, {"out": "comments_with_demographics"});

这种技术绝对不应该在飞行中执行。它适合于cron作业或类似于定期更新合并数据的任务。你可能会想要跑ensureIndex在新集合上，以确保对其执行的查询运行迅速(请记住，您的数据仍在value键，所以如果要索引comments_with_demographics评论created时间，应该是db.comments_with_demographics.ensureIndex({"value.created": 1});