my_pipeline_1_v2

input {
  s3 {
    access_key_id => "AKIAWTLM5HIMNFNXVVFK"
    secret_access_key => "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"
    bucket => "elastic-boost-camp"
    sincedb_path => "/var/lib/logstash/sincedb_wine_v2"
    prefix => "wine"
  }
}
filter {
  csv {
    columns => [id,country,description,designation,points,price,province,region_1,region_2,taster_name,taster_twitter_handle,title,variety,winery]
  }
}
output {
    elasticsearch {
    user => "logstash_output_elasticsearch"
    password => "logstash"
    index => "wine_v2"
  }
}