Fix for issue - #2808: Invalid type WSGIRequest for attribute 'request' value opentelemetry

Author: rads-1996

CHANGELOG.md

@@ -12,6 +12,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## Unreleased
 
+- opentelemetry-sdk: Added request filter which fixes invalid type at WSGI request headers and attributes
 - docs: Added sqlcommenter example
   ([#4734](https://github.com/open-telemetry/opentelemetry-python/pull/4734))
 - build: bump ruff to 0.14.1

opentelemetry-sdk/src/opentelemetry/sdk/_logs/_internal/export/__init__.py

@@ -31,7 +31,11 @@
     ReadableLogRecord,
     ReadWriteLogRecord,
 )
-from opentelemetry.sdk._shared_internal import BatchProcessor, DuplicateFilter
+from opentelemetry.sdk._shared_internal import (
+    BatchProcessor,
+    DuplicateFilter,
+    RequestFilter,
+)
 from opentelemetry.sdk.environment_variables import (
     OTEL_BLRP_EXPORT_TIMEOUT,
     OTEL_BLRP_MAX_EXPORT_BATCH_SIZE,
@@ -49,6 +53,8 @@
 )
 _logger = logging.getLogger(__name__)
 _logger.addFilter(DuplicateFilter())
+_wsgi_request_logger = logging.getLogger("django.request")
+_wsgi_request_logger.addFilter(RequestFilter())
 
 
 class LogExportResult(enum.Enum):

opentelemetry-sdk/src/opentelemetry/sdk/_shared_internal/__init__.py

@@ -62,6 +62,13 @@ def filter(self, record):
         return False
 
 
+class RequestFilter(logging.Filter):
+    def filter(self, record: logging.LogRecord) -> bool:
+        request = getattr(record, "request", None)
+        record.request = str(request)
+        return True
+
+
 class BatchExportStrategy(enum.Enum):
     EXPORT_ALL = 0
     EXPORT_WHILE_BATCH_EXCEEDS_THRESHOLD = 1
@@ -113,6 +120,8 @@ def __init__(
         )
         self._logger = logging.getLogger(__name__)
         self._logger.addFilter(DuplicateFilter())
+        self._wsgi_request_logger = logging.getLogger("django.request")
+        self._wsgi_request_logger.addFilter(RequestFilter())
         self._exporting = exporting
 
         self._shutdown = False

opentelemetry-sdk/tests/shared_internal/test_batch_processor.py

@@ -38,6 +38,7 @@
 )
 from opentelemetry.sdk._shared_internal import (
     DuplicateFilter,
+    RequestFilter,
 )
 from opentelemetry.sdk.trace import ReadableSpan
 from opentelemetry.sdk.trace.export import BatchSpanProcessor
@@ -264,3 +265,49 @@ def test_duplicate_logs_filter_works(self):
             test_logger.info("message")
             test_logger.info("message")
         self.assertEqual(len(cm.output), 1)
+
+
+class TestRequestFilter(unittest.TestCase):
+    def test_converts_http_request_to_string(self):
+        class DummyRequest:
+            def __str__(self):
+                return "<DummyRequest method=GET path=/example/>"
+
+        request = DummyRequest()
+
+        record = logging.LogRecord(
+            name="django.request",
+            level=logging.ERROR,
+            pathname=__file__,
+            lineno=0,
+            msg="test message",
+            args=(),
+            exc_info=None,
+        )
+        record.request = request
+
+        expected_repr = str(request)
+
+        request_filter = RequestFilter()
+        result = request_filter.filter(record)
+
+        self.assertTrue(result)
+        self.assertEqual(getattr(record, "request", None), expected_repr)
+        self.assertIsInstance(getattr(record, "request", None), str)
+
+    def test_handles_missing_request_attribute(self):
+        record = logging.LogRecord(
+            name="django.request",
+            level=logging.INFO,
+            pathname=__file__,
+            lineno=0,
+            msg="no request",
+            args=(),
+            exc_info=None,
+        )
+
+        request_filter = RequestFilter()
+        result = request_filter.filter(record)
+
+        self.assertTrue(result)
+        self.assertEqual(getattr(record, "request", None), "None")