[Pipeline to Pipeline communication] - passing pipeline id dinamically to send_to =>

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.

input { pipeline { address => filebeat } }



            add_field => {

                "pipeline_id" => "%{[target][field_1]}"




output {

        pipeline { send_to =>  %{pipeline_id}} 


No, pipeline to pipeline links are created when the pipelines are initialized. They cannot be dependent on the contents of events.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.