pewpew.csv package

Submodules

pewpew.csv.reader module

class pewpew.csv.reader.Reader(exit_flag=None, inqueue=None, outqueue=None, **kwargs)[source]

Bases: pewpew.base.StreamElement

converters = []
log = <Logger pewpew.csv.reader (WARNING)>
on_start()[source]

Override this method to perform an action at the process’ beginning of execution.

process(data=None)[source]

Abstract method. Implement this for the primary action this process will take on data

data: list or dict or None

Input data to be acted on. Primary data generators can accept None as an input, and produce data.

dict or list:

Data to be processed downstream.

pewpew.csv.writer module

class pewpew.csv.writer.Writer(exit_flag=None, inqueue=None, outqueue=None, **kwargs)[source]

Bases: pewpew.base.StreamElement

property filename
log = <Logger pewpew.csv.writer (WARNING)>
on_completion()[source]

Override this method to perform an action at the process’ end of execution.

on_start()[source]

Override this method to perform an action at the process’ beginning of execution.

property path
process(data)[source]

Abstract method. Implement this for the primary action this process will take on data

data: list or dict or None

Input data to be acted on. Primary data generators can accept None as an input, and produce data.

dict or list:

Data to be processed downstream.

Module contents

Specific implementation written for HDF5 reading and writing with pewpew.