fluentd-recover.rb

require 'fluent-logger'

# specify the host and port to forward data to
logger = Fluent::Logger.new(nil, :host => "localhost", :port => 24224)

fn = ARGV[0]
fh = File.new(fn)

msgpack_unpacker = MessagePack::Unpacker.new(fh)

begin
  msgpack_unpacker.each do |time, record|
    # post data with the tag "t"
    logger.post_with_time('t', record, time)
  end
ensure
  fh.close
end

If the message does not contain time and have tag name, object id and message then use the following code.

require 'fluent-logger'

specify the host and port to forward data to

logger = Fluent::Logger.new(nil, :host => "localhost", :port => 24222)
fn = ARGV[0]
fh = File.new(fn)
msgpack_unpacker = MessagePack::Unpacker.new(fh)
begin
msgpack_unpacker.each do | tag, id, record|
puts "-- pushing data in tag " ; puts tag ; puts "--- object id"; puts id ; puts "---- message"; puts record ; # just for debug
logger.post(tag, record )
end
ensure
fh.close
end