时间戳

首页 > 解决方案 > Logstash：将格式化的指标事件发送到 Elasticsearch

elasticsearch - Logstash：将格式化的指标事件发送到 Elasticsearch

问题描述

我可以使用相关插件stdout从事件中捕获一些指标，logstash如下所示：

在我的filter文件中：

  if "somekeyword" in [tags] {
    metrics {
      meter => "events_somekeyword"
      flush_interval => 60
      add_tag => "metric_somekeyword"
    }
  }

在我的outputs档案中

if "metric_somekeyword" in [tags] {
        stdout {
          codec => line {
            format => "Time: %{+YYYY-MM-dd HH:mm:ss Z} | Metric: rate 1m | Client: SomeJeyword | Rate: %{[events_somekeyword][rate_1m]}"
          }
        }

我的问题是如何在输出方面翻译完全相同的操作/格式elasticsearch。

例如

{
    "Metric Rate": "1m",
    "Client": "SomeKeyword",
    "Rate": "THE_ACTUAL_RATE_VALUE_HERE",
    "@timestamp": "2018-11-02T11:34:34.000Z",
}

我还希望（如果可能）将Rate其四舍五入到最接近的整数值；

以上应分组为每日索引

标签： elasticsearchlogstashmetrics

解决方案

如果我理解正确，您想像这样解析您的键值消息

filter {
  kv { 
      source => "field_containing_the_message_to_parse"
      field_split => "|"
      value_split => ":"
  }
}

如果这是您想要的，还有更多选项可用于自定义您的解析https://www.elastic.co/guide/en/logstash/current/plugins-filters-kv.html

推荐阅读