Class: SemanticLogger::Appender::Http

Inherits:
Subscriber show all
Defined in:
lib/semantic_logger/appender/http.rb

Direct Known Subclasses

ElasticsearchHttp, SplunkHttp, Metric::Signalfx

Instance Attribute Summary collapse

Attributes inherited from Subscriber

#application, #formatter, #host, #logger, #metrics

Attributes inherited from Base

#filter, #name

Instance Method Summary collapse

Methods inherited from Subscriber

#close, #flush, #level, #should_log?

Methods inherited from Base

#backtrace, #fast_tag, #level, #level=, #measure, #payload, #pop_tags, #push_tags, #should_log?, #silence, #tagged, #tags, #with_payload

Constructor Details

#initialize(url:, compress: false, ssl: {}, username: nil, password: nil, open_timeout: 2.0, read_timeout: 1.0, continue_timeout: 1.0, **args, &block) ⇒ Http

Create HTTP(S) log appender

Parameters:

url: [String]
  Valid URL to post to.
    Example: http://example.com/some_path
  To enable SSL include https in the URL.
    Example: https://example.com/some_path
    verify_mode will default: OpenSSL::SSL::VERIFY_PEER

application: [String]
  Name of this application to appear in log messages.
  Default: SemanticLogger.application

host: [String]
  Name of this host to appear in log messages.
  Default: SemanticLogger.host

username: [String]
  User name for basic Authentication.
  Default: nil ( do not use basic auth )

password: [String]
  Password for basic Authentication.

compress: [true|false]
  Whether to compress the JSON string with GZip.
  Default: false

ssl: [Hash]
  Specific SSL options: For more details see NET::HTTP.start
    ca_file, ca_path, cert, cert_store, ciphers, key, ssl_timeout,
    ssl_version, verify_callback, verify_depth and verify_mode.

level: [:trace | :debug | :info | :warn | :error | :fatal]
  Override the log level for this appender.
  Default: SemanticLogger.default_level

formatter: [Object|Proc]
  An instance of a class that implements #call, or a Proc to be used to format
  the output from this appender
  Default: Use the built-in formatter (See: #call)

filter: [Regexp|Proc]
  RegExp: Only include log messages where the class name matches the supplied.
  regular expression. All other messages will be ignored.
  Proc: Only include log messages where the supplied Proc returns true
        The Proc must return true or false.

open_timeout: [Float]
  Default: 2.0

read_timeout: [Float]
  Default: 1.0

continue_timeout: [Float]
  Default: 1.0

Raises:

  • (ArgumentError) 


83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'lib/semantic_logger/appender/http.rb', line 83

def initialize(url:,
               compress: false,
               ssl: {},
               username: nil,
               password: nil,
               open_timeout: 2.0,
               read_timeout: 1.0,
               continue_timeout: 1.0,
               **args,
               &block)

  @url              = url
  @ssl_options      = ssl
  @username         = username
  @password         = password
  @compress         = compress
  @open_timeout     = open_timeout
  @read_timeout     = read_timeout
  @continue_timeout = continue_timeout

  # On Ruby v2.0 and greater, Net::HTTP.new already uses a persistent connection if the server allows it
  @header                     = {
    'Accept'       => 'application/json',
    'Content-Type' => 'application/json',
    'Connection'   => 'keep-alive',
    'Keep-Alive'   => '300'
  }
  @header['Content-Encoding'] = 'gzip' if @compress

  uri     = URI.parse(@url)
  @server = uri.host
  raise(ArgumentError, "Invalid format for :url: #{@url.inspect}. Should be similar to: 'http://hostname:port/path'") unless @server

  @port     = uri.port
  @username = uri.user if !@username && uri.user
  @password = uri.password if !@password && uri.password
  @path     = uri.path
  # Path cannot be empty
  @path     = '/' if @path == ''

  if uri.scheme == 'https'
    @ssl_options[:use_ssl]     = true
    @ssl_options[:verify_mode] ||= OpenSSL::SSL::VERIFY_PEER
    @port                      ||= HTTP.https_default_port
  else
    @port ||= HTTP.http_default_port
  end
  @http = nil

  super(**args, &block)
  reopen
end

Instance Attribute Details

#compress ⇒ Object

Returns the value of attribute compress.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def compress
  @compress
end

#continue_timeout ⇒ Object

Returns the value of attribute continue_timeout.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def continue_timeout
  @continue_timeout
end

#header ⇒ Object

Returns the value of attribute header.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def header
  @header
end

#http ⇒ Object (readonly)

Returns the value of attribute http.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def http
  @http
end

#open_timeout ⇒ Object

Returns the value of attribute open_timeout.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def open_timeout
  @open_timeout
end

#path ⇒ Object (readonly)

Returns the value of attribute path.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def path
  @path
end

#port ⇒ Object (readonly)

Returns the value of attribute port.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def port
  @port
end

#read_timeout ⇒ Object

Returns the value of attribute read_timeout.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def read_timeout
  @read_timeout
end

#server ⇒ Object (readonly)

Returns the value of attribute server.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def server
  @server
end

#ssl_options ⇒ Object (readonly)

Returns the value of attribute ssl_options.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def ssl_options
  @ssl_options
end

#url ⇒ Object (readonly)

Returns the value of attribute url.



24
25
26
 
# File 'lib/semantic_logger/appender/http.rb', line 24

def url
  @url
end

#username ⇒ Object

Returns the value of attribute username.



22
23
24
 
# File 'lib/semantic_logger/appender/http.rb', line 22

def username
  @username
end

Instance Method Details

#log(log) ⇒ Object

Forward log messages to HTTP Server



162
163
164
165
166
 
# File 'lib/semantic_logger/appender/http.rb', line 162

def log(log)
  message = formatter.call(log, self)
  logger.trace(message)
  post(message)
end

#reopen ⇒ Object

Re-open after process fork



137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
 
# File 'lib/semantic_logger/appender/http.rb', line 137

def reopen
  # Close open connection if any
  begin
    @http&.finish
  rescue IOError
    nil
  end

  @http = Net::HTTP.new(server, port)

  if @ssl_options
    @http.methods.grep(/\A(\w+)=\z/) do |meth|
      key = Regexp.last_match(1).to_sym
      @ssl_options.key?(key) || next
      @http.__send__(meth, @ssl_options[key])
    end
  end

  @http.open_timeout     = @open_timeout
  @http.read_timeout     = @read_timeout
  @http.continue_timeout = @continue_timeout
  @http.start
end