pswamp.test_utils.runners

Functions

`run_nqkafka_server`(*config_args[, run_in_process])
`create_topics`(*config_args[, n_samples])
`publish_geo_data`(config, data[, kafka_topic])
`publish_model_data`(config[, kafka_topic])
`csv_to_c37118`(config, data[, ip, port])
`c37118_to_kafka`(config[, ip, port, pdc_id, ...])
`csv_to_kafka`(config, data[, speed, t_end, ...])
`csv_to_kafka_2`(config, data_path[, speed, n_samples, ...])
`create_database`(*config_args)
`run_apps`(config)

pswamp.test_utils.runners.run_nqkafka_server(*config_args, run_in_process=True)

pswamp.test_utils.runners.publish_geo_data(config, data, kafka_topic='pmu.coords')

pswamp.test_utils.runners.publish_model_data(config, kafka_topic='model.data')

pswamp.test_utils.runners.csv_to_c37118(config, data, ip=None, port=50000)

pswamp.test_utils.runners.c37118_to_kafka(config, ip=None, port=50000, pdc_id=1410, kafka_topic='pmudata', kafka_topic_meta='pmudata.meta')

pswamp.test_utils.runners.csv_to_kafka(config, data, speed=1, t_end=None, show_playback_control=False)

pswamp.test_utils.runners.csv_to_kafka_2(config, data_path, speed=1, n_samples=None, streamer_class=PMUDataStreamerKafka, show_playback_control=False, **kwargs)