У меня есть работающий ELK с входным сигналом, полученным из filebeat, который ищет несколько файлов журнала и отправляет их в logstash.Logstash извлекает поток, фильтрует его, чтобы сопоставить строки с некоторыми полями, а затем отправляет их вasticsearch.Теперь я хотел бы проверить перед выходом вasticsearch, существует ли уже существующий документ для предстоящего входа вasticsearch.Если да, я хочу применить другой выходной плагин вместо эластичного поиска.