From 40e13bcbf0a6d572656f96c22ed47f387dfba51e Mon Sep 17 00:00:00 2001 From: Rick Elrod Date: Tue, 4 Feb 2020 22:11:06 +0000 Subject: [PATCH] python3-ize the fedmsg check scripts, and on py3 boxes make it check a valid socket path Signed-off-by: Rick Elrod --- .../scripts/check_fedmsg_consumer_backlog.py | 22 +++++++++---------- .../check_fedmsg_consumer_exceptions.py | 20 ++++++++--------- .../scripts/check_fedmsg_producer_last_ran.py | 20 ++++++++--------- .../check_fedmsg_producers_consumers.py | 22 +++++++++---------- .../templates/check_fedmsg_consumers.cfg.j2 | 12 ++++++++++ .../plugins/check_fedmsg_consumer_backlog.py | 20 ++++++++--------- .../check_fedmsg_consumer_exceptions.py | 18 +++++++-------- .../check_fedmsg_producers_consumers.py | 20 ++++++++--------- 8 files changed, 83 insertions(+), 71 deletions(-) diff --git a/roles/nagios_client/files/scripts/check_fedmsg_consumer_backlog.py b/roles/nagios_client/files/scripts/check_fedmsg_consumer_backlog.py index 09b70aedda..22afced9e1 100644 --- a/roles/nagios_client/files/scripts/check_fedmsg_consumer_backlog.py +++ b/roles/nagios_client/files/scripts/check_fedmsg_consumer_backlog.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -14,18 +14,18 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) if not os.access(fname, os.W_OK): - print "UNKNOWN - cannot write to %s" % fname + print("UNKNOWN - cannot write to %s" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -37,26 +37,26 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] == check_consumer: if consumer['backlog'] is None: - print 'ERROR: fedmsg consumer %s is not initialized' % consumer['name'] + print('ERROR: fedmsg consumer %s is not initialized' % consumer['name']) sys.exit(3) elif consumer['backlog'] > backlog_critical: - print 'CRITICAL: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('CRITICAL: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(2) elif consumer['backlog'] > backlog_warning: - print 'WARNING: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('WARNING: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(1) else: - print 'OK: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('OK: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(0) - print "UNKNOWN: fedmsg consumer %s not found" % check_consumer + print("UNKNOWN: fedmsg consumer %s not found" % check_consumer) sys.exit(3) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_client/files/scripts/check_fedmsg_consumer_exceptions.py b/roles/nagios_client/files/scripts/check_fedmsg_consumer_exceptions.py index c710d02c36..afed1af5f2 100644 --- a/roles/nagios_client/files/scripts/check_fedmsg_consumer_exceptions.py +++ b/roles/nagios_client/files/scripts/check_fedmsg_consumer_exceptions.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -14,18 +14,18 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) if not os.access(fname, os.W_OK): - print "UNKNOWN - cannot write to %s" % fname + print("UNKNOWN - cannot write to %s" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -36,23 +36,23 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] == check_consumer: if consumer['exceptions'] > exceptions_critical: - print 'CRITICAL: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('CRITICAL: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(2) elif consumer['exceptions'] > exceptions_warning: - print 'WARNING: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('WARNING: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(1) else: - print 'OK: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('OK: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(0) - print "UNKNOWN: fedmsg consumers %s not found" % check_consumer + print("UNKNOWN: fedmsg consumers %s not found" % check_consumer) sys.exit(3) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_client/files/scripts/check_fedmsg_producer_last_ran.py b/roles/nagios_client/files/scripts/check_fedmsg_producer_last_ran.py index 49fbd34337..7ac57bf2de 100644 --- a/roles/nagios_client/files/scripts/check_fedmsg_producer_last_ran.py +++ b/roles/nagios_client/files/scripts/check_fedmsg_producer_last_ran.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import arrow import json @@ -16,18 +16,18 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) if not os.access(fname, os.W_OK): - print "UNKNOWN - cannot write to %s" % fname + print("UNKNOWN - cannot write to %s" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -39,7 +39,7 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) now = time.time() @@ -50,20 +50,20 @@ try: diff = now - prod['last_ran'] then = arrow.get(prod['last_ran']).humanize() if diff > elapsed_critical: - print "CRITICAL: %s last ran %s (%i seconds ago)" % ( + print("CRITICAL: %s last ran %s (%i seconds ago)" % () check_producer, then, diff) sys.exit(2) elif diff > elapsed_warning: - print "WARNING: %s last ran %s (%i seconds ago)" % ( + print("WARNING: %s last ran %s (%i seconds ago)" % () check_producer, then, diff) sys.exit(1) else: - print "OK: %s last ran %s (%i seconds ago)" % ( + print("OK: %s last ran %s (%i seconds ago)" % () check_producer, then, diff) sys.exit(0) - print "UNKNOWN: fedmsg producer %s not found" % check_producer + print("UNKNOWN: fedmsg producer %s not found" % check_producer) sys.exit(3) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_client/files/scripts/check_fedmsg_producers_consumers.py b/roles/nagios_client/files/scripts/check_fedmsg_producers_consumers.py index bce153e26e..c3bc307ac5 100644 --- a/roles/nagios_client/files/scripts/check_fedmsg_producers_consumers.py +++ b/roles/nagios_client/files/scripts/check_fedmsg_producers_consumers.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -12,22 +12,22 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not check_list: - print "UNKNOWN - empty list of fedmsg consumers and producers to check" + print("UNKNOWN - empty list of fedmsg consumers and producers to check") sys.exit(3) if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) if not os.access(fname, os.W_OK): - print "UNKNOWN - cannot write to %s" % fname + print("UNKNOWN - cannot write to %s" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -38,27 +38,27 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] in check_list and not consumer['initialized']: - print 'ERROR: fedmsg consumer %s is not initialized' % consumer['name'] + print('ERROR: fedmsg consumer %s is not initialized' % consumer['name']) sys.exit(2) for producer in msg['producers']: if producer['name'] in check_list and not producer['initialized']: - print 'ERROR: fedmsg producer %s is not initialized' % producer['name'] + print('ERROR: fedmsg producer %s is not initialized' % producer['name']) sys.exit(2) for item in check_list: if item not in [p['name'] for p in msg['producers'] + msg['consumers']]: - print 'ERROR: %s not found among installed plugins' % item + print('ERROR: %s not found among installed plugins' % item) sys.exit(2) - print "OK: fedmsg consumer(s) and producer(s) initialized" + print("OK: fedmsg consumer(s) and producer(s) initialized") sys.exit(0) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_client/templates/check_fedmsg_consumers.cfg.j2 b/roles/nagios_client/templates/check_fedmsg_consumers.cfg.j2 index 2f31ae0e7e..4160a8ab5a 100644 --- a/roles/nagios_client/templates/check_fedmsg_consumers.cfg.j2 +++ b/roles/nagios_client/templates/check_fedmsg_consumers.cfg.j2 @@ -1,7 +1,11 @@ # Fedmsg checks for consumers and producers command[check_fedmsg_cp_busgateway_hub]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-hub Nommer MonitoringProducer command[check_fedmsg_cp_busgateway_relay]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-relay RelayConsumer MonitoringProducer +{% if (ansible_distribution == 'RedHat' and ansible_distribution_major_version|int < 8) or (ansible_distribution_major_version|int < 30 and ansible_distribution == 'Fedora') %} command[check_fedmsg_cp_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-gateway GatewayConsumer MonitoringProducer +{% else %} +command[check_fedmsg_cp_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-gateway- GatewayConsumer MonitoringProducer +{% endif %} command[check_fedmsg_cp_anitya_relay]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-relay RelayConsumer MonitoringProducer command[check_fedmsg_cp_app]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-relay RelayConsumer MonitoringProducer command[check_fedmsg_cp_value]={{libdir}}/nagios/plugins/check_fedmsg_producers_consumers.py fedmsg-irc IRCBotConsumer MonitoringProducer @@ -16,7 +20,11 @@ command[check_fedmsg_cp_mbs_backend]={{libdir}}/nagios/plugins/check_fedmsg_prod command[check_fedmsg_cexceptions_busgateway_hub]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-hub Nommer 1 10 command[check_fedmsg_cexceptions_busgateway_relay]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-relay RelayConsumer 1 10 +{% if (ansible_distribution == 'RedHat' and ansible_distribution_major_version|int < 8) or (ansible_distribution_major_version|int < 30 and ansible_distribution == 'Fedora') %} command[check_fedmsg_cexceptions_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-gateway GatewayConsumer 1 10 +{% else %} +command[check_fedmsg_cexceptions_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-gateway- GatewayConsumer 1 10 +{% endif %} command[check_fedmsg_cexceptions_anitya_relay]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-relay RelayConsumer 1 10 command[check_fedmsg_cexceptions_app]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-relay RelayConsumer 1 10 command[check_fedmsg_cexceptions_value]={{libdir}}/nagios/plugins/check_fedmsg_consumer_exceptions.py fedmsg-irc IRCBotConsumer 1 10 @@ -31,7 +39,11 @@ command[check_fedmsg_cexceptions_mbs_backend]={{libdir}}/nagios/plugins/check_fe command[check_fedmsg_cbacklog_busgateway_hub]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-hub Nommer 500 1000 command[check_fedmsg_cbacklog_busgateway_relay]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-relay RelayConsumer 10 50 +{% if (ansible_distribution == 'RedHat' and ansible_distribution_major_version|int < 8) or (ansible_distribution_major_version|int < 30 and ansible_distribution == 'Fedora') %} command[check_fedmsg_cbacklog_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-gateway GatewayConsumer 10 50 +{% else %} +command[check_fedmsg_cbacklog_busgateway_gateway]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-gateway- GatewayConsumer 10 50 +{% endif %} command[check_fedmsg_cbacklog_anitya_relay]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-relay RelayConsumer 10 50 command[check_fedmsg_cbacklog_app]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-relay RelayConsumer 10 50 command[check_fedmsg_cbacklog_value]={{libdir}}/nagios/plugins/check_fedmsg_consumer_backlog.py fedmsg-irc IRCBotConsumer 10 50 diff --git a/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_backlog.py b/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_backlog.py index 4e78bdf656..2ac43b5ee9 100644 --- a/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_backlog.py +++ b/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_backlog.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -14,14 +14,14 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -33,26 +33,26 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] == check_consumer: if consumer['backlog'] is None: - print 'ERROR: fedmsg consumer %s is not initialized' % consumer['name'] + print('ERROR: fedmsg consumer %s is not initialized' % consumer['name']) sys.exit(3) elif consumer['backlog'] > backlog_critical: - print 'CRITICAL: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('CRITICAL: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(2) elif consumer['backlog'] > backlog_warning: - print 'WARNING: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('WARNING: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(1) else: - print 'OK: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog']) + print('OK: fedmsg consumer %s backlog value is %i' % (consumer['name'],consumer['backlog'])) sys.exit(0) - print "UNKNOWN: fedmsg consumer %s not found" % check_consumer + print("UNKNOWN: fedmsg consumer %s not found" % check_consumer) sys.exit(3) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_exceptions.py b/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_exceptions.py index 258e6ed0fb..55870d99aa 100644 --- a/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_exceptions.py +++ b/roles/nagios_server/files/nagios/plugins/check_fedmsg_consumer_exceptions.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -14,14 +14,14 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -32,23 +32,23 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] == check_consumer: if consumer['exceptions'] > exceptions_critical: - print 'CRITICAL: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('CRITICAL: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(2) elif consumer['exceptions'] > exceptions_warning: - print 'WARNING: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('WARNING: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(1) else: - print 'OK: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions']) + print('OK: fedmsg consumer %s exceptions value is %i' % (consumer['name'],consumer['exceptions'])) sys.exit(0) - print "UNKNOWN: fedmsg consumers %s not found" % check_consumer + print("UNKNOWN: fedmsg consumers %s not found" % check_consumer) sys.exit(3) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3) diff --git a/roles/nagios_server/files/nagios/plugins/check_fedmsg_producers_consumers.py b/roles/nagios_server/files/nagios/plugins/check_fedmsg_producers_consumers.py index e0f0359ac8..412c168091 100644 --- a/roles/nagios_server/files/nagios/plugins/check_fedmsg_producers_consumers.py +++ b/roles/nagios_server/files/nagios/plugins/check_fedmsg_producers_consumers.py @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python import json import os @@ -12,18 +12,18 @@ try: fname = '/var/run/fedmsg/monitoring-%s.socket' % service if not check_list: - print "UNKNOWN - empty list of fedmsg consumers and producers to check" + print("UNKNOWN - empty list of fedmsg consumers and producers to check") sys.exit(3) if not os.path.exists(fname): - print "UNKNOWN - %s does not exist" % fname + print("UNKNOWN - %s does not exist" % fname) sys.exit(3) connect_to = "ipc:///%s" % fname ctx = zmq.Context() s = ctx.socket(zmq.SUB) s.connect(connect_to) - s.setsockopt(zmq.SUBSCRIBE, '') + s.setsockopt_string(zmq.SUBSCRIBE, '') poller = zmq.Poller() poller.register(s, zmq.POLLIN) @@ -34,27 +34,27 @@ try: msg = s.recv() msg = json.loads(msg) else: - print 'UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout + print('UNKNOWN - ZMQ timeout. No message received in %i ms' % timeout) sys.exit(3) for consumer in msg['consumers']: if consumer['name'] in check_list and not consumer['initialized']: - print 'ERROR: fedmsg consumer %s is not initialized' % consumer['name'] + print('ERROR: fedmsg consumer %s is not initialized' % consumer['name']) sys.exit(2) for producer in msg['producers']: if producer['name'] in check_list and not producer['initialized']: - print 'ERROR: fedmsg producer %s is not initialized' % producer['name'] + print('ERROR: fedmsg producer %s is not initialized' % producer['name']) sys.exit(2) for item in check_list: if item not in [p['name'] for p in msg['producers'] + msg['consumers']]: - print 'ERROR: %s not found among installed plugins' % item + print('ERROR: %s not found among installed plugins' % item) sys.exit(2) - print "OK: fedmsg consumer(s) and producer(s) initialized" + print("OK: fedmsg consumer(s) and producer(s) initialized") sys.exit(0) except Exception as err: - print "UNKNOWN:", str(err) + print("UNKNOWN:", str(err)) sys.exit(3)