1

ここに私のサンプルデータがあります:

{
"_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"

}

平均値を 2 時間間隔でグループ化し、次の集計クエリを作成しようとしています。

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.、すべての調査を行いましたが、目的の結果が得られません。

4

1 に答える 1

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 }
]

どのモンゴが不平を言っている

パイプライン ステージ仕様オブジェクトには、フィールドが 1 つだけ含まれている必要があります。

間違ったフィールドを認識できないため

'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 }
]
于 2016-10-14T11:56:30.767 に答える