文档的结构看起来像这样:
"_id" : ObjectId("581496e8564627c098e41755"),
"startdate": somedate,
"enddate": somedate,
"userId" : 1,
"activity" : "activity1",
"measures" : [
{
"M1" : 99,
"M2" : 103,
"M3" : 118,
"M4" : 4
},
{
"M1" : 136,
"M2" : 89,
"M3" : 108,
"M4" : 6
},
有50个用户,8种活动,每种活动大约有100个措施。一个用户可以在其他日期进行相同的活动,并使用其他措施。
我在数据库中有大约3000个文档:每个用户每个活动一个文档,包括措施。
我想要获取每个用户每个活动的所有措施。
我有以下代码:
`db.armband.aggregate([
{$match: { "measures.M1": { $gt: 1 } } },
{$project: { _id: 0, userId: 1, activity:1, measures:1 } },
{$sort: {userId:1, activity:1} },
{$out: "actPerUser"}
])
`
问题出在我根据顺序获得每个活动的1个文档并附带措施。但是,我获得了:
- 1个具有userid1、activity1和措施100的文档
- 1个具有userid1、activity1和措施100的文档
- 1个具有userid2、activity1和措施100的文档
我想要一个文档:userid1、activity1和措施(该活动所有措施 - 在上面的示例中为200)。
然后我尝试过:
`db.armband.aggregate(
[
{
$group:
{
_id: { userId: "$userId" },
actMes: { $push: { activity:"$activity", measures: "$measures" } }
}
},
{$project: { _id: 0, userId: "$_id.userId", actMes:1 } },
{$sort: { userId:1}},
]
这为我提供了每个用户的1个文档,其中列举了不同的活动和措施(但活动仍然是重复的)。
然后我尝试解开措施:
`db.armband.aggregate(
[
{$unwind: '$measures'},
{$group: {
_id: { userId: "$userId" },
activity: { $addToSet: "$activity" },
measures: {$addToSet: "$measures"}
}
},
{ $sort: {userId:1}}
])
`
这给我每个用户一个文档,其中包含8项活动和约5900的测量值。
所以我有点迷失,如何实现我想要的?是否可能,即每个用户一个文档,一个活动,该活动的所有测量值?