zio.flow.hdf.writer Namespace Reference

Classes
class	TensWriter

Functions
def	file_handler (ctx, pipe, filename, wargs)
def	client_handler (ctx, pipe, bot, rule_object, writer_addr, broker_addr)

Variables
	log = logging.getLogger("zio")

Detailed Description

Support for writing HDF5 files.

It provides:

- a Writer class with a mapping policy from TENS message to HDF group

- a file handler actor function

- a data flow client handler actor function

Function Documentation

client_handler()

def zio.flow.hdf.writer.client_handler	(		ctx,
			pipe,
			bot,
			rule_object,
			writer_addr,
			broker_addr
	)

Connect to and marshall messages between broker and writer sockets.

Parameters
----------

bot : zio.Message

    The BOT message

rule_object: dicionary 

    A ruleset rule object.

writer_addr :: string

    The address of the writer's PULL socket to connect.

broker_addr : string

    The address of the broker's SERVER socket to connect.

Definition at line 182 of file writer.py.

file_handler()

def zio.flow.hdf.writer.file_handler	(		ctx,
			pipe,
			filename,
			wargs
	)

An actor that marshals messages from socket to file.

Parameters
-----------

filename : string

    Name of an HDF file in which to write

wargs : tuple of args

wargs[0] : string (address pattern)

    An f-string formatted with a "port" parameter that should
    resolve to a legal ZeroMQ socket address.  When a successful
    bind() can be done on the result, the resolved address is
    returned through the pipe.  If no successful address can be
    bound, an empty string is returned as an error indicator.

Definition at line 107 of file writer.py.

Variable Documentation

log

zio.flow.hdf.writer.log = logging.getLogger("zio")

Definition at line 25 of file writer.py.