两小时 Mongodb 聚合

Question

这是我的示例数据：

{
"_id": {
    "$oid": "5654a8f0d487dd1434571a6e"
},

"ValidationDate": {
    "$date": "2015-11-24T13:06:19.363Z"
},

"DataRaw": " WL 00100100012015-08-28 02:44:17+0000+ 16.81 8.879  1084.00",

"ReadingsAreValid": true,

"locationID": " WL 001",

"Readings": {

    "pH": {
        "value": 8.879
    },

    "SensoreDate": {
        "value": {
            "$date": "2015-08-28T02:44:17.000Z"
        }
    },

    "temperature": {
        "value": 16.81
    },

    "Conductivity": {
        "value": 1084
    }
},
"HMAC":"ecb98d73fcb34ce2c5bbcc9c1265c8ca939f639d791a1de0f6275e2d0d71a801"

}

我正在尝试按两小时间隔对平均值进行分组，并进行以下聚合查询。

Query = [{"$unwind":"$Readings"},                    
        {'$group' : { "_id": {
            "year": { "$year": "$Readings.SensoreDate.value" },
            "dayOfYear": { "$dayOfYear": "$Readings.SensoreDate.value" },
            "interval": {
                "$subtract": [ 
                    { "$hour": "$Readings.SensoreDate.value"},
                    { "$mod": [{ "$hour": "$Readings.SensoreDate.value"},2]}
                ]
            }
        }},
'AverageTemp' : { '$avg' : '$Readings.temperature.value'}, "AveragePH": {"$avg" : "$Readings.pH.value"}, "AverageConduc": {"$avg" : "$Readings.Conductivity.value"}}
, {"$limit":10}]

这给了我一个错误提示 A pipeline stage specification object must contain exactly one field. 我已经做了所有的研究，但无法得到想要的结果。

Answer 1

经过一些格式化后，您当前的聚合管道如下所示：

Query = [
    { "$unwind": "$Readings" },                    
    {
        '$group' : { 
            "_id": {
                "year": { "$year": "$Readings.SensoreDate.value" },
                "dayOfYear": { "$dayOfYear": "$Readings.SensoreDate.value" },
                "interval": {
                    "$subtract": [ 
                        { "$hour": "$Readings.SensoreDate.value"},
                        { 
                            "$mod": [
                                { "$hour": "$Readings.SensoreDate.value" },
                                2
                            ]
                        }
                    ]
                }
            }
        },
        'AverageTemp' : { '$avg' : '$Readings.temperature.value' }, 
        "AveragePH": { "$avg" : "$Readings.pH.value" }, 
        "AverageConduc": { "$avg" : "$Readings.Conductivity.value" }
    }, 
    { "$limit": 10 }
]

mongo 抱怨

A pipeline stage specification object must contain exactly one field.

因为它无法识别放错位置的字段

'AverageTemp' : { '$avg' : '$Readings.temperature.value' }, 
"AveragePH": { "$avg" : "$Readings.pH.value" }, 
"AverageConduc": { "$avg" : "$Readings.Conductivity.value" }

正确的管道应该在 $group 管道阶段包含这些字段，因此工作管道如下：

Query = [
    { "$unwind": "$Readings" },                    
    {
        "$group" : { 
            "_id": {
                "year": { "$year": "$Readings.SensoreDate.value" },
                "dayOfYear": { "$dayOfYear": "$Readings.SensoreDate.value" },
                "interval": {
                    "$subtract": [ 
                        { "$hour": "$Readings.SensoreDate.value"},
                        { 
                            "$mod": [
                                { "$hour": "$Readings.SensoreDate.value" },
                                2
                            ]
                        }
                    ]
                }
            },
            "AverageTemp" : { "$avg" : "$Readings.temperature.value" }, 
            "AveragePH": { "$avg" : "$Readings.pH.value" }, 
            "AverageConduc": { "$avg" : "$Readings.Conductivity.value" }
        }       
    }, 
    { "$limit": 10 }
]

两小时 Mongodb 聚合

Two Hours Mongodb Aggregation

javascript

python

arrays

mongodb

pymongo-3.x