当输入中不存在时，elasticsearch logstash 删除答案

【问题标题】：elasticsearch logstash delete when does not exist in input当输入中不存在时，elasticsearch logstash 删除
【发布时间】：2018-11-02 10:58:10
【问题描述】：

我有一个 elasticsearch 数据库，如果输入语句中不存在，我想删除所有文档？你能帮帮我吗，

提前致谢

input {
jdbc {
    jdbc_validate_connection => true
    jdbc_connection_string => "jdbc:postgresql://xxxx:xxxx/xxxx"
    jdbc_user => "xxxx"
    jdbc_password => "xxxx"
    jdbc_driver_library => "/usr/share/logstash/Drivers/postgres/postgresql-9.4.1212.jar"
    jdbc_driver_class => "org.postgresql.Driver"
    statement => "SELECT acso.usagers.id as id FROM acso.usagers WHERE acso.usagers.date_suppression is null"
    tags => ["idUsagers"]
}}  filter {}output {
elasticsearch {
    action => delete
    index => "usagers"
    document_type => "atms"
    doc_as_upsert => true
    document_id => "%{id}"
    hosts => "xxxxxx.example.org"}}

【问题讨论】：

标签： linux elasticsearch command-line logstash

【解决方案1】：

如果我正确理解了您的问题，您希望从 ES 中删除任何未由 JDBC 查询返回的文档。如果这是正确的，我会看到两个选项：

运行查询，将结果放入一个新索引中，并使用该索引进行查询。如果需要，您可以创建一个 index alias 以隐藏您的应用程序的实际索引名称。
运行查询并update ES 中的任何文档以显示它们仍然存在。 Delete未标记的文档。

【讨论】：