Contents

require File.expand_path('../examples_helper', File.dirname(__FILE__))
require Pathname.path_to(:examples, 'dataflow/apache_log_line')

ExampleUniverse.dataflow(:parse_apache_logs) do

  doc 'Parses an apache log line into a structured model, emits it as JSON'

  input  :default, file_source(Pathname.path_to(:data, 'log/sample_apache_log.log'))
  output :dump,    stdout 

  input(:default) >
    map{|line| ApacheLogLine.make(line) or bad_record(line) } >
    to_json >
    output(:dump)
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
wukong-3.0.0.pre	examples/dataflow/parse_apache_logs.rb