Configuration example for Logstash: from csv to EventStore

logstash-rdnltd.yml

input {
  file {
    path => ["C:/inbound/*/*.csv"]
    start_position => "beginning"    
  }
}
filter {    
  fingerprint {
    source => "message"
    target => "[@metadata][fingerprint]"
    method => "UUID"
  }
}
output {
  stdout { codec => rubydebug }
  http {
    url => "http://localhost:2113/streams/inbound-data"
    http_method => "post"
    content_type => "application/vnd.eventstore.events+json"    
    format => "message"
    message => '[
      {        
        "eventType": "InboundDataReceived",
        "eventId": "%{[@metadata][fingerprint]}",                
        "data": { "message": "%{message}" },
        "metadata": { "host": "%{host}", "path": "%{path}" }
      }
    ]'
  }
}