Hi everybody, does exist a method to pass the value of pipeline id dinamically in send_to. in my environment every log has a field with a value corresponding to a pipeline id present in my pipelines.yml. A hoped that with this method i avoided to write a series of "if" in cascade. Below an example of the logstash code i'm writing.
Code
input { pipeline { address => filebeat } }
filter{
mutate{
add_field => {
"pipeline_id" => "%{[target][field_1]}"
}
}
}
output {
pipeline { send_to => %{pipeline_id}}
}