MongoDB Map Reduce（十四）

淩亂°似流年 2021-12-17 11:43 238阅读 0赞

// Map-user_address_by_id
    // Map-Reduce是一种计算模型，简单的说就是将大批量的工作（数据）分解（MAP）执行
    // 然后再将结果并成最终结果（REDUCE）
    // MongoDB提供的Map-Reduce
    
    // MapReduce命令
    // 使用MapReduce要实现两个函数Map函数和Reduce函数
    // Map函数调用emit(key,value),遍历collection中所有的记录，将key与value
    // 传递给Reduce函数进行处理
    
    // map：映射函数（生成键值对序列，作为reduce函数参数）
    // reduce统计函数，reduce函数的任务就是将key-values变成key-value
    // 也就是把values数组变成一个单一的值value
    
    // out统计结果存放集合（不指定则使用临时集合，在客户端断开后自动删除）
    
    // query一个筛选条件，只有满足条件的文档才会调用map函数（query、limit、sort
    // 可以随意组合）
    
    // sort和limit结合的sort排序参数（也是在发往map函数前给文档排序）
    // 可以优化分组机智
    
    // limit发往map函数的文档数量的上限（要是没有limit，单独使用sort的用处不大）
    
    //db.createCollection("posts");
    
    /*db.posts.insert({
    	"post_text":"教程",
    	"user_name":"mark",
    	"status":"active"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"mark",
    	"status":"active"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"mark",
    	"status":"active"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"tom",
    	"status":"disabled"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"tom",
    	"status":"disabled"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"tom",
    	"status":"disabled"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"tom",
    	"status":"disabled"
    })
    
    db.posts.insert({
    	"post_text":"教程",
    	"user_name":"tom",
    	"status":"active"
    })*/
    
    // 在posts集合中使用mapReduce函数来选取已发布的文章（status:"active"）
    // 并通过user_name分组，计算每个用户的文章数
    /*db.posts.mapReduce(function(){ emit(this.user_name,1) }, 
    function(key,values){
    	return Array.sum(values)
    }, 
    {
    	query:{status:"active"},
    	out:"post_total"
    })*/
    
    // find操作符查看mapReduce的查询结果
    /*db.posts.mapReduce(
    function(){ emit(this.user_name,1); }, 
    function(key,values){
    	return Array.sum(values)
    },
    {
    	query:{status:"active"},
    	out:"post_total" // 临时集合参数这样写：out: {inline: 1}
    })
    
    db.post_total.find()*/
    
    // 临时输出参数
    var tmp = db.posts.mapReduce(
    function(){ emit(this.user_name,1); }, 
    function(key,values){
    	return Array.sum(values)
    },
    {
    	query:{status:"active"},
    	out:{inline: 1}
    })
    
    printjson(tmp.results)