TimeStream集成Prometheus接口

例如，通过Prometheus Remote Write方式写入如下数据：

{
  "labels": {
    "instance": "127.0.0.1:9114",
    "job": "elasticsearch"
  },
  "metrics": {
    "up": 0.0,
    "scrape_samples_post_metric_relabeling": 0.0,
    "scrape_samples_scraped": 0.0,
    "scrape_duration_seconds": 4.45999E-4,
    "scrape_series_added": 0.0
  },
  "@timestamp": "1655717638795"
}

Prometheus API返回的维度字段会去掉前缀labels.，/api/v1/labels接口返回结果如下：

{
  "status" : "success",
  "data" : [
    "__name__",
    "instance",
    "job"
  ]
}
                

Prometheus API返回的指标字段会去掉前缀metrics.，/api/v1/metadata接口返回结果如下：

{
  "status" : "success",
  "data" : {
    "scrape_samples_post_metric_relabeling" : [
      {
        "type" : "gauge",
        "help" : "",
        "unit" : ""
      }
    ],
    "scrape_samples_scraped" : [
      {
        "type" : "gauge",
        "help" : "",
        "unit" : ""
      }
    ],
    "scrape_duration_seconds" : [
      {
        "type" : "gauge",
        "help" : "",
        "unit" : ""
      }
    ],
    "scrape_series_added" : [
      {
        "type" : "gauge",
        "help" : "",
        "unit" : ""
      }
    ],
    "up" : [
      {
        "type" : "gauge",
        "help" : "",
        "unit" : ""
      }
    ]
  }
}

如果您自定义了数据模型，则需要额外配置前后缀关键字，否则Prometheus API返回的就是实际的数据。配置前后缀关键字的示例如下：

PUT _time_stream/{name}
{
  "time_stream": {
    "labels_fields": "@labels.*_l",
    "metrics_fields": "@metrics.*_m",
    "label_prefix": "@labels.",
    "label_suffix": "_l",
    "metric_prefix": "@metrics.",
    "metric_suffix": "_m"
  }
}

POST /_time_stream/prom_write/{index}
---PB data---

在Prometheus中配置Remote Write，即可将Prometheus数据同步到Elasticsearch，配置示例如下：

remote_write:
  - url: "http://127.0.0.1:9200/_time_stream/prom_write/prom_index"
    basic_auth:
     username: elastic
     password: xxxx