1
1
import time
2
2
3
3
from django .utils .deprecation import MiddlewareMixin
4
- # from monitoring.statsd.metrics import statsd, REQUEST_COUNT_METRIC_NAME, REQUEST_LATENCY_METRIC_NAME
4
+ from monitoring .statsd .metrics import statsd , REQUEST_COUNT_METRIC_NAME , REQUEST_LATENCY_METRIC_NAME
5
5
6
6
7
7
class StatsdMetricsMiddleware (MiddlewareMixin ):
@@ -17,26 +17,24 @@ def get_view_name(self, request):
17
17
return view_name
18
18
19
19
def process_response (self , request , response ):
20
- # TODO: Enable statsd metric push once production docker setup is ready
21
- # statsd.increment(
22
- # REQUEST_COUNT_METRIC_NAME,
23
- # tags=[
24
- # "service:django_worker",
25
- # "method:%s" % request.method,
26
- # "view:%s" % self.get_view_name(request),
27
- # "status:%s" % str(response.status_code),
28
- # ],
29
- # )
30
-
31
- # resp_time = (time.time() - request.start_time) * 1000
32
-
33
- # statsd.histogram(
34
- # REQUEST_LATENCY_METRIC_NAME,
35
- # resp_time,
36
- # tags=[
37
- # "service:django_worker",
38
- # "view:%s" % self.get_view_name(request),
39
- # ],
40
- # )
41
-
20
+ statsd .increment (
21
+ REQUEST_COUNT_METRIC_NAME ,
22
+ tags = [
23
+ "service:django_worker" ,
24
+ "method:%s" % request .method ,
25
+ "view:%s" % self .get_view_name (request ),
26
+ "status:%s" % str (response .status_code ),
27
+ ],
28
+ )
29
+
30
+ resp_time = (time .time () - request .start_time ) * 1000
31
+
32
+ statsd .histogram (
33
+ REQUEST_LATENCY_METRIC_NAME ,
34
+ resp_time ,
35
+ tags = [
36
+ "service:django_worker" ,
37
+ "view:%s" % self .get_view_name (request ),
38
+ ],
39
+ )
42
40
return response
0 commit comments