Contents

require 'tempfile'
require 'csv'

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

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

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rodimus-1.0.0	examples/rails_log/file_output.rb