Warning
This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.
Source code for galaxy.web.framework.middleware.statsd
"""
Middleware for sending request statistics to statsd.
"""
from __future__ import absolute_import
import time
from galaxy.model.orm.engine_factory import QUERY_COUNT_LOCAL
from galaxy.web.statsd_client import GalaxyStatsdClient
[docs]class StatsdMiddleware(object):
"""
This middleware will log request durations to the configured statsd
instance.
"""
[docs] def __init__(self,
application,
statsd_host,
statsd_port,
statsd_prefix,
statsd_influxdb):
self.application = application
self.galaxy_stasd_client = GalaxyStatsdClient(
statsd_host,
statsd_port,
statsd_prefix,
statsd_influxdb
)
def __call__(self, environ, start_response):
start_time = time.time()
req = self.application(environ, start_response)
dt = int((time.time() - start_time) * 1000)
page = environ.get('controller_action_key', None) or environ.get('PATH_INFO', "NOPATH").strip('/').replace('/', '.')
self.galaxy_stasd_client.timing(page, dt)
try:
times = QUERY_COUNT_LOCAL.times
self.galaxy_stasd_client.timing("sql." + page, sum(times) * 1000.)
self.galaxy_stasd_client.incr("sqlqueries." + page, len(times))
except AttributeError:
# Not logging query counts, skip
pass
return req