Class: Fluent::JsonExpanderOutput

Inherits:
MultiOutput
  • Object
show all
Defined in:
lib/fluent/plugin/out_json_expander.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#outputs ⇒ Object (readonly)

Returns the value of attribute outputs.



11
12
13
 
# File 'lib/fluent/plugin/out_json_expander.rb', line 11

def outputs
  @outputs
end

Instance Method Details

#configure(conf) ⇒ Object 



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
44
 
# File 'lib/fluent/plugin/out_json_expander.rb', line 18

def configure(conf)
  super

  if @remove_prefix
    @removed_prefix_string = @remove_prefix + '.'
    @removed_length = @removed_prefix_string.length
  end
  if @add_prefix
    @added_prefix_string = @add_prefix + '.'
  end

  @outputs = []
  @mutex = Mutex.new
  @mappings = {}
  @invalid_mapping_keys = []

  # touch_recursive: read and throw away to supress unread configuration warning
  # ref: fluent-plugin-forest/lib/fluent/plugin/out_forest.rb
  templates = conf.elements.select{|e| touch_recursive(e).name == 'template' }

  if templates.size != 1
    raise Fluent::ConfigError, "Just 1 template must be contained"
  end

  @template = templates.first
  @expand_target_keys = scan_keys(@template)
end

#emit(tag, es, chain) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/fluent/plugin/out_json_expander.rb', line 56

def emit(tag, es, chain)
  if @remove_prefix and
      ((tag.start_with?(@removed_prefix_string) and tag.length > @removed_length) or tag == @remove_prefix)
    tag = tag[@removed_length..-1]
  end
  if @add_prefix
    tag = tag.empty? ? @add_prefix : (@added_prefix_string + tag)
  end

  es.each {|time, record|
    output, new_record = *new_output(record)
    if output
      dup_es = Fluent::ArrayEventStream.new([[time, new_record]])
      null_chain = Fluent::NullOutputChain.instance
      output.emit(tag, dup_es, null_chain)
    end
  }
  chain.next
end

#shutdown ⇒ Object 



76
77
78
79
80
81
 
# File 'lib/fluent/plugin/out_json_expander.rb', line 76

def shutdown
  super
  @mappings.values.each do |output|
    output.shutdown
  end
end

#touch_recursive(e) ⇒ Object 



46
47
48
49
50
51
52
53
54
 
# File 'lib/fluent/plugin/out_json_expander.rb', line 46

def touch_recursive(e)
  e.keys.each do |k|
    e[k]
  end
  e.elements.each do |child|
    touch_recursive(child)
  end
  e
end