MongoDB——聚合操作之MapReduce

转载 作者：知者 更新时间：2024-03-13 01:32:41 24 4

db.collection.mapReduce(
	function() {emit(key,value);}, //map 函数
	function(key,values) {return reduceFunction}, //reduce 函数
	{
		out: <collection>,
		query: <document>,
		sort: <document>, 
		limit: <number>,
		finalize: <function>, 
		scope: <document>, 
		jsMode: <boolean>,
		verbose: <boolean>, 
		bypassDocumentValidation: <boolean>
	}
)

var tags = ["nosql","mongodb","document","developer","popular"];
var types = ["technology","sociality","travel","novel","literature"];
var books=[];
for(var i=0;i<50;i++){
	var typeIdx = Math.floor(Math.random()*types.length);
	var tagIdx = Math.floor(Math.random()*tags.length);
	var tagIdx2 = Math.floor(Math.random()*tags.length);
	var favCount = Math.floor(Math.random()*100);
	var username = "xx00"+Math.floor(Math.random()*10);
	var age = 20 + Math.floor(Math.random()*15);
	var book = {
		title: "book-"+i, 
		type: types[typeIdx],
		tag: [tags[tagIdx],tags[tagIdx2]],
		favCount: favCount, 
		author: {name:username,age:age}
	};
	books.push(book)
}
db.books1.insertMany(books);

db.books1.mapReduce( 
	function(){emit(this.author.name,this.favCount)}, 
	function(key,values){return Array.sum(values)}, 
	{ 
		query:{type:"travel"}, 
		out: "books_favCount" 
	} 
)

> db.books_favCount.find()

24 4 0

• mongodb - 使用 mongodb+srv 连接到部署为有状态集的 mongodb

  我已经在 kubernetes 中部署了一个 3 pod mongodb statefulset，并且我正在尝试使用新的 mongodb+srv 连接字符串 (mongodb 3.6) 连接到具有 S

• mongodb - 如何使用 MongoDB Atlas 连接 MongoDB

  我已经创建了 MongoDB Atlas 帐户，并尝试连接。但出现以下错误。 MongoDB 连接错误 MongoNetworkError: 首次连接时无法连接到服务器 [cluster0-shard

• mongodb - JsonLD+MongoDB : Store JsonLD in MongoDB

  我正在使用 Node-WebKit 创建桌面应用程序。该应用程序基本上是创建文档(员工日常工作的详细信息)，任何注册用户都可以对这些文档发表评论。我正在创建的文档将被分成几个部分。用户将对特定部分发表

• mongodb - 服务 'MongoDB Server' (MongoDB) 启动失败

  我正在尝试使用官方网站上的安装程序在我的本地机器上安装 mongo DB。但是我不断收到这条消息，有人可以帮忙吗？ 我试过提供的解决方案 here但没有帮助。 最佳答案 我建议执行以下操作: 按 Wi

• mongodb - 如何使用 MongoDB 指南针删除 MongoDB 集合中选定的多条记录

  我对 MongoDB 和 MongoDB Compass 非常陌生。 我的客户集合中有大约 1000 条记录。如何通过 MongoDB 指南针一次删除所有记录。 非常感谢， 最佳答案 您可以使用 Mo

• mongodb - mongodb 和 mongodb-server 的区别

  当我尝试在我的 Ubuntu 机器中安装 mongodb 时，apt-get 会显示以下选项 mongodb mongodb-clients mongodb-dev mongodb-server 谁能

• mongodb - 如何将 mongodb 客户端连接到本地 Meteor MongoDB

  如何将 Robomongo(或任何其他 mongodb 客户端)连接到由本地 Meteor 应用程序创建的 mongodb 实例？ 最佳答案 确保 Meteor 正在本地主机上运行。打开终端窗口并运行

• mongodb - 频率表生成 - MongoDB

  我需要在 MongoDB 中生成一个简单的频率表。假设我在名为 books 的集合中有以下文档。 { "_id": 1, genre: [ "Fantasy", "Crime"

• mongodb - mongodb mapreduce中的where条件

  我如何在 mongos mapreduce 中指定一个条件，就像我们在 mongos group 函数中所做的那样。 我的数据是这样的 {lid:1000, age:23}, {lid:3000, a

• mongodb - 从 mongodb shell 运行具有 mongodb 查询的脚本

  我的 mongodb 数据库文档中有几个 ID。我需要通过脚本在这些 ID 上创建索引，这样我就不必一次又一次地运行 ensureIndex 命令。 db.getCollection("element

• mongodb - 比较嵌套数组中的对象 - mongoDB

  在我的数据库中，每个包含项目的文档中都有一个嵌套的元素数组，格式如下: elements:[ { "elem_id": 12, items: [ {"i_id": 1

• mongodb - MongoDB 上的时区查询

  我正在构建一个应用程序，其中用户可以位于不同的时区，并且我运行的查询对他们的时区很敏感。 我遇到的问题是 MongoDB 似乎在查询时忽略了时区! 这是日期字段“2019-09-29T23:52:13

• mongodb - 为什么当我添加新集合时只有一个分片获取数据？ - MongoDB

  我正在研究使用 mongodb 进行分片，我有以下结构: 1 个 Mongod 到我的 ConfigServer，在 ReplicaSet 中只有 1 个成员 2 个分片，每个分片在 ReplicaS

• mongodb - mongoDB 中是否可以使用循环对象引用？

  我正在尝试获取一个 mongoDB 对象，例如 Friend1 包含另一个 mongoDB 对象 Friend2，该对象又包含第一个对象 Friend1本质上使它成为一个循环对象引用。 要么这样，要么

• mongodb - 通过命令行正确卸载 MongoDB

  关闭。这个问题是off-topic .它目前不接受答案。 想改进这个问题？ Update the question所以它是on-topic对于堆栈溢出。 9年前关闭。 Improve this que

• mongodb - 无法通过终端使用身份验证数据连接 mongodb

  Mongo 版本 5.0.2。 Ubuntu 20.0 我在本地主机中启用了 MongoDB 连接的安全性。 我正在尝试通过以下命令使用身份验证详细信息连接我的本地主机 MongoDBmongo ad

• mongodb - 当配置实例使用与数据实例相同的二进制文件时升级 Mongodb

  我即将将分片的 MongoDB 环境从 2.0.7 升级到 2.2.9，最终我想升级到 2.4.9，但显然我需要通过 2.2 来完成。 2.2 的发行说明声明配置服务器应该首先升级其二进制文件，然后是

• mongodb - 无法远程连接到 mongodb

  目前，我无法在我的虚拟 Ubuntu 机器上远程连接 mongodb 服务器。我无法使用在我的 Windows PC 上运行的 Robomongo 客户端连接，该 PC 也运行 vm。 这是两台电脑的

• mongodb - 如何从 mongodb compass 连接 mongodb 集群？

  我创建了一个免费的 mongodb 集群。我创建了一个用户，设置了与 mongodb compass 的连接，复制了连接字符串，然后打开了我的 mongodb compass。将复制的字符串粘贴到那里

• mongodb - MongoDB 索引名称

  我使用 java 代码创建了 mongo 数据库集合索引 dbCollection.createIndex("accountNumber"); 当我看到索引使用 db.accounts.getInde