Может быть возможно добавить поле на основе определенной части classpath, когда filebeat отправляется в logstash
Вот сообщение:
2019-10-30 12:30:01,185 DEBUG com.company.class1.json - Connection[/10.0.0.31:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
Я пытаюсь отфильтровать все, что начинается сcom.company и для создания специального нового поля, но с полным именем пути к классу, который может быть разным каждый раз, возможно, что будет выполняться динамически что-то вроде:
filter {
grok {
match => { "message" => "%{GREEDYDATA:com.company}" }
}
if "com.company" in [message]{
mutate {
add_field => { "%{here to put com.company.class1.json}" => "12345" }
convert => { "com.company.class1.json" => "integer" }
}
}
}