requests duration histogram stable semconv

Signed-off-by: emdneto <[email protected]>

Author: emdneto

instrumentation/opentelemetry-instrumentation-requests/src/opentelemetry/instrumentation/requests/__init__.py

@@ -57,6 +57,22 @@ def response_hook(span, request_obj, response):
         request_hook=request_hook, response_hook=response_hook
     )
 
+Custom Duration Histogram Boundaries
+************************************
+To customize the duration histogram bucket boundaries used for HTTP client request duration metrics,
+you can provide a list of values when instrumenting:
+
+.. code:: python
+
+    import requests
+    from opentelemetry.instrumentation.requests import RequestsInstrumentor
+
+    custom_boundaries = [0, 5, 10, 25, 50, 100, 250, 500, 1000]
+
+    RequestsInstrumentor().instrument(
+        duration_histogram_boundaries=custom_boundaries
+    )
+
 Exclude lists
 *************
 To exclude certain URLs from being tracked, set the environment variable ``OTEL_PYTHON_REQUESTS_EXCLUDED_URLS``
@@ -87,7 +103,8 @@ def response_hook(span, request_obj, response):
 from requests.structures import CaseInsensitiveDict
 
 from opentelemetry.instrumentation._semconv import (
-    _DURATION_HISTOGRAM_NEW_EXPLICIT_BOUNDS,
+    DURATION_HISTOGRAM_EXPLICIT_BOUNDS_NEW,
+    DURATION_HISTOGRAM_EXPLICIT_BOUNDS_OLD,
     _client_duration_attrs_new,
     _client_duration_attrs_old,
     _filter_semconv_duration_attrs,
@@ -411,8 +428,8 @@ def _instrument(self, **kwargs: Any):
                 ``tracer_provider``: a TracerProvider, defaults to global
                 ``request_hook``: An optional callback that is invoked right after a span is created.
                 ``response_hook``: An optional callback which is invoked right before the span is finished processing a response.
-                ``excluded_urls``: A string containing a comma-delimited
-                    list of regexes used to exclude URLs from tracking
+                ``excluded_urls``: A string containing a comma-delimited list of regexes used to exclude URLs from tracking
+                ``duration_histogram_boundaries``: A list of float values representing the explicit bucket boundaries for the duration histogram.
         """
         semconv_opt_in_mode = _OpenTelemetrySemanticConventionStability._get_opentelemetry_stability_opt_in_mode(
             _OpenTelemetryStabilitySignalType.HTTP,
@@ -427,6 +444,9 @@ def _instrument(self, **kwargs: Any):
         )
         excluded_urls = kwargs.get("excluded_urls")
         meter_provider = kwargs.get("meter_provider")
+        duration_histogram_boundaries = kwargs.get(
+            "duration_histogram_boundaries"
+        )
         meter = get_meter(
             __name__,
             __version__,
@@ -439,14 +459,17 @@ def _instrument(self, **kwargs: Any):
                 name=MetricInstruments.HTTP_CLIENT_DURATION,
                 unit="ms",
                 description="measures the duration of the outbound HTTP request",
+                explicit_bucket_boundaries_advisory=duration_histogram_boundaries
+                or DURATION_HISTOGRAM_EXPLICIT_BOUNDS_OLD,
             )
         duration_histogram_new = None
         if _report_new(semconv_opt_in_mode):
             duration_histogram_new = meter.create_histogram(
                 name=HTTP_CLIENT_REQUEST_DURATION,
                 unit="s",
                 description="Duration of HTTP client requests.",
-                explicit_bucket_boundaries_advisory=_DURATION_HISTOGRAM_NEW_EXPLICIT_BOUNDS,
+                explicit_bucket_boundaries_advisory=duration_histogram_boundaries
+                or DURATION_HISTOGRAM_EXPLICIT_BOUNDS_NEW,
             )
         _instrument(
             tracer,

instrumentation/opentelemetry-instrumentation-requests/tests/test_requests_integration.py

@@ -23,8 +23,8 @@
 import opentelemetry.instrumentation.requests
 from opentelemetry import trace
 from opentelemetry.instrumentation._semconv import (
-    _DURATION_HISTOGRAM_NEW_EXPLICIT_BOUNDS,
-    _DURATION_HISTOGRAM_OLD_EXPLICIT_BOUNDS,
+    DURATION_HISTOGRAM_EXPLICIT_BOUNDS_NEW,
+    DURATION_HISTOGRAM_EXPLICIT_BOUNDS_OLD,
     OTEL_SEMCONV_STABILITY_OPT_IN,
     _OpenTelemetrySemanticConventionStability,
 )
@@ -125,6 +125,7 @@ def setUp(self):
     def tearDown(self):
         super().tearDown()
         self.env_patch.stop()
+        _OpenTelemetrySemanticConventionStability._initialized = False
         RequestsInstrumentor().uninstrument()
         httpretty.disable()
 
@@ -732,6 +733,7 @@ def setUp(self):
     def tearDown(self):
         super().tearDown()
         self.env_patch.stop()
+        _OpenTelemetrySemanticConventionStability._initialized = False
         RequestsInstrumentor().uninstrument()
         httpretty.disable()
 
@@ -766,7 +768,7 @@ def test_basic_metric_success(self):
                     for data_point in metric.data.data_points:
                         self.assertEqual(
                             data_point.explicit_bounds,
-                            _DURATION_HISTOGRAM_OLD_EXPLICIT_BOUNDS,
+                            DURATION_HISTOGRAM_EXPLICIT_BOUNDS_OLD,
                         )
                         self.assertDictEqual(
                             expected_attributes, dict(data_point.attributes)
@@ -796,7 +798,7 @@ def test_basic_metric_new_semconv(self):
                     for data_point in metric.data.data_points:
                         self.assertEqual(
                             data_point.explicit_bounds,
-                            _DURATION_HISTOGRAM_NEW_EXPLICIT_BOUNDS,
+                            DURATION_HISTOGRAM_EXPLICIT_BOUNDS_NEW,
                         )
                         self.assertDictEqual(
                             expected_attributes, dict(data_point.attributes)
@@ -843,6 +845,38 @@ def test_basic_metric_both_semconv(self):
                             )
                         self.assertEqual(data_point.count, 1)
 
+    def test_custom_histogram_boundaries(self):
+        RequestsInstrumentor().uninstrument()
+        custom_boundaries = (0, 1, 2, 5, 10, 20, 50, 100)
+        meter_provider, memory_reader = self.create_meter_provider()
+        RequestsInstrumentor().instrument(
+            meter_provider=meter_provider,
+            duration_histogram_boundaries=custom_boundaries,
+        )
+
+        self.perform_request(self.URL)
+        metrics = memory_reader.get_metrics_data().resource_metrics[0]
+        self.assertEqual(len(metrics.scope_metrics), 1)
+        data_point = metrics.scope_metrics[0].metrics[0].data.data_points[0]
+        self.assertEqual(data_point.explicit_bounds, custom_boundaries)
+        self.assertEqual(data_point.count, 1)
+
+    def test_custom_histogram_boundaries_new_semconv(self):
+        RequestsInstrumentor().uninstrument()
+        custom_boundaries = (0, 5, 10, 25, 50, 100, 250, 500, 1000)
+        meter_provider, memory_reader = self.create_meter_provider()
+        RequestsInstrumentor().instrument(
+            meter_provider=meter_provider,
+            duration_histogram_boundaries=custom_boundaries,
+        )
+
+        self.perform_request(self.URL)
+        metrics = memory_reader.get_metrics_data().resource_metrics[0]
+        self.assertEqual(len(metrics.scope_metrics), 1)
+        data_point = metrics.scope_metrics[0].metrics[0].data.data_points[0]
+        self.assertEqual(data_point.explicit_bounds, custom_boundaries)
+        self.assertEqual(data_point.count, 1)
+
     def test_basic_metric_non_recording_span(self):
         expected_attributes = {
             SpanAttributes.HTTP_STATUS_CODE: 200,

opentelemetry-instrumentation/src/opentelemetry/instrumentation/_semconv.py

@@ -48,7 +48,7 @@
 from opentelemetry.trace.status import Status, StatusCode
 
 # Values defined in milliseconds
-_DURATION_HISTOGRAM_OLD_EXPLICIT_BOUNDS = (
+DURATION_HISTOGRAM_EXPLICIT_BOUNDS_OLD = (
     0.0,
     5.0,
     10.0,
@@ -67,7 +67,7 @@
 )
 
 # Values defined in seconds
-_DURATION_HISTOGRAM_NEW_EXPLICIT_BOUNDS = (
+DURATION_HISTOGRAM_EXPLICIT_BOUNDS_NEW = (
     0.005,
     0.01,
     0.025,