时间序列数据的 Mongodb 聚合

Question

我有一个包含几十万条记录的时间序列数据集。我正在尝试在 mongo 中创建一个聚合查询，以便在平均价格的同时按时间间隔对这些数据进行分组。

理想情况下，我想要 10 分钟的间隔（600000 毫秒）和平均价格。我不太确定如何从现在的位置继续。

数据~几十万条记录：

  {
    "time" : 1391485215000,
    "price" : "0.00133355",
    }

query = [
    {   
        "$project": {
            "_id":"$_id",
            "price":"$price",
            "time": {
                xxxx
            }
        }
    },
    {   
        "$group": {xxxx}
    }
]

Answer 1

所以看来我的架构存在根本缺陷。我使用的是纪元时间戳而不是 mongo 的 Date 类型，并将其他数字存储为字符串而不是双精度数。我尝试了一些解决方法，但除非它们的类型正确，否则您似乎无法使用内置聚合函数。

    $project: {
        year: { $year: '$time'},
        month: { $month: '$time'},
        day: { $dayOfMonth: '$time'},
        hour: { $hour: '$time'},
        price: 1,
        total: 1,
        amount: 1
    }
},
{
    $group : {
        _id: { year: '$year', month: '$month', day: '$day', hour: '$hour' },
        price:{
            $avg: "$price"
        },
        high:{
            $max: "$price"
        },
        low:{
            $min: "$price"
        },
        amount:{
            $sum: "$amount"
        },
        total:{
            $sum: "$total"
        }
    }