Mongodb MapReduce 使用 Mongoid 对每个类别最多进行 n 次分组

Question

我在 MongoDB (2.0.2) 地图缩减方面遇到了一个奇怪的问题。

所以，故事是这样的：

我有广告模型（在下面查找模型源代码摘录），我需要对每个类别最多 n 个广告进行分组，以便获得一个很好的有序列表，我以后可以用它来做更多有趣的事情。

# encoding: utf-8
class Ad  
  include Mongoid::Document
  cache
  include Mongoid::Timestamps

  field :title
  field :slug, :unique => true

  def self.aggregate_latest_active_per_category

    map = "function () {
        emit( this.category, { id: this._id });
    }"

    reduce = "function ( key, value ) {
      return { ads:v };
    }"

  self.collection.map_reduce(map, reduce, { :out => "categories"} )

  end

到目前为止所有的乐趣和游戏。

我期望得到类似于 (mongo shell for db.categories.findOne() ) 的结果：

    {
      "_id" : "category_name",
      "value" : {
          "ads" : [
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014ab")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014b0")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014b6")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014b8")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014bd")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014c1")
                          },
                          {
                            "id" : ObjectId("4f2970e9e815f825a30014ca")
                          },
                          // ... and it goes on and on
          ]
        }
      }

实际上，如果我可以获得包含的值，那就更好了只有数组，但 MongoDB 抱怨还不支持它，但是，随着稍后使用 finalize 函数，这不是我想问的大问题。

现在，回到问题。当我进行映射缩减时实际发生的情况是，它会输出类似以下内容的内容：

{
    "_id" : "category_name",
    "value" : {
        "ads" : [
            {
                "ads" : [
                    {
                        "ads" : [
                            {
                                "ads" : [
                                    {
                                        "ads" : [
                                            {
                                                "id" : ObjectId("4f2970d8e815f825a3000011")
                                            },
                                            {
                                                "id" : ObjectId("4f2970d8e815f825a3000017")
                                            },
                                            {
                                                "id" : ObjectId("4f2970d8e815f825a3000019")
                                            },
                                            {
                                                "id" : ObjectId("4f2970d8e815f825a3000022")
                                            },

   // ... on and on and on

...虽然我可能可以找到一种使用它的方法，但它看起来不像我应该得到的东西。

所以，我的问题（最后）是：

1. 我做错了什么吗？
2. 我的 MongoDB map reduce 有问题（我的意思是除了与 hadoop 相比的所有常见问题之外）？

Answer 1

是的，你做错了。 map 和 reduce 的输入和输出应该是统一的。因为它们是并行执行的，并且 reduce 可能会在部分减少的结果上运行。尝试这些功能：

var map = function() {
  emit(this.category, {ads: [this._id]});
};

var reduce = function(key, values) {
  var result = {ads: []};

  values.forEach(function(v) {
    v.ads.forEach(function(a) {
      result.ads.push(a)
    });
  });
  return result;
}

这应该生成如下文档：

{_id: category, value: {ads: [ObjectId("4f2970d8e815f825a3000011"), 
                              ObjectId("4f2970d8e815f825a3000019"), 
                              ...]}}