class Fluent::Plugin::JSONInJSONParser

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/parser_json_in_json.rb, line 12
def configure(conf)
  if conf.has_key?('time_format')
    conf['time_type'] ||= 'string'
  end

  super
end
parse(text) { |time, record| ... } click to toggle source
# File lib/fluent/plugin/parser_json_in_json.rb, line 20
def parse(text)
  record = Yajl.load(text)

  values = Hash.new

  record.each do |k, v|
    if v.is_a?(String) && /^\s*(\{|\[)/ =~ v
      begin
        deserialized = Yajl.load(v)
        if deserialized.is_a?(Hash)
          values.merge!(deserialized)
          record.delete k
        elsif deserialized.is_a?(Array)
          values[k] = deserialized
        end
      rescue Yajl::ParseError
        # continue if failed to parse record
      end
    end
  end
  record.merge!(values)

  time, record = convert_values(parse_time(record), record)

  yield time, record
rescue Yajl::ParseError
  yield nil, nil
end