fix console log exporter

Author: DylanRussell

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

@@ -20,6 +20,7 @@
 import logging
 import threading
 import traceback
+import base64
 import warnings
 from os import environ
 from threading import Lock
@@ -60,6 +61,12 @@
 _DEFAULT_OTEL_ATTRIBUTE_COUNT_LIMIT = 128
 _ENV_VALUE_UNSET = ""
 
+class BytesEncoder(json.JSONEncoder):
+    def default(self, o):
+        if isinstance(o, bytes):
+            return base64.b64encode(o).decode()
+        return super().default(o)
+
 
 class LogDroppedAttributesWarning(UserWarning):
     """Custom warning to indicate dropped log attributes due to limits.
@@ -248,6 +255,7 @@ def to_json(self, indent: int | None = 4) -> str:
                 "resource": json.loads(self.resource.to_json()),
             },
             indent=indent,
+            cls=BytesEncoder,
         )
 
     @property

opentelemetry-sdk/tests/logs/test_log_record.py

@@ -22,6 +22,7 @@
     LogDroppedAttributesWarning,
     LogLimits,
     LogRecord,
+    BytesEncoder,
 )
 from opentelemetry.sdk.resources import Resource
 
@@ -30,7 +31,7 @@ class TestLogRecord(unittest.TestCase):
     def test_log_record_to_json(self):
         expected = json.dumps(
             {
-                "body": "a log line",
+                "body": {'key': 'logLine', 'bytes': b'123'},
                 "severity_number": None,
                 "severity_text": None,
                 "attributes": {
@@ -51,11 +52,12 @@ def test_log_record_to_json(self):
                 },
             },
             indent=4,
+            cls=BytesEncoder,
         )
         actual = LogRecord(
             timestamp=0,
             observed_timestamp=0,
-            body="a log line",
+            body={'key': 'logLine', 'bytes': b'123'},
             resource=Resource({"service.name": "foo"}),
             attributes={
                 "mapping": {"key": "value"},