Conditional pipeline


Hello everyone,

I want to apply a specific pipeline if a field exist in the pipeline.yml but i don't know how to figure it out.

For exemple event with the field version1 will be sent to the pipeline 1 and event with the field version2 will be sent to the pipeline 2. Here is my pipeline.yml config

//- my-pipeline_1
path.config: "/Users/dkuiate/logstash-6.6.2/condition1.conf"
pipeline.workers: 3

  • my-other-pipeline
    path.config: "/Users/dkuiate/logstash-6.6.2/condition2.conf"
    queue.type: persisted

Best regards


You could use pipeline-to-pipeline communications for that. You would probably want to use a distributor pattern.

1 Like