Logstash将ES服务器A数据迁移ES服务器B

input {
    stdin{
    }
    elasticsearch {
        hosts => ["http://127.0.0.1:9200"]
        user => "admin"
        index => "*"
        password => "admin"
        #设置为true，将会提取ES文档的元数据信息，例如index、type和id。
        docinfo => true
    }
    
}

output {
    
    elasticsearch {
        hosts => ["http://127.0.0.2:9200"]
        user => elastic
        password => elastic
        #指定同步索引名。input中设置为*，表示同步全部索引；output中设置为%{[@metadata][_index]}，表示匹配元数据中的index，即迁移前后两台服务器ES的索引相同。
        index => "%{[@metadata][_index]}"
        #设置为%{[@metadata][_type]}，表示匹配元数据中索引的type，即迁移前后ES服务器的索引类型相同。
        document_type => "%{[@metadata][_type]}"
        #设置为%{[@metadata][_id]}，表示匹配元数据中文档的id，即迁移前后ES服务器的文档id相同。
        document_id => "%{[@metadata][_id]}"
    }
    stdout {
        codec => json_lines
    }
    
}