diff --git a/tomograph/__init__.py b/tomograph/__init__.py index 2d1d8d5..63a70c8 100644 --- a/tomograph/__init__.py +++ b/tomograph/__init__.py @@ -27,7 +27,6 @@ def _initLogging(logging, sys): if logger.level == logging.NOTSET: logger.setLevel(logging.INFO) if not logger.handlers: - print "yadda" handler = logging.StreamHandler(sys.stdout) handler.setFormatter(logging.Formatter( '%(asctime)s %(levelname)s %(name)s %(message)s')) diff --git a/tomograph/backends/statsd/statsd.py b/tomograph/backends/statsd/statsd.py index 50bf24b..6b31684 100644 --- a/tomograph/backends/statsd/statsd.py +++ b/tomograph/backends/statsd/statsd.py @@ -29,9 +29,12 @@ def send(span): def statsd_send(name, value, units): stat = str(name).replace(' ', '-') + ':' + str(int(value)) + '|' + str(units) - #logger.info('sending stat {0}'.format(stat)) with lock: - udp_socket.sendto(stat, (hostname_cache.get(config.statsd_host), config.statsd_port)) + try: + udp_socket.sendto(stat, (hostname_cache.get(config.statsd_host), config.statsd_port)) + except Exception: + if config.debug: + logger.warning("Error sending metric to statsd.", exc_info=True) def server_name(note): address = note.address.replace('.', '-') @@ -46,6 +49,4 @@ def send(span): # a count stat for each note for note in span.notes: stat_name = server_name(note) + '.' + span.name + '.' + str(note.value) - #print "before" statsd_send(stat_name, 1, 'c') - #print "after"