MapReduce 用于计算参数值

Question

我有这样的文档：

{
   "_id": ObjectId("4d17c7963ffcf60c1100002f"),
   "title": "Text",
   "params": {
     "brand": "BMW",
     "model": "i3"
    }
}

{
   "_id": ObjectId("4d17c7963ffcf60c1100002f"),
   "title": "Text",
   "params": {
     "brand": "BMW",
     "model": "i5"
    }
}

我需要的是每个参数值的计数。就像：

brand
---------
BMW (2)

model
---------
i3 (1)
i5 (1)

我想我必须编写映射/归约函数。我该怎么做？谢谢。

Answer 1

我想我必须编写map/reduce函数。

是的，你需要为此进行映射缩减。对于一些简单的 Map-Reduce 示例，请查看此处。

对于您的特定情况，您首先需要更改对输出的期望。 Map/Reduce 的输出是一个集合。该集合将看起来像这样（在您的情况下）：

{ key : { 'brand' : 'bmw' }, value : 2 }
{ key : { 'model' : 'i5' }, value : 1 }

要生成此集合，您将需要一个“map”函数和一个“reduce”函数。 “map”函数将发出一个键和一个值。键是 params 的每个元素，值是 1 的计数。“reduce”函数接受一个键和一个值数组，并仅返回一个值。您的问题与 MongoDB 网站 上的示例基本相同：

map = function() {
    if (!this.params) {
        return;
    }
    for (index in this.params) {
        emit(this.params[index], 1);
    }
}

reduce = function(previous, current) {
    var count = 0;

    for (index in current) {
        count += current[index];
    }

    return count;
}

Answer 2

在您的地图函数中，枚举 this 对象的 params 属性的属性。对于您发现的每个属性，使用包含属性名称和属性值的键调用 emit 。传递 1 作为值。例如 emit({'brand','BMW'}, 1) 但显然使用变量而不是常量！

在您的reduce函数中，您将传递一个键和一个值数组。对这些值求和并返回总和。即使初始数组全为 1，也不要试图使用数组的长度，因为可以迭代调用 reduce 函数。

您可以随后对结果集合中的结果进行分组，如果需要提高性能，则应用索引。