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