elasticsearch - 如何使用logstash自动在弹性中插入，更新和删除

Question

如何使用logstash自动插入，更新和删除 flex ？

在我的输入语句中，我得到了该操作(插入，更新，删除)，当我仅执行插入操作或仅执行更新操作时，该方法就可以正常工作，但是如果该进程使用插入，更新或删除操作，则会抛出错误代码=> 400，％c =>“http:// ip:9200 / _bulk操作=>

output{
# Para ELK
        elasticsearch {
                    hosts => "localhost:9200"
                    index => "hca_001"
                    document_type => "hca_001_lgs"
                    document_id => "%{hca_numero}%{hca_anio}"
                    action => "%{my_accion}"   
                    doc_as_upsert => true
                    manage_template => false        
        }
}

Answer 1

您是否尝试过有条件的工作？

output{
  if [my_accion] == "delete" {
        elasticsearch {
                    action => "delete"   
                    ...  
        }
  } else {
        elasticsearch {
                    action => "update"
                    doc_as_upsert => true   
                    ...  
        }
  }
}

过去，这为我解决了类似的问题。