Class: LogStash::Filters::Rest

Inherits:

Base

• Object
• Base
• LogStash::Filters::Rest

Includes:

PluginMixins::HttpClient

Defined in:

lib/logstash/filters/rest.rb

Overview

Logstash REST Filter This filter calls a defined URL and saves the answer into a specified field.

Instance Method Summary

• #filter(event) ⇒ Object
• #register ⇒ Object

Instance Method Details

#filter(event) ⇒ Object

# File 'lib/logstash/filters/rest.rb', line 292

def filter(event)
  return unless filter?(event)
  request = LogStash::Util.deep_clone(@request)
  @logger.debug? && @logger.debug('processing request',
                                  :request => request,
                                  :sprintf_needed => @sprintf_needed)

  if @sprintf_needed
    request = field_intrpl(request, event)
    @logger.debug? && @logger.debug('interpolated request',
                                    :request => request)
  end

  client_error = nil
  begin
    code, body = request_http(request)
  rescue StandardError => e
    client_error = e
  end

  if !client_error && code.between?(200, 299)
    @logger.debug? && @logger.debug('success received',
                                    :code => code, :body => body)
    process_response(body, event)
  else
    @logger.debug? && @logger.debug('http error received',
                                    :code => code, :body => body,
                                    :client_error => client_error)
    if @fallback.empty?
      @logger.error('error in rest filter',
                    :request => request, :json => @json,
                    :code => code, :body => body,
                    :client_error => client_error)
      @tag_on_rest_failure.each { |tag| event.tag(tag) }
    else
      @logger.debug? && @logger.debug('setting fallback',
                                      :fallback => @fallback)
      event.set(@target, @fallback)
    end
  end
  filter_matched(event)
end

#register ⇒ Object

# File 'lib/logstash/filters/rest.rb', line 143

def register
  @request = normalize_request(@request).deep_freeze
  @sprintf_fields = find_sprintf(
    LogStash::Util.deep_clone(@request)
  ).deep_freeze
  @sprintf_needed = !@sprintf_fields.empty?
  @target = normalize_target(@target).freeze
end