Create a gist now

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Configuration example for Logstash: from csv to EventStore
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}" }
}
]'
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment