pswamp.test_utils.pmu_csv_to_kafka

Classes

CSVtoKafka

Module Contents

class pswamp.test_utils.pmu_csv_to_kafka.CSVtoKafka(kafka_kwargs, *args, topic='pmudata', freq_data=None, dfreq_data=None, speed=1, t_end=None, **kwargs)

Bases: synchrophasor.timeSeriesPlayback.PMUTimeSeriesPublisher

t_end

speed = 1

topic = 'pmudata'

kafka_producer

freq_data

dfreq_data

initialize()

main_loop()