位置: 编程技术 - 正文

Mongodb中MapReduce实现数据聚合方法详解

编辑:rootadmin

推荐整理分享Mongodb中MapReduce实现数据聚合方法详解,希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:,内容如对您有帮助,希望把文章链接给更多的朋友!

Mongodb是针对大数据量环境下诞生的用于保存大数据量的非关系型数据库,针对大量的数据,如何进行统计操作至关重要,那么如何从Mongodb中统计一些数据呢?

在Mongodb中,给我们提供了三种用于数据聚合的方式:

(1)简单的用户聚合函数;

(2)使用aggregate进行统计;

(3)使用mapReduce进行统计;

今天我们首先来讲讲mapReduce是如何统计,在后续的文章中,将另起文章进行相关说明。

MapReduce是啥呢?以我的理解,其实就是对集合中的各个满足条件的文档进行预处理,整理出想要的数据然后进行统计得到最终的统计结果。其中map函数用于对集合中的各个满足条件的文档进行预处理,整理出想要的数据。Reduce函数用于对整理出的数据进行处理得到统计结果。Map函数和Reduce函数都是JavaScript函数。

首先,我们先构造一个测试数据集test,使用js脚本往集合中随机插入一组数据,每条记录是哪个人花了多少钱买了什么东西。具体脚本test1.js如下:

接下来我们通过在控制台执行脚本来向数据库插入具体的数据,具体执行指令如下:

执行之后,通过MongoVUE来查看下具体的数据,如下所示,数据已经插入到集合中了:

接下来,我们可以做几个简单的统计操作了。

(1)统计不同用户都买了多少个商品?编写js脚本test2.js,将结果保存到statis1集合中。

按照刚才执行脚本的方式执行test2.js,并查看数据:

从数据库就可以直观看到统计数据了,若想查看某个人如majing购买了多少个商品,直接使用

(2)统计每个用户购买的每个商品的数量情况

脚本test3.js如下所示:

Mongodb中MapReduce实现数据聚合方法详解

按照刚才执行脚本的方式执行test3.js,并查看数据:

总共返回了条记录。此时如果我们想查找某个用户购买商品的情况,可以使用下面的查询方法:

如果我们想查找某个用户购买某个商品的情况,可以使用下面的查询方法:

(3)统计每个用户购买商品的总量及花费的总金额

脚本test4.js如下所示:

按照刚才执行脚本的方式执行test4.js,并查看数据:

(4)统计每个用户购买商品的平均价钱

在这个情景下,我们需要用到说道mapReduce里的另一个参数finalize,该参数是一个javascript脚本函数,用于对reduce后的集合进行一个后期处理操作。

执行脚本test5.js,具体如下所示:

执行之后查看得到的数据,具体如下所示,显示了总价钱,商品数量和商品单价。

如果想查找某个人的,可以和上面的查询方法一样,使用find()方法进行查询:

以上通过4个简单的例子对Mongodb中的MapReduce进行了简单的说明,当然MapReduce功能很强大,大家如果想知道其他高级的使用方法,可以到Mongodb的官网进行查阅和学习,网址为

谢谢。

以上所述是小编给大家介绍的Mongodb中MapReduce实现数据聚合方法详解,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对积木网网站的支持!

MongoDB 学习笔记(一)-MongoDB配置 MongoDB简介MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。MongoDB是一个介于关系数据

MongoDB快速翻页的方法 翻阅数据是MongoDB最常见的操作之一。一个典型的场景是需要在你的用户界面中显示你的结果。如果你是批量处理的数据,同样重要的是要让你的分页策

MongoDB快速入门笔记(六)之MongoDB删除文档操作 MongoDB是一个跨平台,面向文档的数据库,提供高性能,高可用性和易于扩展。MongoDB是工作在集合和文档上一种概念。文档是一组键值对。文档具有动态

标签: Mongodb中MapReduce实现数据聚合方法详解

本文链接地址:https://www.jiuchutong.com/biancheng/312539.html 转载请保留说明!

上一篇:Mongodb聚合函数count、distinct、group如何实现数据聚合操作(mongodb聚合函数mapreduce)

下一篇:MongoDB 学习笔记(一)-MongoDB配置(mongodb 教程)

  • 企业收到退税款怎么处理
  • 银行代发工资必须交社保吗
  • 企业的办税员承担责任吗
  • 应计入企业存货成本有哪些
  • 付给总机构的管理费可以税前扣除吗
  • 发票隔月报送可以么?
  • 持有至到期投资账务处理
  • 广告公司好进吗
  • 代扣公积金会计怎么做账
  • 个人转让不动产给个人独资企业
  • 公司收款收据
  • 事业单位收个人部分社保怎么入账
  • 继承房产出售时交个人所得税税率是多少
  • 销项税额抵减是怎么回事
  • 增值税发票如何红冲
  • 混合销售和兼营的区别
  • 甲公司采用租赁方式租入一台大型设备
  • 什么时候计入其他综合收益什么时候计入投资收益
  • 固定资产明细账有哪些
  • 退休职工费用哪里列支
  • 差旅费中的车票可以抵扣进项税吗
  • 个人捐赠住房
  • 小企业的费用应当在发生时计入当期损益
  • 在租的土地上建房
  • 给法院交的诉讼费怎么交
  • 收到增值税进项税增量留抵退税如何列报
  • win7右键设置方法
  • 子公司接受母公司捐赠的会计处理
  • 电脑屏幕字体模糊怎么办
  • 公积金托收怎么变更
  • 企业所得税弥补以前年度亏损怎么算
  • 业务招待费如何进行纳税调整
  • php strlen函数
  • php获取数组的值
  • 补充养老保险税前扣除标准与扣除比例
  • thinkphp ajaxfileupload实现异步上传图片的示例
  • 待报解预算收入什么意思
  • php 抓取别的网站的内容
  • ptech模型
  • 企业转让专利权属于什么收入
  • 汇算清缴退税的账务处理
  • 应收账款转回坏账怎么办
  • 股东借款转增资本公积要验资吗
  • 海关进口增值税专用缴款书如何抵扣
  • 开票钱收不回怎么办
  • 餐具报损率一般为多少
  • 对公账户怎么查询开户行
  • sql查询使用临时表
  • 小规模纳税人购买税控设备
  • 发票先认证后入账怎么做账
  • 验资报告费用如何做账
  • 写字楼里的公司怎么赚钱
  • 收到利息收入如何做分录
  • 税盘减免税款怎么做账
  • 纳税人将外购的货物用于非应税项目
  • 税控盘服务费减免政策
  • 银行存款负数如何计算
  • 管理费用当月可以结转吗
  • 总产值的计算方法是什么
  • 水果销售公司怎么起名字好听
  • 分公司费用报销
  • 个税返还申请流程
  • linux常用基本命令pwd
  • linux里find命令
  • 如何让windows7更快
  • 微软2021年新系统
  • win10 64位系统提示0x80070643错误代码的解决方法
  • windows 8.1 (multiple editions)
  • cocos2dx tableview基础:实现多图片的滑动显示
  • cocos2dx游戏开发
  • android点击按钮弹出对话框
  • 女鬼照片
  • JavaScript中数组的相关方法
  • nodejs 调用命令行
  • css3瀑布流布局
  • 如何使用jquery实现点击按钮弹出一个对话框
  • bootstrapped 5%
  • jquery showdialog
  • 上海市国家税务局地址
  • 税务投诉电话12345
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设