Я пытаюсь разобрать некоторый json с помощью logstash, в настоящее время файл, который мне нравится вводить, имеет следующую структуру (упрощенную):
-4: {"audit":{"key1":"value1","key2":"value2"}}
-4: {"audit":{"key1":"value1","key2":"value2"}}
Поэтому мне нужно удалить префикс -4:, чтобы правильно проанализировать файл с помощью json. К сожалению, я не могу использовать кодек json для входного плагина, потому что он не в правильном формате json. Поэтому мои требования к конвейеру:
Я пробовал со следующим конвейером, который дает мне ошибку синтаксического анализа:
input {
tcp {
port => 5001
codec => multiline {
pattern => "^-\d:."
what => previous
}
#codec => json_lines
type => "raw_input"
}
}
filter {
if [type] == "raw_input" {
mutate {
gsub => ["message", "^-\d:.", ""]
}
}
json {
source => "message"
}
mutate {
convert => { "[audit][sequenceNumber]" => "integer" }
add_field => { "test" => "%{[audit][sequenceNumber]}"}
}
}
output {
file {
path => "/var/log/logstash/debug-output.log"
codec => line { format => "%{message}" }
}
}
Можно ли добиться этого с помощью logstash? Любые предложения, как это сделать?

Круто, рад, что помогло!