Conditional pipeline

#1

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

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

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

Best regards

#2

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

1 Like