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