Logstash逐行输入

Question

如何使用编解码器逐行读取logstash文件？ 当我尝试下面的配置，但它不工作：配置

file { 
path => "C:/DEV/Projects/data/*.csv" 
start_position => "beginning" 
codec => line { 
    format => "%{[data]}" 
} 

Answer 1

例与elasticsearch输出：

input{ 
    file { 
     path => "C:/DEV/Projects/data/*.csv" 
     start_position => beginning 
    } 

} 

filter { 

csv { 

    columns => [ 
     "COLUMN_1", 
     "COLUMN_2", 
     "COLUMN_3", 
     . 
     . 
     "COLUMN_N" 
    ] 
    separator => "," 
} 

mutate { 
     convert => { 
      "COLUMN_1" => "float" 
      "COLUMN_4" => "float" 
      "COLUMN_6" => "float" 
     } 
} 
} 

output { 
elasticsearch { 

    hosts => ["localhost:9200"] 
    action => "index" 
    index => "test_index" 
} 

对于过滤器： https://www.elastic.co/guide/en/logstash/current/plugins-filters-csv.html