Logstash json 字段转换

Question

Logstash 正在接收来自 filebeat 的 json 输入。然后它会解析 json。

filter {
  json {
    source => "message"
    target => "data"
  }
}

这些数据然后进入弹性搜索。一切都很完美。

现在我需要转换一些 json 字段。

例如data.body_bytes_sent 必须转换为整数。

我知道 logstash 中有一个转换字段：

filter {
  mutate {
    convert => { "msgSubmissionTime" => "integer" }
  }
}

但是如何告诉它转换解析后的 json 对象中的字段呢？

Answer 1

这行得通：

filter {
  json {
    source => "message"
    target => "data"
  }
  mutate {
    convert => {"[data][body_bytes_sent]" => "integer"}
    convert => {"[data][bytes_sent]" => "integer"}
  }
}