parser_heroku.rb

require 'fluent/plugin/parser'
require 'heroku-log-parser'

module Fluent
  module Plugin
    class HerokuParser < Parser
      Fluent::Plugin.register_parser('heroku', self)

      def configure(conf)
        super
      end

      def parse(data)
        records = HerokuLogParser.parse(data)
        yield Time.now.to_i, records
      end
    end
  end
end

これをlib/fluent/plugin/においてfluent.confをこんな感じで書けばherokuのLog Drainsから流れてくるログを受け取れる

<source>
  @type http
  port 9880
  bind 0.0.0.0
  format heroku
</source>