10

我有如下访问日志存储在 mongodb 实例中：

Time                           Service                      Latency
[27/08/2013:11:19:22 +0000]    "POST Service A HTTP/1.1"    403
[27/08/2013:11:19:24 +0000]    "POST Service B HTTP/1.1"    1022 
[27/08/2013:11:22:10 +0000]    "POST Service A HTTP/1.1"    455

是否有像PERCENTILE_DISCOracle 中的分析功能来计算百分位数？

我想计算一段时间内的延迟百分位数。

4

3 回答 3

9

似乎仍然没有计算百分位数的本地方法，但通过组合一些聚合运算符，您可以获得相同的结果。

db.items.aggregate([
        {'$group': {
            '_id': {
                'league': '$league',
                'base': '$base',
                'type': '$type'
            },
            'value': {'$push': '$chaosequiv'}
        }},
        {'$unwind': '$value'},
        {'$sort': {'value': 1}},
        {'$group': {'_id': '$_id', 'value': {'$push': '$value'}}},
        {'$project': {
            '_id': 1,
            'value': {'$arrayElemAt': ['$value', {'$floor': {'$multiply': [0.25, {'$size': '$value'}]}}]}
        }}
    ], allowDiskUse=True)

请注意，我在 pymongo 中编写了我的原始代码，以解决需要在第一组中对 3 个字段进行分组的问题，因此这可能比单个字段所需的更复杂。我会针对这个问题写一个解决方案，但我认为没有足够的具体信息。

于 2016-09-07T10:02:45.153 回答
3

开始Mongo 4.4，该$group阶段有一个新的聚合运算符$accumulator，允许通过 javascript 用户定义的函数在文档分组时自定义累积文档。

因此，为了找到第 20 个百分位数：

// { "a" : 25, "b" : 12 }
// { "a" : 89, "b" : 73 }
// { "a" : 25, "b" : 7  }
// { "a" : 25, "b" : 17 }
// { "a" : 89, "b" : 14 }
// { "a" : 89, "b" : 17 }
// { "a" : 25, "b" : 24 }
// { "a" : 25, "b" : 15 }
// { "a" : 25, "b" : 22 }
// { "a" : 25, "b" : 94 }
db.collection.aggregate([
  { $group: {
    _id: "$a",
    percentile: {
      $accumulator: {
        accumulateArgs: ["$b"],
        init: function() { return []; },
        accumulate: function(bs, b) { return bs.concat(b); },
        merge: function(bs1, bs2) { return bs1.concat(bs2); },
        finalize: function(bs) {
          bs.sort(function(a, b) { return a - b });
          return bs[Math.floor(bs.length*.2) + 1];
        },
        lang: "js"
      }
    }
  }}
])
// { "_id" : 89, "percentile" : 17 }
// { "_id" : 25, "percentile" : 15 }

蓄能器：

  • 累积在场上b( accumulateArgs)
  • 初始化为空数组 ( init)
  • b在数组中累积项目 ( accumulateand merge)
  • 最后对b项目（finalize）进行百分位数计算
于 2020-03-15T15:33:11.087 回答
0

计算 0 到 100 的百分位数（步骤 5）

// { "session": 1, "date" : 2013-08-27 11:00::00, "latency" : 403 }
// { "session": 1, "date" : 2013-08-27 11:00::01, "latency" : 1022 }
// { "session": 1, "date" : 2013-08-27 11:00::02, "latency" : 455 }
// { "session": 1, "date" : 2013-08-27 11:00::02, "latency" : 307 }
// { "session": 2, "date" : 2013-08-27 12:00::00, "latency" : 403 }
// { "session": 2, "date" : 2013-08-27 12:00::01, "latency" : 1022 }
// { "session": 2, "date" : 2013-08-27 12:00::02, "latency" : 455 }
// { "session": 2, "date" : 2013-08-27 12:00::02, "latency" : 307 }

var interval = 5

db.getCollection.aggregate([
    {
        $group:{
            _id: { $toString: "$session" },
            value: { $push: "$atency" }
        }
    },
    {
        $addFields:{
            index : {$range: [0, 100, interval]}
        }
    },
    {$unwind: "$index"},
    {
        $addFields:{
            p_index : {$divide: ["$index", 100]}
        }
    },
    {
        $addFields:{
            percentile_x : {$toDouble: {'$arrayElemAt': ['$value', {'$floor': {'$multiply': ["$p_index", {'$size': '$value'}]}}]}}
        }
    },
    {   $project: {
           'percentile': "$index",
           'value': "$percentile_x"
        }
    },
        {$sort: {
          percentile: 1
        }
    }
])
于 2021-11-22T23:25:25.713 回答