python - MongoDB 聚合然后平均

Question

我有一个使用如下聚合框架的 MongoDB 查询:

System._get_collection().aggregate([
        { "$match": {
            "system_id": system.id,
            "utc_timestamp": {
                "$gte": datetime.datetime.now().replace(hour=0, minute=0, second=0, microsecond=0) - datetime.timedelta(days=1),
                "$lt": datetime.datetime.now().replace(hour=0, minute=0, second=0, microsecond=0)
            }
        }},
        { "$group": {
            "_id": { "$dayOfYear": "$utc_timestamp" },
            "correct": {
                "$sum": { "$cond": [
                    { "$eq": [ "$status", 455 ]}, 1, 0
                ]}
            },
            "total_count": { "$sum": 1 }
        }},
        { "$project": {
            "correctness": {
                "$cond": [
                    { "$eq": [ "$correct", 0 ] },
                    0,
                    { "$multiply" : [{"$divide": [ "$correct", "$total_count" ]}, 100] }
                ]
            }
        }}
    ])

输出如下所示:

{'result': [{'_id': 272, 'correctness': 99.89373007438896}], 'ok': 1.0}

我想向结果添加一个字段，该字段是每个匹配的 System 文档中所有 delay 字段的平均值。

我尝试将 "delay": { "$avg": "$delay"}, 添加到 $group 部分，但它并没有改变结果。

我想要这样的结果:

{'result': [{'_id': 272, 'correctness': 99.89373007438896, 'delay': 5}], 'ok': 1.0}

注意上面的'delay': 5，它应该是计算出的平均值。

我需要以某种方式将其添加到投影中吗？或者，我做错了什么吗？

Answer 1

除了 _id 之外，您从 $project 中省略的任何字段都不包含在输出中，因此您只需添加 delay给它:

{ "$project": {
    "correctness": {
        "$cond": [
            { "$eq": [ "$correct", 0 ] },
            0,
            { "$multiply" : [{"$divide": [ "$correct", "$total_count" ]}, 100] }
        ]
    },
    "delay": 1
}}