class Fluent::HttpBufferedOutput
Main Output plugin class
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_http_buffered.rb, line 8 def initialize super require 'net/http' require 'uri' end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_http_buffered.rb, line 26 def configure(conf) super # Check if endpoint URL is valid unless @endpoint_url =~ /^#{URI.regexp}$/ fail Fluent::ConfigError, 'endpoint_url invalid' end begin @uri = URI.parse(@endpoint_url) rescue URI::InvalidURIError raise Fluent::ConfigError, 'endpoint_url invalid' end # Parse http statuses @statuses = @http_retry_statuses.split(',').map { |status| status.to_i } @statuses = [] if @statuses.nil? @http = Net::HTTP.new(@uri.host, @uri.port) @http.read_timeout = @http_read_timeout @http.open_timeout = @http_open_timeout end
format(tag, time, record)
click to toggle source
# File lib/fluent/plugin/out_http_buffered.rb, line 62 def format(tag, time, record) [tag, time, record].to_msgpack end
shutdown()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_http_buffered.rb, line 54 def shutdown super begin @http.finish rescue end end
start()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_http_buffered.rb, line 50 def start super end
write(chunk)
click to toggle source
# File lib/fluent/plugin/out_http_buffered.rb, line 66 def write(chunk) data = [] chunk.msgpack_each do |(tag, time, record)| data << [tag, time, record] end request = create_request(data) begin response = @http.start do |http| request = create_request(data) http.request request end if @statuses.include? response.code.to_i # Raise an exception so that fluent retries fail "Server returned bad status: #{response.code}" end rescue IOError, EOFError, SystemCallError => e # server didn't respond $log.warn "Net::HTTP.#{request.method.capitalize} raises exception: #{e.class}, '#{e.message}'" ensure begin @http.finish rescue end end end
Protected Instance Methods
create_request(data)
click to toggle source
# File lib/fluent/plugin/out_http_buffered.rb, line 97 def create_request(data) request = Net::HTTP::Post.new(@uri.request_uri) # Headers request['Content-Type'] = 'application/json' # Body request.body = JSON.dump(data) request end