MongoDB 按名称和不同时间间隔聚合

Question

我已经找了几天的解决方案，但我无法得到结果。请帮帮我！

我在 MongoDB 中有一个数据：

{ name: 'apple', date: 2018-01-04T10:00:00.000Z, price: 100 }
{ name: 'apple', date: 2018-01-04T10:01:00.000Z, price: 101 }
{ name: 'apple', date: 2018-01-04T10:02:00.000Z, price: 102 }
{ name: 'apple', date: 2018-01-04T10:03:00.000Z, price: 103 }
{ name: 'apple', date: 2018-01-04T10:04:00.000Z, price: 102 }
{ name: 'apple', date: 2018-01-04T10:05:00.000Z, price: 104 }

{ name: 'cherry', date: 2018-01-04T10:00:00.000Z, price: 53 }
{ name: 'cherry', date: 2018-01-04T10:01:00.000Z, price: 55 }
{ name: 'cherry', date: 2018-01-04T10:02:00.000Z, price: 51 }
{ name: 'cherry', date: 2018-01-04T10:03:00.000Z, price: 51 }
{ name: 'cherry', date: 2018-01-04T10:04:00.000Z, price: 50 }
{ name: 'cherry', date: 2018-01-04T10:05:00.000Z, price: 52 }

{ name: 'melon', date: 2018-01-04T10:00:00.000Z, price: 133 }
{ name: 'melon', date: 2018-01-04T10:01:00.000Z, price: 132 }
{ name: 'melon', date: 2018-01-04T10:02:00.000Z, price: 136 }
{ name: 'melon', date: 2018-01-04T10:03:00.000Z, price: 137 }
{ name: 'melon', date: 2018-01-04T10:04:00.000Z, price: 138 }
{ name: 'melon', date: 2018-01-04T10:05:00.000Z, price: 140 }

我想通过一个查询得到这个结果。

{name: 'apple', price_last: 104, price_1m_ago: 102, price_5m_ago: 100}
{name: 'cherry', price_last: 52, price_1m_ago: 50, price_5m_ago: 53}
{name: 'melon', price_last: 140, price_1m_ago: 138, price_5m_ago: 133}

我尝试使用聚合，但无法以任何方式构建有效查询。

food.aggregate([
    {
        $group: {
            _id: "$name",
            price_last: {$last:"$price"},
        }
    }
]}

Answer 1

如果您的数据保证每分钟包含一个元素，并且中间没有丢失数据，则可以很容易地实现，如下所示：

food.aggregate([{
    $sort: {
        date: 1 // make sure the data is sorted by date
    }
}, {
    $group: {
        _id: "$name",
        prices: { $push: "$price" }, // create an array per "name" with all prices in it
    }
}, {
    $project: {
        name: "$_id",
        price_last: { $arrayElemAt: [ "$prices", -1 ] }, // select the first from the end of the array
        price_1m_ago:  { $arrayElemAt: [ "$prices", -2 ] }, // select the second from the end
        price_5m_ago:  { $arrayElemAt: [ "$prices", -6 ] } // select the 6th from the end
    }
}])

Answer 2

我得到了这个结果，@Avij 第一个查询。这里有一些重复。如果我用 new Date() 替换 $minute:'$lastdate'，查询将不起作用。

{ _id: 'melon',
    lastPrice: 1575,
    five_min_price: 1573 },
  { _id: 'cherry',
    lastPrice: 60165,
    five_min_price: 59098 },
  { _id: 'apple',
    lastPrice: 0153,
    five_min_price: 0155 },
  { _id: 'apple',
    lastPrice: 0153,
    five_min_price: 0154 },
  { _id: 'apple',
    lastPrice: 0153,
    five_min_price: 0155 },
  { _id: 'apricot',
    lastPrice: 6897,
    five_min_price: 6235 },
  { _id: 'apricot',
    lastPrice: 6897,
    five_min_price: 6235 },
  { _id: 'apricot',
    lastPrice: 6897,
    five_min_price: 6822 },
  { _id: 'apricot',
    lastPrice: 6897,
    five_min_price: 683 },
  { _id: 'cucumber',
    lastPrice: 3461,
    five_min_price: 3533 },
  { _id: 'cucumber',
    lastPrice: 3461,
    five_min_price: 3496 },
  { _id: 'orange',
    lastPrice: 5366,
    five_min_price: 5367 }

也许可以用 $match 来剪切查询，然后在这个结果中排在最后。如果数据库中的日期以 Unix 格式存储。这适用于一个结果，但我如何获得 10s/30s/1m/5m/10m/30m/1h 会导致一个查询。

var now = new Date();
var shift_5_min = shift_5_min = new Date( now.valueOf() - ( 5*60*1000 );

"$match": {
    "date": { "$lte": shift_5_min" }
}
$group: {
     id: "$name",
     price: {$last: "$price"}
}