module LogStats::LineParser

Public Class Methods

parse(log_data, config) click to toggle source
# File lib/log_stats/line_parser.rb, line 3
def self.parse(log_data, config)
  data = {}
  lines = (log_data.is_a?(String) ? log_data.split("\n") : log_data)
  lines.each do |line_string|
    config[:events].each do |event, event_config|
      if event_config[:line_pattern] =~ line_string
        data[event] ||= []
        data[event].push(parse_line(line_string, event_config))
      end
    end
  end
  data
end
parse_field(field, line_string, event_config) click to toggle source
# File lib/log_stats/line_parser.rb, line 29
def self.parse_field(field, line_string, event_config)
  if field[:parse]
    value = field[:parse].call(line_string)
  else
    value = /\b#{field[:name]}=(\S+)/.match(line_string).to_a[1]
    value = strip_quotes(value)
    value = parse_numeric(value) if field[:numeric]
  end
  puts "Parsing failed field=#{field} line=#{line_string}" unless (value || field[:optional])
  value
rescue Exception => e
  puts "Parsing failed field=#{field} line=#{line_string}: #{e.message}"
  nil
end
parse_line(line_string, event_config) click to toggle source
# File lib/log_stats/line_parser.rb, line 44
def self.parse_line(line_string, event_config)
  event_config[:fields].reduce({}) do |acc, field|
    if value = parse_field(field, line_string, event_config)
      acc[field[:name]] = value
    end
    acc
  end
end
parse_numeric(value) click to toggle source
# File lib/log_stats/line_parser.rb, line 25
def self.parse_numeric(value)
  value[/\d+/].to_i
end
strip_quotes(value) click to toggle source
# File lib/log_stats/line_parser.rb, line 17
def self.strip_quotes(value)
  if value && value.start_with?('"')
    value[1..-2]
  else
    value
  end
end