Contents

require 'tempfile'
require 'csv'

class FileOutput < Rodimus::Step
  def before_run_set_output
    @outgoing = CSV.open('/tmp/connection_logging.csv', 'w')
  end

  def after_run_log_path
    puts "\nData written to #{outgoing.path}\n\n"
  end

  def process_row(row)
    JSON.parse(row).values
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rodimus-1.3.1	examples/rails_log/file_output.rb
rodimus-1.3.0	examples/rails_log/file_output.rb
rodimus-1.2.0	examples/rails_log/file_output.rb
rodimus-1.1.0	examples/rails_log/file_output.rb