From 98e1a0534a30dae28964a5f9aa62082483f53573 Mon Sep 17 00:00:00 2001 From: cal Date: Wed, 14 Aug 2019 15:21:00 +0000 Subject: [PATCH] calibhandler.py: More verbose messaging about kafka server being established gstlal_calibration_aggregator: Making this generic for any IFO --- gstlal-calibration/bin/gstlal_calibration_aggregator | 11 +++++++++-- gstlal-calibration/python/calibhandler.py | 1 + 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/gstlal-calibration/bin/gstlal_calibration_aggregator b/gstlal-calibration/bin/gstlal_calibration_aggregator index a5bf6a352..e38df285e 100755 --- a/gstlal-calibration/bin/gstlal_calibration_aggregator +++ b/gstlal-calibration/bin/gstlal_calibration_aggregator @@ -80,6 +80,10 @@ if __name__ == '__main__': Config = ConfigParser.ConfigParser() Config.read(options.config_file) MonitoringConfigs = ConfigSectionMap("MonitoringConfigurations") + CalibrationConfigs = ConfigSectionMap("CalibrationConfigurations") + OutputConfigs = ConfigSectionMap("OutputConfigurations") + + # Read in monitoring options kafka_server = MonitoringConfigs["kafkaserver"] influx_hostname = MonitoringConfigs["influxhostname"] influx_port = MonitoringConfigs["influxport"] @@ -89,8 +93,11 @@ if __name__ == '__main__': across_jobs = Config.getboolean("MonitoringConfigurations", "acrossjobs") data_type = MonitoringConfigs["datatype"] dump_period = float(MonitoringConfigs["dumpperiod"]) - topics = ['H1_latency', 'H1_statevector_bit_check'] - channel = 'H1_HOFT_TEST' + + # Read in ifo specific options + ifo = CalibrationConfigs["ifo"] + topics = ['%s_latency' % ifo, '%s_statevector_bit_check' % ifo] + channel = OutputConfigs["frametype"] statevector_tags = ['TDCFs_valid', 'monitor_on'] logging.basicConfig(level = logging.INFO, format = "%(asctime)s %(levelname)s:%(processName)s(%(process)d):%(funcName)s: %(message)s") diff --git a/gstlal-calibration/python/calibhandler.py b/gstlal-calibration/python/calibhandler.py index 4daaa187c..1301db1e1 100644 --- a/gstlal-calibration/python/calibhandler.py +++ b/gstlal-calibration/python/calibhandler.py @@ -80,6 +80,7 @@ class Handler(simplehandler.Handler): key_serializer = lambda m: json.dumps(m).encode('utf-8'), value_serializer = lambda m: json.dumps(m).encode('utf-8'), ) + print("Kafka server established.") except errors.NoBrokersAvailable: self.producer = None print("No brokers available for kafka. Defaulting to not pushing to kafka.") -- GitLab