pswamp.utils.pmu_time_window

Classes

`PMUDecoder`
`PMUTimeWindow`
`PMUTimeWindowOnline`	This class is intended for consuming PMU data from a specified Kafka topic and storing the last samples (n_samples) in a

Module Contents

class pswamp.utils.pmu_time_window.PMUDecoder(channel_selection=None, channel_selection_idx=None, substitute_zero_freq_with_nan=True)

channel_selection = None

channel_selection_idx

substitute_zero_freq_with_nan = True

data_dtype

get_time_stamp(data_frame)

get_data_rate(sample_data_frame)

generate_header(sample_data_frame=None, config_frame=None)

data_frame_to_row(pmu_data_frame)

class pswamp.utils.pmu_time_window.PMUTimeWindow(n_samples=None, window_length=None, time_window_type=TimeWindowLabeled, substitute_zero_freq_with_nan=True, channel_selection=None, channel_selection_idx=None)

time_window_type

tw = None

header = None

n_samples = None

window_length = None

is_initialized = False

n_channels = None

dt

fs

pmu_decoder

initialize_from_config_frame(config_frame)

update_window(pmu_data_frame)

class pswamp.utils.pmu_time_window.PMUTimeWindowOnline(kafka_kwargs={}, kafka_topic='pmudata', auto_adjust_offset=False, **kwargs)

Bases: PMUTimeWindow

This class is intended for consuming PMU data from a specified Kafka topic and storing the last samples (n_samples) in a TimeWindow object.

kafka_topic = 'pmudata'

kafka_kwargs

auto_adjust_offset = False

pmu_stream

_is_stopped = False

initialize()

run()

stop()