Contents

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

# An redis output that does nothing.
class LogStash::Outputs::Redis < LogStash::Outputs::Base
  config_name "redis-increment"

  # The hostname of your Redis server.
  config :host, :validate => :string, :default => "127.0.0.1:6379"

  # Password to authenticate with. There is no authentication by default.
  config :password, :validate => :password

  # The Redis database number.
  config :db, :validate => :number, :default => 0

  # Connection timeout
  config :timeout, :validate => :number, :default => 5

  # Interval for reconnecting to failed Redis connections
  config :reconnect_interval, :validate => :number, :default => 1

  # The name of a redis key
  config :key, :validate => :string, :required => true

  public
  def register
    require 'redis'
    @redis = nil
  end # def register

  public
  def receive(event)
    begin
      key = event.sprintf(@key)

      @redis ||= connect
      @redis.incr(key)
    rescue => e
      @logger.warn("Failed to increment event to Redis", :event => event,
                   :identity => identity, :exception => e,
                   :backtrace => e.backtrace)
      sleep @reconnect_interval
      @redis = nil
      retry
    end
  end # def event

  private
  def connect
    @current_host, @current_port = @host[@host_idx].split(':')
    params = {
      :host => @current_host,
      :port => @current_port,
      :timeout => @timeout,
      :db => @db,
    }
    @logger.debug("connection params", params)

    if @password
      params[:password] = @password.value
    end

    Redis.new(params)
  end

  # A string used to identify a Redis instance in log messages
  def identity
    "redis://#{@password}@#{@current_host}:#{@current_port}/#{@db} #{@key}"
  end
end # class LogStash::Outputs::Redis

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
logstash-output-redis-increment-0.2.0	lib/logstash/outputs/redis-increment.rb
logstash-output-redis-increment-0.1.0	lib/logstash/outputs/redis-increment.rb