按 15 分钟间隔时间聚合组

Question

我正在尝试计算 15 分钟的平均数据速度。我得到了结果，它包含平均速度，但不确定它是否正确，并且对于 15 分钟的设置，也是minutes零。o3 := bson.M{    "$group": bson.M{        "_id": bson.M{            "minute": bson.M{                "$subtract": []interface{}{                    "$timestamp",                    bson.M{                        "$mod": []interface{}{                            "$minute",                            15,                        },                    },                },            },        },        "averageSpeed": bson.M{            "$avg": "$speed",        },    },}有人做过类似的事情或可以提供帮助吗？

Answer 1

在 mongo shell 中运行以下管道应该会给你正确的结果：

pipeline = [

    { 

        "$group": {

            "_id": {

                "year": { "$year": "$timestamp" },

                "dayOfYear": { "$dayOfYear": "$timestamp" },

                "minute_interval": {

                    "$subtract": [ 

                        { "$minute": "$timestamp" },

                        { "$mod": [{ "$minute": "$timestamp" }, 15] }

                    ]

                }

            },

            "averageSpeed": { "$avg": "$speed" }

        }

    }

]

db.collection.aggregate(pipeline)

其中等效的 mGo 表达式如下（未经测试）：

pipeline := []bson.D{   

    bson.M{

        "$group": bson.M{

            "_id": bson.M{

                "year": bson.M{ "$year": "$timestamp" },

                "dayOfYear": bson.M{ "$dayOfYear": "$timestamp" },

                "minute_interval": bson.M{

                    "$subtract": []interface{}{ 

                        bson.M{ "$minute": "$timestamp" },

                        bson.M{ "$mod": []interface{}{ bson.M{ "$minute": "$timestamp" }, 15, }, } }

                    }

                }

            },

            "averageSpeed": bson.M{ "$avg": "$speed" }

        }

    }

}

pipe := collection.Pipe(pipeline)

iter := pipe.Iter()