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, #environment, #formatter, #host, #logger, #metrics

Attributes inherited from Base

#filter, #name

Instance Method Summary collapse

Methods inherited from Subscriber

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

Methods inherited from Base

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

Constructor Details

#initialize(url:, compress: false, ssl: {}, username: nil, password: nil, header: {}, proxy_url: :ENV, 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.

header: [Hash]
  Custom HTTP headers to send with each request.
  Default: {} ( do not send any custom headers)
  Example: {"Authorization" => "Bearer BEARER_TOKEN"}

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.

proxy_url: [String]
  URL of proxy server to use for HTTP(s) connections.  Should
    include username and password if required.
    Example: http://user@pass:example.com/some_path
  To enable SSL include https in the URL.
    Example: https://example.com/some_path
  If this is set to :ENV, Net::HTTP will use the environment http_proxy*
    variables if they are set.  If set to nil then no proxy will be used,
    even if the environment variables are set.

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



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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
 
# File 'lib/semantic_logger/appender/http.rb', line 98

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

  @url              = url
  @proxy_url        = proxy_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"
  }.merge(header)
  @header["Content-Encoding"] = "gzip" if @compress

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

  @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

  @proxy_uri = URI.parse(@proxy_url) if @proxy_url && @proxy_url != :ENV

  @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

#proxy_url ⇒ Object (readonly)

Returns the value of attribute proxy_url.



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

def proxy_url
  @proxy_url
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



189
190
191
192
193
 
# File 'lib/semantic_logger/appender/http.rb', line 189

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

#reopen ⇒ Object

Re-open after process fork



160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
 
# File 'lib/semantic_logger/appender/http.rb', line 160

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

  @http = if @proxy_uri
            Net::HTTP.new(server, port, @proxy_uri.host, @proxy_uri.port, @proxy_uri.user, @proxy_uri.password)
          else
            Net::HTTP.new(server, port, @proxy_url)
          end

  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