dispel4py.seismo package

Submodules

dispel4py.seismo.obspy_stream module

class dispel4py.seismo.obspy_stream.ObspyStreamPE

Bases: dispel4py.seismo.seismo.SeismoPE

A SeismoPE that calls a function to process an input stream.

compute()

Calls the processing function with the given parameters and one input stream.

getOutputTypes()

setCompute(compute_fn, params={})

Define the compute function that this PE uses for processing input streams, and any input parameters for the function. The function must have at least one input, an obspy stream, and can accept more input parameters that must be provided before the PE is executed.

setInputTypes(types)

dispel4py.seismo.obspy_stream.createProcessingComposite(chain, suffix='', controlParameters={}, provRecorder=None)

Creates a composite PE wrapping a pipeline that processes obspy streams. :param chain: list of functions that process obspy streams. The function takes one input parameter, stream, and returns an output stream. :param requestId: id of the request that the stream is associated with :param controlParameters: environment parameters for the processing elements :rtype: dictionary inputs and outputs of the composite PE that was created

dispel4py.seismo.seismo module

class dispel4py.seismo.seismo.SeismoPE

Bases: dispel4py.provenance.ProvenancePE

INPUT_NAME = 'input'

OUTPUT_DATA = 'output'

extractItemMetadata(st)

getDataStreams(inputs)

initParameters(streams)

writeOutputStreams(outputs)

writeStream(st, attr)

dispel4py.seismo.simple module

class dispel4py.seismo.simple.DataTuple(data=None, metadata=None)

Bases: object

class dispel4py.seismo.simple.SeismoStreamPE(compute_fn, params={})

Bases: dispel4py.base.IterativePE

INPUT_NAME = 'input'

OUTPUT_NAME = 'output'

get_data()

process(inputs)

write_data(data, metadata=None)

dispel4py.seismo.simple.create_pipeline(chain, name_prefix='SeismoStreamPE_', name_suffix='')

Creates a composite PE wrapping a pipeline that processes obspy streams. :param chain: list of functions that process obspy streams. The function takes one input parameter, stream, and returns an output stream. :param requestId: id of the request that the stream is associated with :param controlParameters: environment parameters for the processing elements :rtype: dictionary inputs and outputs of the composite PE that was created

Module contents