Contents

require 'fluent/plugin/script_append/version'

class Fluent::ScriptAppendOutput < Fluent::Output

  config_param :key,             :string, :default => nil
  config_param :language,        :string, :default => 'ruby'
  config_param :run_script,      :string, :default => ''
  config_param :record_var_name, :string, :default => 'record'
  config_param :new_tag,         :string, :default => nil
  config_param :prefix,          :string, :default => nil

  def configure(conf)
    super
    ensure_param_set!(:key, @key)
    ensure_param_set!(:run_script, @run_script)
    ensure_param_set!("new_tag or prefix", (@new_tag or @prefix))

    @script_runner = Object.new

    # TODO multiple script language support
    if @language != 'ruby'
      warn "Plugin out_script_append would not accept 'language' value other than 'ruby'. Ignoring."
    end

    eval <<-RUBY
      def @script_runner.run(#{@record_var_name})
        #{@run_script}
      end
    RUBY
  end

  def emit(tag, event_stream, chain)
    event_stream.each do |time, record|
      rewrited_tag = get_new_tag(tag)
      record[@key] = @script_runner.run(record)
      Fluent::Engine.emit(rewrited_tag, time, record)
    end
    chain.next
  end

  private
  def get_new_tag(tag)
    if @new_tag
      @new_tag
    elsif @prefix
      [@prefix, tag].join('.')
    end
  end

  def ensure_param_set!(name, value)
    unless value
      raise "#{name} must be set"
    end
  end

  Fluent::Plugin.register_output('script_append', self)
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-script_append-0.0.1	lib/fluent/plugin/out_script_append.rb