263 lines
7.7 KiB
Ruby
263 lines
7.7 KiB
Ruby
####################################
|
|
# USAGE
|
|
#
|
|
# in your rack.rb file
|
|
# require this file and then:
|
|
#
|
|
# couch = CouchRest.new
|
|
# LOG_DB = couch.database!('couchrest-logger')
|
|
# use CouchRest::Logger, LOG_DB
|
|
#
|
|
# Note:
|
|
# to require just this middleware, if you have the gem installed do:
|
|
# require 'couchrest/middlewares/logger'
|
|
#
|
|
# For log processing examples, see examples at the bottom of this file
|
|
|
|
module CouchRest
|
|
class Logger
|
|
|
|
def self.log
|
|
Thread.current["couchrest.logger"] ||= {:queries => []}
|
|
end
|
|
|
|
def initialize(app, db=nil)
|
|
@app = app
|
|
@db = db
|
|
end
|
|
|
|
def self.record(log_info)
|
|
log[:queries] << log_info
|
|
end
|
|
|
|
def log
|
|
Thread.current["couchrest.logger"] ||= {:queries => []}
|
|
end
|
|
|
|
def reset_log
|
|
Thread.current["couchrest.logger"] = nil
|
|
end
|
|
|
|
def call(env)
|
|
reset_log
|
|
log['started_at'] = Time.now
|
|
log['env'] = env
|
|
log['url'] = 'http://' + env['HTTP_HOST'] + env['REQUEST_URI']
|
|
response = @app.call(env)
|
|
log['ended_at'] = Time.now
|
|
log['duration'] = log['ended_at'] - log['started_at']
|
|
# let's report the log in a different thread so we don't slow down the app
|
|
@db ? Thread.new(@db, log){|db, rlog| db.save_doc(rlog);} : p(log.inspect)
|
|
response
|
|
end
|
|
end
|
|
end
|
|
|
|
# inject our logger into CouchRest HTTP abstraction layer
|
|
module HttpAbstraction
|
|
|
|
def self.get(uri, headers=nil)
|
|
start_query = Time.now
|
|
log = {:method => :get, :uri => uri, :headers => headers}
|
|
response = super(uri, headers=nil)
|
|
end_query = Time.now
|
|
log[:duration] = (end_query - start_query)
|
|
CouchRest::Logger.record(log)
|
|
response
|
|
end
|
|
|
|
def self.post(uri, payload, headers=nil)
|
|
start_query = Time.now
|
|
log = {:method => :post, :uri => uri, :payload => (payload ? (JSON.load(payload) rescue 'parsing error') : nil), :headers => headers}
|
|
response = super(uri, payload, headers=nil)
|
|
end_query = Time.now
|
|
log[:duration] = (end_query - start_query)
|
|
CouchRest::Logger.record(log)
|
|
response
|
|
end
|
|
|
|
def self.put(uri, payload, headers=nil)
|
|
start_query = Time.now
|
|
log = {:method => :put, :uri => uri, :payload => (payload ? (JSON.load(payload) rescue 'parsing error') : nil), :headers => headers}
|
|
response = super(uri, payload, headers=nil)
|
|
end_query = Time.now
|
|
log[:duration] = (end_query - start_query)
|
|
CouchRest::Logger.record(log)
|
|
response
|
|
end
|
|
|
|
def self.delete(uri, headers=nil)
|
|
start_query = Time.now
|
|
log = {:method => :delete, :uri => uri, :headers => headers}
|
|
response = super(uri, headers=nil)
|
|
end_query = Time.now
|
|
log[:duration] = (end_query - start_query)
|
|
CouchRest::Logger.record(log)
|
|
response
|
|
end
|
|
|
|
end
|
|
|
|
|
|
# Advanced usage example
|
|
#
|
|
#
|
|
# # DB VIEWS
|
|
# by_url = {
|
|
# :map =>
|
|
# "function(doc) {
|
|
# if(doc['url']){ emit(doc['url'], 1) };
|
|
# }",
|
|
# :reduce =>
|
|
# 'function (key, values, rereduce) {
|
|
# return(sum(values));
|
|
# };'
|
|
# }
|
|
# req_duration = {
|
|
# :map =>
|
|
# "function(doc) {
|
|
# if(doc['duration']){ emit(doc['url'], doc['duration']) };
|
|
# }",
|
|
# :reduce =>
|
|
# 'function (key, values, rereduce) {
|
|
# return(sum(values)/values.length);
|
|
# };'
|
|
# }
|
|
#
|
|
# query_duration = {
|
|
# :map =>
|
|
# "function(doc) {
|
|
# if(doc['queries']){
|
|
# doc.queries.forEach(function(query){
|
|
# if(query['duration'] && query['method']){
|
|
# emit(query['method'], query['duration'])
|
|
# }
|
|
# });
|
|
# };
|
|
# }" ,
|
|
# :reduce =>
|
|
# 'function (key, values, rereduce) {
|
|
# return(sum(values)/values.length);
|
|
# };'
|
|
# }
|
|
#
|
|
# action_queries = {
|
|
# :map =>
|
|
# "function(doc) {
|
|
# if(doc['queries']){
|
|
# emit(doc['url'], doc['queries'].length)
|
|
# };
|
|
# }",
|
|
# :reduce =>
|
|
# 'function (key, values, rereduce) {
|
|
# return(sum(values)/values.length);
|
|
# };'
|
|
# }
|
|
#
|
|
# action_time_spent_in_db = {
|
|
# :map =>
|
|
# "function(doc) {
|
|
# if(doc['queries']){
|
|
# var totalDuration = 0;
|
|
# doc.queries.forEach(function(query){
|
|
# totalDuration += query['duration']
|
|
# })
|
|
# emit(doc['url'], totalDuration)
|
|
# };
|
|
# }",
|
|
# :reduce =>
|
|
# 'function (key, values, rereduce) {
|
|
# return(sum(values)/values.length);
|
|
# };'
|
|
# }
|
|
#
|
|
# show_queries = %Q~function(doc, req) {
|
|
# var body = ""
|
|
# body += "<h1>" + doc['url'] + "</h1>"
|
|
# body += "<h2>Request duration in seconds: " + doc['duration'] + "</h2>"
|
|
# body += "<h3>" + doc['queries'].length + " queries</h3><ul>"
|
|
# if (doc.queries){
|
|
# doc.queries.forEach(function(query){
|
|
# body += "<li>"+ query['uri'] +"</li>"
|
|
# });
|
|
# };
|
|
# body += "</ul>"
|
|
# if(doc){ return { body: body} }
|
|
# }~
|
|
#
|
|
#
|
|
# couch = CouchRest.new
|
|
# LOG_DB = couch.database!('couchrest-logger')
|
|
# design_doc = LOG_DB.get("_design/stats") rescue nil
|
|
# LOG_DB.delete_doc design_doc rescue nil
|
|
# LOG_DB.save_doc({
|
|
# "_id" => "_design/stats",
|
|
# :views => {
|
|
# :by_url => by_url,
|
|
# :request_duration => req_duration,
|
|
# :query_duration => query_duration,
|
|
# :action_queries => action_queries,
|
|
# :action_time_spent_in_db => action_time_spent_in_db
|
|
# },
|
|
# :shows => {
|
|
# :queries => show_queries
|
|
# }
|
|
# })
|
|
#
|
|
# module CouchRest
|
|
# class Logger
|
|
#
|
|
# def self.roundup(value)
|
|
# begin
|
|
# value = Float(value)
|
|
# (value * 100).round.to_f / 100
|
|
# rescue
|
|
# value
|
|
# end
|
|
# end
|
|
#
|
|
# # Usage example:
|
|
# # CouchRest::Logger.average_request_duration(LOG_DB)['rows'].first['value']
|
|
# def self.average_request_duration(db)
|
|
# raw = db.view('stats/request_duration', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.average_query_duration(db)
|
|
# raw = db.view('stats/query_duration', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.average_get_query_duration(db)
|
|
# raw = db.view('stats/query_duration', :key => 'get', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.average_post_query_duration(db)
|
|
# raw = db.view('stats/query_duration', :key => 'post', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.average_queries_per_action(db)
|
|
# raw = db.view('stats/action_queries', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.average_db_time_per_action(db)
|
|
# raw = db.view('stats/action_time_spent_in_db', :reduce => true)
|
|
# (raw.has_key?('rows') && !raw['rows'].empty?) ? roundup(raw['rows'].first['value']) : 'not available yet'
|
|
# end
|
|
#
|
|
# def self.stats(db)
|
|
# Thread.new(db){|db|
|
|
# puts "=== STATS ===\n"
|
|
# puts "average request duration: #{average_request_duration(db)}\n"
|
|
# puts "average query duration: #{average_query_duration(db)}\n"
|
|
# puts "average queries per action : #{average_queries_per_action(db)}\n"
|
|
# puts "average time spent in DB (per action): #{average_db_time_per_action(db)}\n"
|
|
# puts "===============\n"
|
|
# }
|
|
# end
|
|
#
|
|
# end
|
|
# end |