FluentD Parse configs

fluentd.rb

<match row.busylogbox.**>
  @type record_reformer
  tag busylogbox.${tag_suffix[2]}
  renew_record false
  enable_ruby true
  <record>
    request_time ${record['log'].scan(/(?<param>^[^ ]+ [^ ]+)/).flatten.compact[0]}
    request_id ${record['log'].scan(/(?<param>[^ ]+) OS/).flatten.compact[0]}
    os ${record['log'].scan(/OS=(?<param>[^ ]+)/).flatten.compact[0]}
    architecture ${record['log'].scan(/AR=(?<param>[^ ]+)/).flatten.compact[0]}
    cpu ${record['log'].scan(/CPU=\((?<param>[^ ]+)\)/).flatten.compact[0]}
    usr ${record['log'].scan(/USR=(?<param>[^ ]+)/).flatten.compact[0]}
    nice ${record['log'].scan(/NICE=(?<param>[^ ]+)/).flatten.compact[0]}
    sys ${record['log'].scan(/SYS=(?<param>[^ ]+)/).flatten.compact[0]}
    iowait ${record['log'].scan(/IOWAIT=(?<param>[^ ]+)/).flatten.compact[0]}
    irq ${record['log'].scan(/IRQ=(?<param>[^ ]+)/).flatten.compact[0]}
    soft ${record['log'].scan(/SOFT=(?<param>[^ ]+)/).flatten.compact[0]}
    soft ${record['log'].scan(/STEAL=(?<param>[^ ]+)/).flatten.compact[0]}
    soft ${record['log'].scan(/GUEST=(?<param>[^ ]+)/).flatten.compact[0]}
    soft ${record['log'].scan(/IDLE=(?<param>[^ ]+)/).flatten.compact[0]}
    message ${record['log'].to_s.strip}
    log ''
  </record>
</match>