class Serializer

Public Class Methods

deserialize(event, json_fields) click to toggle source

@param [String] event @param [Array] json_fields @return [Hash]

# File lib/logstash/serializer.rb, line 143
def self.deserialize(event, json_fields)
  event_values = event.to_s.split("\t")
  event = Hash[*ENRICHED_EVENT.zip(event_values).flatten]
  json_fields.each do |field|
    event = parse(event, field) if event.has_key? field
  end
  event
end
parse(event, field) click to toggle source

@param [Hash] event @param [String] field @return [Hash]

# File lib/logstash/serializer.rb, line 155
def self.parse(event, field)
  event[field] = JSON.parse(event[field])
  return event
rescue JSON::ParserError => _
  return event
end