1. 程式人生 > 實用技巧 >logstash7.6.2更新已存在的elasticsearch記錄

logstash7.6.2更新已存在的elasticsearch記錄

配置檔案中新增配置
output {
    
    if [type]=="student" {
        elasticsearch {
            hosts => "10.130.225.49:9200"
            user => elastic
            password => elastic
            # index名
            index => "monitor_student"
            # type名
            document_type => "_doc"
            # 需要關聯的資料庫中有有一個id欄位,對應索引的id號
            document_id => "%{id}"
            #當id存在的時候會覆蓋,當id不存的時候會新增
            doc_as_upsert => true
            #如果id存在,則覆蓋,如果id不存在,則列印一條錯誤日誌(不會影響logstash的執行)
            action => "update"
            #如果之前_id存在的話,直接拋棄掉新資料。這樣的話老資料不會被覆蓋。如果_id不存在的話  直接新增。
            action => "create"
        }
        stdout {
            codec => json_lines
        }

    }
    
}