logstash可以更新或删除elasticsearch中数据吗

• index: indexes a document (an event from Logstash).
• delete: deletes a document by id (An id is required for this action)
• create: indexes a document, fails if a document by that id already exists in the index.
• update: updates a document by id. Update has a special case where you can upsert — update a document if not already present. See the upsert option. NOTE: This does not work and is not supported in Elasticsearch 1.x. Please upgrade to ES 2.x or greater to use this feature with Logstash!

input{

    jdbc {

        type => "111"



        jdbc_connection_string => "jdbc:mysql://localhost:3306/111?characterEncoding=UTF-8&useSSL=false&serverTimezone=CTT"

        jdbc_user => "root"

        jdbc_password => "111"

        jdbc_driver_library => "/home/logstash-7.3.1/mysql/mysql-connector-java-8.0.18.jar"

        jdbc_driver_class => "com.mysql.cj.jdbc.Driver"

        jdbc_paging_enabled => true

        jdbc_page_size => 1000

        

        record_last_run => true

        use_column_value => false

        tracking_column => "modify_date"

        tracking_column_type => "timestamp"

        last_run_metadata_path => "/home/logstash-7.3.1/data/111.txt"



        statement => "select * from 111 where modify_date > :sql_last_value"

        schedule => "* * * * *"

    }

}

output{

    if [type] == "111" {

        elasticsearch {

            action => "index"

            hosts => ["localhost:9201","localhost:9202"]

            index => "111"

            document_id => "%{id}"

            template_overwrite => true

            manage_template => false

        }

        stdout {

            codec => json_lines

        }

    }

}