pswamp.coordination.pmu_to_kafka

Classes

This class receives PMU data (using PyPMU) and forwards the full dataframes to a specified Kafka topic.

Module Contents

class pswamp.coordination.pmu_to_kafka.PMUToKafka(pdc_id, pmu_ip, pmu_port, kafka_kwargs, kafka_topic='pmudata')

This class receives PMU data (using PyPMU) and forwards the full dataframes to a specified Kafka topic.

pdc

subscribers = []

header = None

config = None

_stopped = False

kafka_topic = 'pmudata'

kafka_producer

connect_to_pmu(): Connect to the PDC, and receive header- and configuration frames. Does not start stream of data. :returns: None

run(): Ask PDC to start sending data and start receiving and forwarding data.