如何查找timeseries数据的最新项？

qgelzfjb 于 2021-06-10 发布在 ElasticSearch

关注(0)|答案(1)|浏览(452)

例如，存在诸如根分区利用率之类的timeseries数据。数据结构如下：

name: root_disk_utilizatoin
ip: 1.1.1.1
timestamp: 1234567890
value: 0.5

我们有数百万台服务器每隔几分钟报告一次这些数据。我的期望是找到每台服务器的最新数据。
第一个想法是将这些时间序列数据存储在一些存储器中，如elasticsearc或tsdb（influxdb/opentsdb）。然后查询存储以获得结果。但我担心表演。无论我选择什么存储，他们都必须执行以下两个步骤来归档结果。
按ip分组数据
按时间戳对数据排序并返回最新的数据
我想这将是一个非常昂贵的过程（花费了很多时间）。
所以我想这可能不是个好主意。
您是否有类似的要求，如何解决？
像XDB这样的timeseries db会有问题吗？

elasticsearch Database time-series data-analysis

来源：https://stackoverflow.com/questions/64762507/how-do-i-find-latest-item-for-timeseries-data

1条答案

按热度按时间

xtupzzrd1#

您可以使用术语聚合和最大聚合的组合
添加索引数据、搜索查询和搜索结果的工作示例
索引数据：

{
  "name": "root_disk_utilizatoin",
  "ip": "1.1.1.2",
  "timestamp": 1234567891,
  "value": 0.5
}
{
  "name": "root_disk_utilizatoin",
  "ip": "1.1.1.1",
  "timestamp": 1234567890,
  "value": 0.5
}

搜索查询：

{
  "size":0,
  "aggs": {
    "unique_id": {
      "terms": {
        "field": "ip.keyword",
        "order": {
          "latestOrder": "desc"
        },
        "size":1
      },
      "aggs": {
        "latestOrder": {
          "max": {
            "field": "timestamp"
          }
        }
      }
    }
  }
}

搜索结果：

"aggregations": {
    "unique_id": {
      "doc_count_error_upper_bound": 0,
      "sum_other_doc_count": 1,
      "buckets": [
        {
          "key": "1.1.1.2",
          "doc_count": 1,
          "latestOrder": {
            "value": 1.234567891E9
          }
        }
      ]
    }

展开查看全部

赞(0）回复(0）举报 2021-06-10

我来回答

如何查找timeseries数据的最新项？

1条答案

相关问题

热门标签

最新问答