如何在Logstash配置文件中包含過濾器？

Question

我正在使用LogStash接收來自日誌文件的數據，日誌文件具有不同類型的日誌。

第一行表示自定義日誌，而第二行表示JSON格式的日誌。

現在，我想編寫一個過濾器，它將根據內容解析日誌，並最終將所有JSON格式的日誌導向一個名爲jsonformat.log的文件，而另一個日誌則記錄到一個單獨的文件中。

Answer 1

您可以利用json過濾器並檢查它是否失敗或不確定發送事件的位置。

input { 
    file { 
     path => "/Users/mysystem/Desktop/abc.log" 
     start_position => beginning 
     ignore_older => 0 
    } 
} 
filter { 
    json { 
    source => "message" 
    } 
} 
output { 
    # this condition will be true if the log line is not valid JSON 
    if "_jsonparsefailure" in [tags] { 
    file { 
     path => "/Users/mysystem/Desktop/nonjson.log" 
    } 
    } 
    # this condition will be true if the log line is valid JSON 
    else { 
    file { 
     path => "/Users/mysystem/Desktop/jsonformat.log" 
    } 
    } 
}