Sha256: a8d81531e8679c76f3c25c066fe9efdec8b5c2153ac62cac165476ea2ca6d2da
Contents?: true
Size: 1.45 KB
Versions: 16
Compression:
Stored size: 1.45 KB
Contents
module RequestLogAnalyzer::FileFormat
# The DelayedJob21 file format parsed log files that are created by DelayedJob 2.1 or higher.
# By default, the log file can be found in RAILS_ROOT/log/delayed_job.log
class DelayedJob21 < Base
extend CommonRegularExpressions
line_definition :job_lock do |line|
line.header = true
line.regexp = /(#{timestamp('%Y-%m-%dT%H:%M:%S%z')}): \[Worker\(\S+ host:(#{hostname_or_ip_address}) pid:(\d+)\)\] acquired lock on (\S+)/
line.capture(:timestamp).as(:timestamp)
line.capture(:host)
line.capture(:pid).as(:integer)
line.capture(:job)
end
line_definition :job_completed do |line|
line.footer = true
line.regexp = /(#{timestamp('%Y-%m-%dT%H:%M:%S%z')}): \[Worker\(\S+ host:(#{hostname_or_ip_address}) pid:(\d+)\)\] (\S+) completed after (\d+\.\d+)/
line.capture(:timestamp).as(:timestamp)
line.capture(:host)
line.capture(:pid).as(:integer)
line.capture(:job)
line.capture(:duration).as(:duration, :unit => :sec)
end
report do |analyze|
analyze.timespan
analyze.hourly_spread
analyze.frequency :job, :line_type => :job_completed, :title => "Completed jobs"
#analyze.frequency :job, :if => lambda { |request| request[:attempts] == 1 }, :title => "Failed jobs"
analyze.duration :duration, :category => :job, :line_type => :job_completed, :title => "Job duration"
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems