timeflux.nodes.hdf5


timeflux.nodes.hdf5: HDF5 nodes

hdf5

class timeflux.nodes.hdf5.Replay(filename, keys, speed=1, timespan=None, resync=True, start=0)[source]

Bases: timeflux.core.node.Node

Replay a HDF5 file.

Initialize.

Parameters:
  • filename (string) – The path to the HDF5 file.

  • keys (list) – The list of keys to replay.

  • speed (float) – The speed at which the data must be replayed. 1 means real-time. Default: 1

  • timespan (float) – The timespan of each chunk, in seconds. If not None, will take precedence over the speed parameter Default: None

  • resync (boolean) – If False, timestamps will not be resync’ed to current time Default: True

  • start (float) – Start directly at the given time offset, in seconds Default: 0

update()[source]

Update the input and output ports.

terminate()[source]

Perform cleanup upon termination.

class timeflux.nodes.hdf5.Save(filename=None, path='/tmp', complib='zlib', complevel=3, min_itemsize=None)[source]

Bases: timeflux.core.node.Node

Save to HDF5.

Initialize.

Parameters:
update()[source]

Update the input and output ports.

terminate()[source]

Perform cleanup upon termination.