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