Contents

module Fluent
  module Plugin
    class RegexpParser < Parser
      include Fluent::Compat::TypeConverter

      Plugin.register_parser("regexp", self)

      config_param :expression, :string, default: ""
      config_param :ignorecase, :bool, default: false
      config_param :multiline, :bool, default: false
      config_param :time_key, :string, default: 'time'

      def initialize
        super
        @mutex = Mutex.new
      end

      def configure(conf)
        super
        @time_parser = time_parser_create
        unless @expression.empty?
          if @expression[0] == "/" && @expression[-1] == "/"
            regexp_option = 0
            regexp_option |= Regexp::IGNORECASE if @ignorecase
            regexp_option |= Regexp::MULTILINE if @multiline
            @regexp = Regexp.new(@expression[1..-2], regexp_option)
          else
            raise Fluent::ConfigError, "expression must start with `/` and end with `/`: #{@expression}"
          end
        end
      end

      def parse(text)
        m = @regexp.match(text)
        unless m
          yield nil, nil
          return
        end

        time = nil
        record = {}

        m.names.each do |name|
          if value = m[name]
            if name == @time_key
              time = @mutex.synchronize { @time_parser.parse(value) }
              if @keep_time_key
                record[name] = if @type_converters.nil?
                                 value
                               else
                                 convert_type(name, value)
                               end
              end
            else
              record[name] = if @type_converters.nil?
                               value
                             else
                               convert_type(name, value)
                             end
            end
          end
        end

        if @estimate_current_event
          time ||= Fluent::EventTime.now
        end

        yield time, record
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
fluentd-0.14.8	lib/fluent/plugin/parser_regexp.rb
fluentd-0.14.7-x64-mingw32	lib/fluent/plugin/parser_regexp.rb
fluentd-0.14.7-x86-mingw32	lib/fluent/plugin/parser_regexp.rb
fluentd-0.14.7	lib/fluent/plugin/parser_regexp.rb