input { 
  file {
    path => ["E:/222/*.csv"]
    start_position => "beginning"
  }
}
filter {
  csv {
    separator => ","
    columns => ["tm","openid","fuwuhao","action","content"]
  }  
   date {
  
      match => ["timestamp", "yyyy-MM-dd HH:mm:ss", "ISO8601"]
 
      remove_field => ["tm"]
  
    }
  
  }

output {
  elasticsearch {
    hosts => ["http://192.168.222.222:9200"]
    index => "wx" 
  }
}