Mogodb聚合

Question

这是我的用户集合

{ 
    "_id" : ObjectId("58e8cb640f861e6c40627a06"), 
    "actorId" : "665991", 
    "login" : "petroav", 
    "gravatar_id" : "", 
    "url" : "https://api.github.com/users/petroav", 
    "avatar_url" : "https://avatars.githubusercontent.com/u/665991?" 

}

这是我的回购收藏

{ 
    "_id" : ObjectId("58e8cb640f861e6c40627a07"), 
    "repoId" : "28688495", 
    "name" : "petroav/6.828", 
    "url" : "https://api.github.com/repos/petroav/6.828"
}

这是我的事件集合

{ 
    "_id" : ObjectId("58e8cb640f861e6c40627a08"), 
    "eventId" : "2489651045", 
    "type" : "CreateEvent", 
    "actorLogin" : "petroav", 
    "repoId" : "28688495", 
    "eventDate" : ISODate("2015-01-01T15:00:00.000+0000"), 
    "public" : true         
}

我试图对上述数据执行以下查询

1. 所有存储库及其最大贡献者的返回列表
2. 从参与者处查找事件数量最多的存储库(通过登录)。如果多个repos有相同数量的事件，则返回具有最新事件的事件。
3. 通过登录返回参与者详细信息和贡献存储库列表

我试了三次这样做

db.events.aggregate(
   [    {
            $match:{"actorLogin":"petroav"}
        },
        {
            $lookup:{
                from:"repos",
                localField:"repoId",
                foreignField:"repoId",
                as:"Repostory"
                }
        },
        {
            $group:{ _id : "$Repostory", repo: { $push: "$$ROOT" } } 
        }

   ]
).pretty()

请帮帮忙。我是蒙哥大的新手。

Answer 1

如果这些变量名称与代码不完全匹配，则可能需要更新它们。因为您使用actorLogin和repoId作为引用而不是_id，所以您可能希望为字段创建索引以帮助提高性能。

此外，如果要清理最终格式、删除额外字段、重命名字段等，则可能需要在这些管道的末尾添加一个$project阶段。

编号1

db.repos.aggregate(
    [    
         {
             $lookup:{
                 from:"events",
                 localField:"repoId",
                 foreignField:"repoId",
                 as:"Event"
                 }
         },{
             $unwind:"$Event"
         },
         {
             $group:{ 
                 _id : {repo: "$_id", user: "$Event.actorLogin" }, 
                 contributionCount: { $sum:1 },//number of times logged in
                } 
         },
         { 
             $sort: {
                contributionCount: -1
            } 
        },{
            $group:{
                _id: {repo:'$_id.repo'},
                contributionCount: {$first: '$contributionCount' },
                actorLogin: {$first: '$_id.user' }
            } 
        } 
    ]
 ).then(console.log)

编号2

db.events.aggregate(
    [    {
             $match:{"actorLogin":"petroav"}
         },
         {
             $lookup:{
                 from:"repos",
                 localField:"repoId",
                 foreignField:"repoId",
                 as:"Repostory"
                 }
         },{
             $unwind:"$Repostory"
         },
         {
             $group:{ 
                 _id : "$Repostory", 
                 loginCount: { $sum:1 },//number of times logged in
                 lastLoginDate: {$max:'$eventDate'} //largest ISODate for the repo
                } 
         },
         { 
             $sort: {
                  loginCount: -1, 
                  date: -1
            } 
        },
        {limit:1}
 
    ]
 ).then(console.log)    

编号3

db.user.aggregate(
         [    
             {
            $match:{"actorLogin":"petroav"}
        },
        {
           $lookup:{
               from:"events",
               localField:"actorLogin",
               foreignField:"actorLogin",
               as:"Events"
               }
       },{
           $unwind:"$Events"
       },
        {
            $lookup:{
                from:"repos",
                localField:"Events.repoId",
                foreignField:"repoId",
                as:"Repostory"
                }
        },{
             $unwind:"$Repostory"
         },{
             $group: {
                 _id:'$actorLogin',
                 user: {$first:'$$ROOT'}
                 repos: {$addToSet:'$Repostory'}

             }
         }
    ]
 ).then(console.log)