logstash + rails + redis

logstash_redis.rb

# Gemfile
gem "logstasher"


# production.rb
  config.logstasher.enabled = true

# config/initializers/logstash.rb
$logstasher_redis = Redis.new(:port => 9002)

module LogStasher
  class RequestLogSubscriber < ActiveSupport::LogSubscriber
    alias_method :orig_process_action, :process_action
    def process_action(event)
      orig_process_action(event)
      $logstasher_redis.publish("logstash:channel", event.to_json)
    end
  end
end