pewpew.csv package

Submodules

pewpew.csv.reader module

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

Bases: pewpew.base.StreamElement

converters = []

log = <Logger pewpew.csv.reader (WARNING)>

on_start()

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

process(data=None)

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)

Bases: pewpew.base.StreamElement

property filename

log = <Logger pewpew.csv.writer (WARNING)>

on_completion()

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

on_start()

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

property path

process(data)

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.