`
kabike
  • 浏览: 608694 次
  • 性别: Icon_minigender_1
  • 来自: 大连
社区版块
存档分类
最新评论

mongodb的简单map reduce

阅读更多
mongodb的orders collection里已经有了一些数据
> db.orders.find();
{ "_id" : ObjectId("5237b7807d76a3941f8774c8"), "user_id" : 305, "amount" : 300 }
{ "_id" : ObjectId("5237b7907d76a3941f8774c9"), "user_id" : 306, "amount" : 200 }
{ "_id" : ObjectId("5237b7987d76a3941f8774ca"), "user_id" : 307, "amount" : 205 }
{ "_id" : ObjectId("5237b7a37d76a3941f8774cb"), "user_id" : 305, "amount" : 200 }
{ "_id" : ObjectId("5237b7ae7d76a3941f8774cc"), "user_id" : 306, "amount" : 400 }
{ "_id" : ObjectId("5237b7b97d76a3941f8774cd"), "user_id" : 307, "amount" : 505 }
{ "_id" : ObjectId("5237b8cb7d76a3941f8774ce"), "user_id" : 308, "amount" : 5 }

现在用一个mapreduce任务来统计每个user_id的amount总量

要编写一个map函数和一个reduce函数
> function mapper(){emit(this.user_id,this.amount)}
> function reducer(keyUserId,amount){return Array.sum(amount)}

运行mapreduce job,其中用到了map函数和reduce函数

> db.orders.mapReduce(mapper,reducer,{out:"mrresult"})

结果会输出到mrresult 这个collection中

> db.mrresult.find()
{ "_id" : 305, "value" : 500 }
{ "_id" : 306, "value" : 600 }
{ "_id" : 307, "value" : 710 }
{ "_id" : 308, "value" : 5 }
分享到:
评论

相关推荐

    MapReduceMongoDB:在 MongoDB 中使用 Map reduce

    标题:在 MongoDB 中使用 Map Reduce 检查波兰语和英语句子中的字母分布 动机 我们越来越多地听到各种网站遭到攻击以及密码非常薄弱的​​管理员的不负责任。 如何创建一个强密码:有一种观点认为你应该造一个句子,...

    Loggio:Java Bases Log Framework with Elastic Search Distributed Architecture & MongoDB Map Reduce based Recommendation Logging

    Java Bases Log Framework with Elastic Search Distributed Architecture & MongoDB Map Reduce based Recommendation Logging 建筑学 建筑学 弹性搜索 MongoDB 和 Map Reduce 部署说明 要快速使用 Loggio,您必须...

    mongodb数据库复习资料

    * Map-Reduce操作:mongodb的Map-Reduce操作是指使用不同的管道阶段操作器进行聚合操作的过程。 * Map阶段:mongodb的Map阶段是指将数据映射到指定的键上。 * Reduce阶段:mongodb的Reduce阶段是指将数据聚合到一起...

    mongodb mapreduce 实例

    总结来说,MongoDB的MapReduce功能为我们提供了一种有效处理和分析大规模订单数据的方法,通过自定义的map和reduce函数,可以实现各种复杂的统计需求,这对于理解和优化业务表现非常有价值。在电子商务领域,这样的...

    mongodb总结

    MongoDB 的 Map-Reduce 功能用于处理大数据和聚合操作。`map()` 函数用于遍历数据并生成键值对,`reduce()` 函数则对这些键值对进行聚合。Map-Reduce 适合执行复杂的数据分析任务,但效率相对较低,一般用于离线...

    mongodb-win32-x86_64-2008plus-ssl-v3.4-latest-signed.msi

    Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。 Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录,将key与value传给Reduce函数进行处理。 Map函数和Reduce函数是使用Javascript...

    MongoDB MapReduce分享.ppt

    MapReduce 包含两个主要函数:Map 和 Reduce。Map 阶段负责将输入数据分解成小块,然后对每一块应用一个函数,生成中间键值对。Reduce 阶段则负责收集这些中间结果,通过相同的键进行合并和减少,从而得到最终的结果...

    mongodb 3.4 手册

    综上所述,MongoDB 3.4手册是一份全面、权威的文档,从安装MongoDB开始,到基础操作、CRUD、性能优化、聚合操作、Map-Reduce处理以及文本搜索等功能,为开发者提供了详尽的指导。无论是数据库管理员还是应用程序...

    mongodb aggregation运用例子

    在文档中提及的MongoDB聚合框架主要包括聚合管道、Map-Reduce以及一些单一用途的聚合操作。现在,让我们深入探索这些知识点。 ### 聚合管道(Aggregation Pipeline) 聚合管道是一个多层次的处理过程,它将数据...

    Mongodb入门教程、示例+Spring Boot完整示例+聚合.docx

    7. Mongodb 中的 Map/reduce 主要是用来对数据进行批量处理和聚合操作。 8. Map 函数调用 emit(key,value) 遍历集合中所有的记录,将 key 与 value 传给 Reduce 函数进行处理。 9. Map 函数和 Reduce 函数是使用 ...

    MongoDB期末考试测试题

    `map`函数定义了如何将每个文档转换为键值对,`reduce`函数则负责聚合这些键值对。在这里,它用于生成不同专业学生名字的列表。 12. Aggregation Framework: `aggregate`命令用于执行聚合管道操作,例如统计不同...

    MongoDB入门到精通

    - Map/Reduce 是一种数据处理模型,MongoDB 支持使用 Map/Reduce 对集合中的数据执行复杂的计算任务,如聚合数据、统计分析等。 7. **GridFS** - GridFS 是 MongoDB 提供的一个用于存储大文件(如音频、视频等)...

    mongodb3.2.4说明文档

    虽然 Map-Reduce 在某些场景下仍然有用,但 MongoDB 推荐使用聚合管道进行数据分析,因为它提供了更高级的功能和更好的性能。 **7.3 单目的聚合操作** 部分聚合操作专门用于解决特定的问题,例如统计集合中的文档...

    mongodb安装培训文档

    6. 内置 MapReduce 功能,用于数据批量处理和聚合操作,Map 函数遍历记录,Reduce 函数处理结果。 7. GridFS 用于存储大量小文件。 8. 支持在服务器端执行 JavaScript 脚本,可以存储和调用函数。 9. 兼容多种编程...

    Mongo-Commands:MongoDB命令速查表。 包含map-reduce,aggregate等

    以下是对MongoDB中`map-reduce`和`aggregate`两个重要功能的详细解释。 ### 1. Map-Reduce Map-Reduce是一种处理大数据的编程模型,常用于数据聚合。在MongoDB中,map-reduce用于执行复杂的分析任务,通过将数据...

    基于MongoDB的BESIII分布式计算记账系统的研究与实现.pdf

    6. Map/Reduce:Map/Reduce 是一种分布式计算模型,用于处理大规模数据。该模型能够快速地对大量数据进行处理和分析。本文中,采用了 Map/Reduce 和 Matplotlib 等技术,提高了分析速度和实现了分析结果的多样化展示...

    MongoDB数据库应用.docx

    8. 其他:MongoDB 还提供了其他一些功能,如 map-reduce 和聚合管道等。 Linux 下安装 MongoDB 操作: 1. 下载与解压:下载 MongoDB 的安装包,解压到指定目录下。 2. 运行服务端:使用命令mongod 启动 MongoDB ...

Global site tag (gtag.js) - Google Analytics