##// END OF EJS Templates
metrics: reduce cardinality on view names
super-admin -
r4810:4c813ee9 default
parent child Browse files
Show More
@@ -1,90 +1,90 b''
1 # -*- coding: utf-8 -*-
1 # -*- coding: utf-8 -*-
2
2
3 # Copyright (C) 2016-2020 RhodeCode GmbH
3 # Copyright (C) 2016-2020 RhodeCode GmbH
4 #
4 #
5 # This program is free software: you can redistribute it and/or modify
5 # This program is free software: you can redistribute it and/or modify
6 # it under the terms of the GNU Affero General Public License, version 3
6 # it under the terms of the GNU Affero General Public License, version 3
7 # (only), as published by the Free Software Foundation.
7 # (only), as published by the Free Software Foundation.
8 #
8 #
9 # This program is distributed in the hope that it will be useful,
9 # This program is distributed in the hope that it will be useful,
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 # GNU General Public License for more details.
12 # GNU General Public License for more details.
13 #
13 #
14 # You should have received a copy of the GNU Affero General Public License
14 # You should have received a copy of the GNU Affero General Public License
15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
16 #
16 #
17 # This program is dual-licensed. If you wish to learn more about the
17 # This program is dual-licensed. If you wish to learn more about the
18 # RhodeCode Enterprise Edition, including its added features, Support services,
18 # RhodeCode Enterprise Edition, including its added features, Support services,
19 # and proprietary license terms, please see https://rhodecode.com/licenses/
19 # and proprietary license terms, please see https://rhodecode.com/licenses/
20
20
21 import time
21 import time
22 import logging
22 import logging
23
23
24 import rhodecode
24 import rhodecode
25 from rhodecode.lib.auth import AuthUser
25 from rhodecode.lib.auth import AuthUser
26 from rhodecode.lib.base import get_ip_addr, get_access_path, get_user_agent
26 from rhodecode.lib.base import get_ip_addr, get_access_path, get_user_agent
27 from rhodecode.lib.utils2 import safe_str, get_current_rhodecode_user
27 from rhodecode.lib.utils2 import safe_str, get_current_rhodecode_user
28
28
29
29
30 log = logging.getLogger(__name__)
30 log = logging.getLogger(__name__)
31
31
32
32
33 class RequestWrapperTween(object):
33 class RequestWrapperTween(object):
34 def __init__(self, handler, registry):
34 def __init__(self, handler, registry):
35 self.handler = handler
35 self.handler = handler
36 self.registry = registry
36 self.registry = registry
37
37
38 # one-time configuration code goes here
38 # one-time configuration code goes here
39
39
40 def _get_user_info(self, request):
40 def _get_user_info(self, request):
41 user = get_current_rhodecode_user(request)
41 user = get_current_rhodecode_user(request)
42 if not user:
42 if not user:
43 user = AuthUser.repr_user(ip=get_ip_addr(request.environ))
43 user = AuthUser.repr_user(ip=get_ip_addr(request.environ))
44 return user
44 return user
45
45
46 def __call__(self, request):
46 def __call__(self, request):
47 start = time.time()
47 start = time.time()
48 log.debug('Starting request time measurement')
48 log.debug('Starting request time measurement')
49 response = None
49 response = None
50 try:
50 try:
51 response = self.handler(request)
51 response = self.handler(request)
52 finally:
52 finally:
53 count = request.request_count()
53 count = request.request_count()
54 _ver_ = rhodecode.__version__
54 _ver_ = rhodecode.__version__
55 _path = safe_str(get_access_path(request.environ))
55 _path = safe_str(get_access_path(request.environ))
56 _auth_user = self._get_user_info(request)
56 _auth_user = self._get_user_info(request)
57
57
58 total = time.time() - start
58 total = time.time() - start
59 log.info(
59 log.info(
60 'Req[%4s] %s %s Request to %s time: %.4fs [%s], RhodeCode %s',
60 'Req[%4s] %s %s Request to %s time: %.4fs [%s], RhodeCode %s',
61 count, _auth_user, request.environ.get('REQUEST_METHOD'),
61 count, _auth_user, request.environ.get('REQUEST_METHOD'),
62 _path, total, get_user_agent(request. environ), _ver_
62 _path, total, get_user_agent(request. environ), _ver_
63 )
63 )
64
64
65 statsd = request.registry.statsd
65 statsd = request.registry.statsd
66 if statsd:
66 if statsd:
67 match_route = request.matched_route.name if request.matched_route else _path
67 match_route = request.matched_route.name if request.matched_route else "NOT_FOUND"
68 resp_code = getattr(response, 'status_code', 'UNDEFINED')
68 resp_code = getattr(response, 'status_code', 'UNDEFINED')
69 elapsed_time_ms = round(1000.0 * total) # use ms only
69 elapsed_time_ms = round(1000.0 * total) # use ms only
70 statsd.timing(
70 statsd.timing(
71 "rhodecode_req_timing.histogram", elapsed_time_ms,
71 "rhodecode_req_timing.histogram", elapsed_time_ms,
72 tags=[
72 tags=[
73 "view_name:{}".format(match_route),
73 "view_name:{}".format(match_route),
74 "code:{}".format(resp_code)
74 "code:{}".format(resp_code)
75 ],
75 ],
76 use_decimals=False
76 use_decimals=False
77 )
77 )
78 statsd.incr(
78 statsd.incr(
79 'rhodecode_req_total', tags=[
79 'rhodecode_req_total', tags=[
80 "view_name:{}".format(match_route),
80 "view_name:{}".format(match_route),
81 "code:{}".format(resp_code)
81 "code:{}".format(resp_code)
82 ])
82 ])
83
83
84 return response
84 return response
85
85
86
86
87 def includeme(config):
87 def includeme(config):
88 config.add_tween(
88 config.add_tween(
89 'rhodecode.lib.middleware.request_wrapper.RequestWrapperTween',
89 'rhodecode.lib.middleware.request_wrapper.RequestWrapperTween',
90 )
90 )
General Comments 0
You need to be logged in to leave comments. Login now