Мне было интересно, могу ли я отфильтровать наши документы перед индексированием в Elasticsearch на основе определенных условий. Например, предположим, что я хочу исключить документ из индекса, если field1 = "something". Могу ли я решить эту проблему, используя готовые процессоры в Elasticsearch и используя "узел приема", чтобы покрыть это? Могу ли я написать собственный процессор, если его не существует?
Вы не можете сделать это непосредственно в Elasticsearch, используя конвейеры (см. Эта проблема).
Однако в Logstash есть фильтр уронить, предназначенный именно для этого и который может быть полезен в вашем случае.