class Fluent::JqFilter
Public Instance Methods
filter_stream(tag, es)
click to toggle source
# File lib/fluent/plugin/filter_jq.rb, line 12 def filter_stream(tag, es) result_es = Fluent::MultiEventStream.new es.each do |time, record| jq_search(time, record, result_es) end result_es rescue => e log.warn e.message log.warn e.backtrace.join(', ') end
Private Instance Methods
jq_search(time, record, result_es)
click to toggle source
# File lib/fluent/plugin/filter_jq.rb, line 27 def jq_search(time, record, result_es) json = MultiJson.dump(record) JQ(json).search(@jq) do |value| unless value.is_a?(Hash) value = {@no_hash_root_key => value} end result_es.add(time, value) end end