DataWriter

class DataWriter.DataWriter(q)

Bases: multiprocessing.context.Process

Class to be launched as separate process to pull data from queue and write out to .csv dataFrames :param q: queue object from multiprocessing.Manager.queue

Returns

Nil

run()

The process run loop. Gets data from a queue and writes it out to per message csv files :param Nil:

Returns

Nil