class LogStash::Codecs::Snowplow
Read serialized Thrift Snowplow
enriched-event records as Logstash events
This plugin is used to serialize Logstash events as Snowplow
enriched-event objects.
Encoding¶ ↑
This codec is for serializing individual Logstash events as Snowplow
enriched-event.
Decoding¶ ↑
This codec is for deserializing individual Snowplow
enriched-event serialized objects as Logstash events.
Usage¶ ↑
Example usage with kafka input.
- source,ruby
input {
kafka { codec => snowplow { } }
} filter {
...
} output {
...
}
Public Instance Methods
decode(data) { |event| ... }
click to toggle source
# File lib/logstash/codecs/snowplow.rb, line 53 def decode(data) event = Serializer.deserialize(data, @json_fields) yield LogStash::Event.new(event) rescue @logger.error("Fail to decode: #{data}") end
register()
click to toggle source
# File lib/logstash/codecs/snowplow.rb, line 48 def register @logger.info("Initializing logstash snowplow codec: json fields: #{@json_fields}!") end