我有一个 mongo 集合:

    {
   "_id":ObjectId("55f16650e3cf2242a79656d1"),
   "user_id":11,
   "push":[
      ISODate("2015-09-08T11:14:18.285      Z"),
      ISODate("2015-09-08T11:14:18.285      Z"),
      ISODate("2015-09-09T11:14:18.285      Z"),
      ISODate("2015-09-10T11:14:18.285      Z"),
      ISODate("2015-09-10T11:14:18.285      Z")
   ]
}{
   "_id":ObjectId("55f15c78e3cf2242a79656c3"),
   "user_id":12,
   "push":[
      ISODate("2015-09-06T11:14:18.285      Z"),
      ISODate("2015-09-05T11:14:18.285      Z"),
      ISODate("2015-09-07T11:14:18.285      Z"),
      ISODate("2015-09-09T11:14:18.285      Z"),
      ISODate("2015-09-09T11:14:18.285      Z"),
      ISODate("2015-09-10T11:14:18.285      Z"),
      ISODate("2015-09-11T11:14:18.285      Z")
   ]
}

如何在单个查询中找到 timeStamps 计数 < 3="" 且具有="" date(timestamp)=""> (currentDate-5) 的 user_id。我将使用 php，不想将所有文档都放在内存中。

解释:

user_id : date       : count
11      : 2015-09-08 : 2
          2015-09-09 : 1
          2015-09-10 : 2

12      : 2015-09-05 : 1
          2015-09-06 : 1
          2015-09-07 : 1
          2015-09-09 : 2
          2015-09-10 : 1
          2015-09-11 : 1

如果日期设置为 2015-09-09(用户输入)，它将为 user_id 11 提供 3(计数)，为 user_id 12 提供 4(计数)。因此假设计数设置为 3(用户输入)。查询应返回 11(user_id)。如果 count 设置为 2，将没有可用的 user_id，如果 count 设置为 5，它应该同时返回 11 和 12

最佳答案

要解决这个问题，您需要一个聚合管道，它首先将结果“过滤”到“最近 5 天”，然后基本上对每个符合条件的文档中存在的数组项的计数进行“求和”，然后查看“总数”是否为“少于三个”。

$size MongoDB 聚合运算符在这里确实有帮助， $map 也是如此。以及通过 $setDifference 进行的一些额外过滤对于 false从 $map 返回的结果，因为这样做“首先在文档中”并且“在” $group 中需要阶段，是处理此问题的最有效方法

$result = $collection->aggregate(array(
    array( '$match' => array(
        'push' => array( 
            'time' => array( 
                '$gte' =>  MongoDate( strtotime('-5 days',time()) )
            )
        )     
    )),
    array( '$group' => array(
        '_id' => '$user_id',
        'count' => array(
            '$sum' => array(
                '$size' => array(
                    '$setDifference' => array(
                        array( '$map' => array(
                            'input' => '$push',
                            'as' => 'time',
                            'in' => array(
                                '$cond' => array(
                                    array( '$gte' => array(
                                        '$$time',
                                        MongoDate( strtotime('-5 days',time()) )
                                    )),
                                    '$time',
                                    FALSE
                                )
                            ) 
                        )),
                        array(FALSE)
                    )
                )
            )
        )
    )),
    array( '$match' => array(
        'count' => array( '$lt' => 3 )
    )) 
));

因此，首先要通过 $match 找到包含满足条件的数组条目的“可能的”文档。然后找到 $group 下匹配数组项的“总”大小, 然后是最后的 $match排除总大小小于三个的所有结果。

对于大部分“JavaScript 大脑”(像我自己，训练有素)来说，这基本上是这样的结构:

db.collection.aggregate([
    { "$match": {
        "push": {
            "$gte": new Date( new Date().valueOf() - ( 5 * 1000 * 60 * 60 * 24 ))
        }
    }},
    { "$group": {
        "_id": "$user_id",
        "count": {
            "$sum": {
                "$size": {
                    "$setDifference": [
                        { "$map": {
                            "input": "$push",
                            "as": "time",
                            "in": {
                                "$cond": [
                                    { "$gte": [ 
                                        "$$time",
                                        new Date( 
                                            new Date().valueOf() - 
                                            ( 5 * 1000 * 60 * 60 * 24 )
                                        )
                                    ]},
                                    "$$time",
                                    false
                                ]
                            }
                        }},
                        [false]
                    ]
                }
            }
        }
    }},
    { "$match": { "count": { "$lt": 3 } } }
])

此外，MongoDB 的 future 版本将提供 $filter ，这简化了整个$map和 $setDifference声明部分:

db.collection.aggregate([
    { "$match": {
        "push": {
            "$gte": new Date( new Date().valueOf() - ( 5 * 1000 * 60 * 60 * 24 ))
        }
    }},
    { "$group": {
        "_id": "$user_id",
        "count": {
            "$sum": {
                "$size": {
                    "$filter": {
                        "input": "$push",
                        "as": "time",
                        "cond": {
                            "$gte": [
                                "$$time",
                                new Date( 
                                    new Date().valueOf() - 
                                    ( 5 * 1000 * 60 * 60 * 24 )
                                )                       
                            ]
                        }
                    }
                }
            }
        }
    }},
    { "$match": { "count": { "$lt": 3 } } }
])

同时请注意，“日期”可能最好在管道定义“之前”计算为一个单独的变量，以获得最佳准确性。

关于php - 在 Mongodb 中聚合嵌套数组，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32501767/