pswamp.monitoring.islanding

Attributes

config

Classes

IslandingApp

General time window application template.

Functions

moving_average(x, w)

detect_islands(t, data[, mean_threshold])

run_islanding_application(config, **kwargs)

Module Contents

pswamp.monitoring.islanding.moving_average(x, w)
pswamp.monitoring.islanding.detect_islands(t, data, mean_threshold=0.05)
class pswamp.monitoring.islanding.IslandingApp(*args, eval_freq=1, window_length=10, **kwargs)

Bases: pswamp.app_templates.time_window_app.TimeWindowApp

General time window application template.

New applications could be defined by inheriting from this template, and defining the “run_analysis” method. Similar to SnapshotApp, but has an internal time window storage. The length of the time window is determined by either of the arguments n_samples or window_length. If neither are specified, the size of the time window will grow indefinitely.

TODO: Remove channel_selection and channel_selection_idx from arguments.

Parameters:

  • io – Input/output object (normally connects to Kafka)

  • eval_freq – How often the evaluation of the application should be run (e.g., the part in “run_analysis”)

  • t_end – The application will stop running when this time is reached (but can be restarted)

  • t_start – The application will ask the io object (first argument) to search for t_start when initializing.

  • app_name – Name for the application.

  • input_decoder – This determines how the input is read/decoded (if no decoder is specified, a decoder for PMU data frames will be used.)

  • decoder_kwargs – Kwargs for initalizing the “input_decoder”.

  • channel_selection – Argument for specifying channel subset.

  • channel_selection_idx – Argument for specifying channel subset.

  • n_samples – Determines the window length in samples.

  • window_length – Determines the window length in seconds.

  • report_status – If enabled, status messages will be emitted.

  • io_kwargs – Any other kwargs will be forwarded to the io object.

alarm_handler
init(mean_threshold=0.05)
run_analysis(t, data)
set_status(return_value)
pswamp.monitoring.islanding.run_islanding_application(config, **kwargs)
pswamp.monitoring.islanding.config