fluent-agent-lite のように正規表現なしで行をそのまま一つのキーに突っ込んで取り込む fluentd plugin

in_tailasis.rb

module Fluent

class AsisTailInput < TailInput
  Plugin.register_input('tailasis', self)

  def initialize
    super

    @parser = nil
  end

  def configure_parser(conf)
    @parser = AsisParser.new
    @parser.configure(conf)
  end
end

class AsisParser
  include Configurable

  config_param :asis_key, :string, :default => 'message'

  def parse(text)
     record = {}
     record[@asis_key] = text
     return Engine.now, record
  end
end

end