module RequestLogAnalyzer::Tracker
# Determines the average hourly spread of the parsed requests.
# This spread is shown in a graph form.
#
# Accepts the following options:
# * :line_type The line type that contains the duration field (determined by the category proc).
# * :if Proc that has to return !nil for a request to be passed to the tracker.
#
# Expects the following items in the update request hash
# * :timestamp in YYYYMMDDHHMMSS format.
#
# Example output:
# Requests graph - average per day per hour
# --------------------------------------------------
# 7:00 - 330 hits : ░░░░░░░
# 8:00 - 704 hits : ░░░░░░░░░░░░░░░░░
# 9:00 - 830 hits : ░░░░░░░░░░░░░░░░░░░░
# 10:00 - 822 hits : ░░░░░░░░░░░░░░░░░░░
# 11:00 - 823 hits : ░░░░░░░░░░░░░░░░░░░
# 12:00 - 729 hits : ░░░░░░░░░░░░░░░░░
# 13:00 - 614 hits : ░░░░░░░░░░░░░░
# 14:00 - 690 hits : ░░░░░░░░░░░░░░░░
# 15:00 - 492 hits : ░░░░░░░░░░░
# 16:00 - 355 hits : ░░░░░░░░
# 17:00 - 213 hits : ░░░░░
# 18:00 - 107 hits : ░░
# ................
class HourlySpread < Base
attr_reader :first, :last, :request_time_graph
def prepare
options[:field] ||= :timestamp
@request_time_graph = [0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]
end
def update(request)
request = request.attributes
timestamp = request[options[:field]]
@request_time_graph[timestamp.to_s[8..9].to_i] +=1
@first = timestamp if @first.nil? || timestamp < @first
@last = timestamp if @last.nil? || timestamp > @last
end
def report(output)
output.title("Requests graph - average per day per hour")
if @request_time_graph == [0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]
output << "None found.\n"
return
end
first_date = DateTime.parse(@first.to_s, '%Y%m%d%H%M%S')
last_date = DateTime.parse(@last.to_s, '%Y%m%d%H%M%S')
days = (@last && @first) ? (last_date - first_date).ceil : 1
total_requests = @request_time_graph.inject(0) { |sum, value| sum + value }
output.table({}, {:align => :right}, {:type => :ratio, :width => :rest, :treshold => 0.15}) do |rows|
@request_time_graph.each_with_index do |requests, index|
ratio = requests.to_f / total_requests.to_f
requests_per_day = requests / days
rows << ["#{index.to_s.rjust(3)}:00", "#{requests_per_day} hits", ratio]
end
end
end
end
end