Sha256: a860f315b2ecd0f9ce0b14bb2905d8fccf1f4811041e3622d3864bf6c0c5864b
Contents?: true
Size: 892 Bytes
Versions: 53
Compression:
Stored size: 892 Bytes
Contents
module Fluent::Plugin
class S3Input
class LZOExtractor < Extractor
S3Input.register_extractor('lzo', self)
config_param :command_parameter, :string, default: '-qdc'
def configure(conf)
super
check_command('lzop', 'LZO')
end
def ext
'lzo'.freeze
end
def content_type
'application/x-lzop'.freeze
end
def extract(io)
path = if io.respond_to?(path)
io.path
else
temp = Tempfile.new("lzop-temp")
temp.write(io.read)
temp.close
temp.path
end
stdout, succeeded = Open3.capture2("lzop #{@command_parameter} #{path}")
if succeeded
stdout
else
raise "Failed to extract #{path} with lzop command."
end
end
end
end
end
Version data entries
53 entries across 53 versions & 3 rubygems