MongoDB 的 MapReduce 是一种处理大规模数据集的强大工具，可以将数据从集合中提取出来，进行处理和聚合，然后将结果存储在新的集合中，MapReduce 分为两个阶段：Map 阶段和 Reduce 阶段，Map 阶段将输入文档拆分成键值对，而 Reduce 阶段则将这些键值对进行合并，生成最终的结果。
MapReduce 的基本步骤
1、Map 阶段：每个输入文档都会调用一次 Map 函数，该函数会将文档转换为一组键值对。
2、Shuffle 和 Sort 阶段：MongoDB 会根据键对所有键值对进行分组和排序。
3、Reduce 阶段：对于每个唯一的键，Reduce 函数会接收到该键对应的所有值，并将这些值合并为一个单一的输出值。
4、输出阶段：Reduce 阶段的输出会被写入到指定的输出集合中。
MapReduce 示例
假设我们有一个集合orders，其中包含以下文档：
| order_id | product | quantity | price |
| 1 | Apple | 10 | 1.5 |
| 2 | Orange | 20 | 2 |
| 3 | Apple | 30 | 1.5 |
我们希望计算每种产品的总销售额，我们可以使用 MapReduce 来实现这个需求。
Map 函数
function map() {
emit(this.product, this.quantity * this.price);
}
Reduce 函数
function reduce(key, values) {
return Array.sum(values);
}
执行 MapReduce
db.orders.mapReduce(
function() { emit(this.product, this.quantity * this.price); },
function(key, values) { return Array.sum(values); },
{ out: "totalSales" }
)
执行上述命令后，MongoDB 会在totalSales 集合中生成以下结果：
| product | value |
| Apple | 60 |
| Orange | 40 |
使用 out 选项
out 选项用于指定 MapReduce 输出的集合名称，如果指定的集合已经存在，MongoDB 会删除该集合并创建一个新的集合来存储输出结果，如果省略out 选项，MapReduce 会将结果作为临时集合返回，但不会将其保存到数据库中。
FAQs
Q1: MapReduce 的 Map 函数和 Reduce 函数有什么作用？
A1: Map 函数负责将输入文档转换为一组键值对，而 Reduce 函数负责将这些键值对合并为一个单一的输出值，Map 函数会被应用到集合中的每个文档上，而 Reduce 函数会被应用到具有相同键的所有值上。
Q2: MapReduce 的out 选项有什么用途？
A2:out 选项用于指定 MapReduce 输出的集合名称，如果指定的集合已经存在，MongoDB 会删除该集合并创建一个新的集合来存储输出结果，如果省略out 选项，MapReduce 会将结果作为临时集合返回，但不会将其保存到数据库中。
原创文章，作者：未希，如若转载，请注明出处：https://www.kdun.com/ask/1105119.html
