fluentdのin_tailで特定フィールドを数値型に変換する拡張クラス

gistfile1.rb

#@config
#<source>
#  type mytail
#  format apache
#  path /var/log/httpd/access_log
#  tag apache.access
#  to_i size,code
#</source>

module Fluent
class MyTail < TailInput
  Fluent::Plugin.register_input('mytail', self)

  config_param :to_i, :string

  def configure(conf)
    super

    @to_i = @to_i.split(',').map {|path| path.strip }
  end

  def parse_line(line)
    time, record = @parser.parse(line)
    @to_i.each {|key|
      record[key] = record[key].to_i
    }
    return time, record
  end
end
end