如何减去时间序列元素以获得与之前日期的差异?

How to subtract time series element to get differance to the date before?

我正在尝试在 Mongo-Atlas 中构建仪表板图表。 Table 应该在 x 轴上显示日期,在 y 轴上显示 _id。 值应该是与之前日期的计数差异。

我有一个包含数据点的集合,例如:

_id: "someName"
timestamp: 2019-09-05T06:24:24.689+00:00
count: 50

_id: "someName"
timestamp: 2019-09-04T06:24:24.689+00:00
count: 40

...

目标是获取计数与之前数据点的差异。同名

_id: "someName"
timestamp: 2019-09-05T06:24:24.689+00:00
count: 50
difference: 10

_id: "someName"
timestamp: 2019-09-04T06:24:24.689+00:00
count: 40
difference: 17

...

这样我就可以table列出差异

到目前为止我创建了一个聚合管道

[
{$sort: {
  "timestamp": -1
}}, 
{$group: {
  _id: "$_id",
  count: {
    $push: { count: "$count", timestamp: "$timestamp" }
  }
}}, 
{$project: {
  _id: "$_id",
  count: "$count",
  countBefore: { $slice: [ "$count", 1, { $size: "$count" } ] }
}}
]

我希望减去 count 和 countBefore 以便我得到一个包含数据点和差值的数组...

所以我试着跟随:

{$project: {
  countDifference: {
    $map: {
      input: "$countBefore",
        as: "before",
        in: {
          $subtract: ["$$before.count", "$count.count"] 
/*"$count.count" seems to be the problem, since an integer works*/
        }
      }
    }
  }
}

Mongo图集只显示"An unknown error occurred"

我很乐意提供一些建议:)

以下查询可以获得预期的输出:

db.collection.aggregate([
    {
        $sort:{
            "timestamp":1
        }
    },
    {
        $group:{
            "_id":"$id",
            "counts":{
                $push:"$count"
            }
        }
    },
    {
        $project:{
            "differences":{
                $reduce:{
                    "input":"$counts",
                    "initialValue":{
                        "values":[],
                        "lastValue":0
                    },
                    "in":{
                        "values":{
                            $concatArrays:[
                                "$$value.values",
                                [
                                    {
                                        $subtract:["$$this","$$value.lastValue"]
                                    }
                                ]
                            ]
                        },
                        "lastValue":"$$this"
                    }
                }
            }
        }
    },
    {
        $project:{
            "_id":0,
            "id":"$_id",
            "plots":"$differences.values"
        }
    }
]).pretty()

数据集:

{
    "_id" : ObjectId("5d724550ef5e6630fde5b71e"),
    "id" : "someName",
    "timestamp" : "2019-09-05T06:24:24.689+00:00",
    "count" : 50
}
{
    "_id" : ObjectId("5d724550ef5e6630fde5b71f"),
    "id" : "someName",
    "timestamp" : "2019-09-04T06:24:24.689+00:00",
    "count" : 40
}
{
    "_id" : ObjectId("5d724796ef5e6630fde5b720"),
    "id" : "someName",
    "timestamp" : "2019-09-06T06:24:24.689+00:00",
    "count" : 61
}
{
    "_id" : ObjectId("5d724796ef5e6630fde5b721"),
    "id" : "someName",
    "timestamp" : "2019-09-07T06:24:24.689+00:00",
    "count" : 72
}
{
    "_id" : ObjectId("5d724796ef5e6630fde5b722"),
    "id" : "someName",
    "timestamp" : "2019-09-08T06:24:24.689+00:00",
    "count" : 93
}
{
    "_id" : ObjectId("5d724796ef5e6630fde5b723"),
    "id" : "someName",
    "timestamp" : "2019-09-09T06:24:24.689+00:00",
    "count" : 100
}

输出:

{ "id" : "someName", "plots" : [ 40, 10, 11, 11, 21, 7 ] }

解释: 我们将相同 idcount 推入 counts 数组,然后应用 $reduce 操作它准备一组新值,其中当前值将保持 counts 数组的当前值和先前值之间的差异。对于第一个值,前一个值被视为零。