Logstash：在Elasticsearch

Question

發送不同的JSON的領域不同類型的

我已經JSON數據的格式如下，我發送到logstash實例 監聽一個HTTP端點

{ 
    client: "c", 
    pageInfo: ["a","b","c"], 
    restInfo: ["r","s","t"] 
} 

我的目標是這個輸入發送到彈性搜索終點是同一指數中的兩種不同類型;例如

PUT elasticsearchhost:port/myindex/pageInfo 
     { client: "c", pageInfo: ["a","b","c"] } 

PUT elasticsearchhost:port/myindex/restInfo 
     { client: "c", restInfo: ["r","s","t"] } 

我曾試圖與一些過濾器在logstash（分裂，變異，神交），但我不明白如何執行這個非常具體的分裂，或者如果我也必須修改輸出部分我的配置

Answer 1

您將需要使用clone克隆事件，然後修改克隆。

例如：

filter { 
    clone { clones => ["pageInfo", "restInfo" ] } 
    if [type]=="pageInfo" { 
    mutate { 
     remove_field => "restInfo" 
    } 
    } 
    if [type] == "restInfo" { 
    mutate { 
     remove_field => "pageInfo" 
    } 
    } 
} 

，然後在你的elasticsearch輸出，一定要包括document_type => "%{type}"