Contents

# encoding: utf-8
require "logstash/filters/base"
require "logstash/namespace"
require "fastimage"

# This example filter will replace the contents of the default
# message field with whatever you specify in the configuration.
#
# It is only intended to be used as an example.
class LogStash::Filters::Imgsize < LogStash::Filters::Base

  # Setting the config_name here is required. This is how you
  # configure this filter from your Logstash config.
  #
  # filter {
  #   example {
  #     message => "My message..."
  #   }
  # }
  #
  config_name "imgsize"

  # Replace the message with this value.
  config :image_url_field, :validate => :string, :default => "image_url"
  config :image_width_field, :validate => :string, :default => "image_width"
  config :image_height_field, :validate => :string, :default => "image_height"
  config :drop_on_fail, :validate => :boolean, :default => false

  public
  def register
    # Add instance variables
  end # def register

  public
  def filter(event)
    @logger.debug? && @logger.debug("Running imgsize filter")
    begin
      image_url = event[@image_url_field]
      width, height = FastImage.size(image_url)
      event.cancel if @drop_on_fail && (width.nil? || height.nil?)
      event[@image_width_field] = width
      event[@image_height_field] = height
    rescue => exception
      @logger.warn("Imgszie exception occurred. Error: #{exception} ; ImageUrl: #{image_url}")
      event.cancel if @drop_on_fail
    end
    filter_matched(event)
  end # def filter
end # class LogStash::Filters::Imgsize

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-filter-imgsize-1.0.1	lib/logstash/filters/imgsize.rb