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