pswamp.monitoring.utils

Classes

`TimeWindowRTApp`	Generic real-time application, which does nothing, except stores a time window with PMU data of specified length.
`StatusCom`

Module Contents

class pswamp.monitoring.utils.TimeWindowRTApp(kafka_kwargs, time_window_length=None, n_samples_window=None, input_topic='pmudata', output_topic=None, input_meta_topic=None, output_meta_topic=None, phasor_selection=None, channel_selection=None, channel_selection_idx=None, eval_freq=None, auto_adjust_offset=False, t_end=np.inf)

Generic real-time application, which does nothing, except stores a time window with PMU data of specified length. The run_analysis method should be overwritten in order to perform various analysis. Results can be forwarded to another topic automatically.

t_end

eval_freq = None

app_name = 'TimeWindowRTApp'

pmu_tw

kafka_server

output_topic = None

_stopped = False

output_metadata()

send_output_metadata()

stop()

Returns:: None

run_analysis(t, phasors): This should be overwritten. :param t: :param phasors: :return:

run()

class pswamp.monitoring.utils.StatusCom(kafka_kwargs, status_topic='application.status')

status_topic = 'application.status'

producer

uuid

app_name = 'StatusCom'

status_update_thread

status = 'Undefined'

update_status()