6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
# File 'lib/fluent/plugin/parser_json_in_json.rb', line 6
def parse(text)
record = Yajl.load(text)
record.each do |key, value|
record[key] = Yajl.load(value)
end
value = @keep_time_key ? record[@time_key] : record.delete(@time_key)
if value
if @time_format
time = @mutex.synchronize { @time_parser.parse(value) }
else
begin
time = value.to_i
rescue => e
raise ParserError, "invalid time value: value = #{value}, error_class = #{e.class.name}, error = #{e.message}"
end
end
else
if @estimate_current_event
time = Engine.now
else
time = nil
end
end
if block_given?
yield time, record
else
return time, record
end
rescue Yajl::ParseError
if block_given?
yield nil, nil
else
return nil, nil
end
end
|