Update

Author: hectorhdzg

CHANGELOG.md

@@ -16,6 +16,49 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#4734](https://github.com/open-telemetry/opentelemetry-python/pull/4734))
 - [BREAKING] Remove LogData and extend SDK LogRecord to have instrumentation scope
   ([#4676](https://github.com/open-telemetry/opentelemetry-python/pull/4676))
+  
+  **Migration Guide:**
+  
+  `LogData` has been removed. Users should update their code as follows:
+  
+  - **For Log Exporters:** Change from `Sequence[LogData]` to `Sequence[ReadableLogRecord]`
+    ```python
+    # Before
+    from opentelemetry.sdk._logs import LogData
+    def export(self, batch: Sequence[LogData]) -> LogExportResult:
+        ...
+    
+    # After
+    from opentelemetry.sdk._logs import ReadableLogRecord
+    def export(self, batch: Sequence[ReadableLogRecord]) -> LogExportResult:
+        ...
+    ```
+  
+  - **For Log Processors:** Use `ReadWriteLogRecord` for processing, `ReadableLogRecord` for exporting
+    ```python
+    # Before
+    from opentelemetry.sdk._logs import LogData
+    def on_emit(self, log_data: LogData):
+        ...
+    
+    # After
+    from opentelemetry.sdk._logs import ReadWriteLogRecord, ReadableLogRecord
+    def on_emit(self, log_record: ReadWriteLogRecord):
+        # Convert to ReadableLogRecord before exporting
+        readable = ReadableLogRecord(
+            log_record=log_record.log_record,
+            resource=log_record.resource or Resource.create({}),
+            instrumentation_scope=log_record.instrumentation_scope,
+            limits=log_record.limits,
+        )
+        ...
+    ```
+  
+  - **Accessing log data:** Use the same attributes on `ReadableLogRecord`/`ReadWriteLogRecord`
+    - `log_record.log_record` - The API LogRecord (contains body, severity, attributes, etc.)
+    - `log_record.resource` - The Resource
+    - `log_record.instrumentation_scope` - The InstrumentationScope (now included, was in LogData before)
+    - `log_record.limits` - The LogLimits
 
 ## Version 1.38.0/0.59b0 (2025-10-16)
 

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

@@ -173,6 +173,46 @@ def dropped_attributes(self) -> int:
             return self.log_record.attributes.dropped
         return 0
 
+    def to_json(self, indent: int | None = 4) -> str:
+        return json.dumps(
+            {
+                "body": self.log_record.body,
+                "severity_number": self.log_record.severity_number.value
+                if self.log_record.severity_number is not None
+                else None,
+                "severity_text": self.log_record.severity_text,
+                "attributes": (
+                    dict(self.log_record.attributes)
+                    if bool(self.log_record.attributes)
+                    else None
+                ),
+                "dropped_attributes": self.dropped_attributes,
+                "timestamp": ns_to_iso_str(self.log_record.timestamp)
+                if self.log_record.timestamp is not None
+                else None,
+                "observed_timestamp": ns_to_iso_str(
+                    self.log_record.observed_timestamp
+                ),
+                "trace_id": (
+                    f"0x{format_trace_id(self.log_record.trace_id)}"
+                    if self.log_record.trace_id is not None
+                    else ""
+                ),
+                "span_id": (
+                    f"0x{format_span_id(self.log_record.span_id)}"
+                    if self.log_record.span_id is not None
+                    else ""
+                ),
+                "trace_flags": self.log_record.trace_flags,
+                "resource": json.loads(self.resource.to_json()),
+                "event_name": self.log_record.event_name
+                if self.log_record.event_name
+                else "",
+            },
+            indent=indent,
+            cls=BytesEncoder,
+        )
+
 
 @dataclass
 class ReadWriteLogRecord:
@@ -603,14 +643,17 @@ def emit(self, record: LogRecord):
         """Emits the :class:`ReadWriteLogRecord` by setting instrumentation scope
         and forwarding to the processor.
         """
+        writable_record: ReadWriteLogRecord
         if not isinstance(record, ReadWriteLogRecord):
             # pylint:disable=protected-access
-            record = ReadWriteLogRecord._from_api_log_record(
+            writable_record = ReadWriteLogRecord._from_api_log_record(
                 record=record,
                 resource=self._resource,
                 instrumentation_scope=self._instrumentation_scope,
             )
-        self._multi_log_record_processor.on_emit(record)
+        else:
+            writable_record = record
+        self._multi_log_record_processor.on_emit(writable_record)
 
 
 class LoggerProvider(APILoggerProvider):

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

@@ -31,6 +31,7 @@
     ReadableLogRecord,
     ReadWriteLogRecord,
 )
+from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk._shared_internal import BatchProcessor, DuplicateFilter
 from opentelemetry.sdk.environment_variables import (
     OTEL_BLRP_EXPORT_TIMEOUT,
@@ -124,9 +125,11 @@ def on_emit(self, log_record: ReadWriteLogRecord):
         token = attach(set_value(_SUPPRESS_INSTRUMENTATION_KEY, True))
         try:
             # Convert ReadWriteLogRecord to ReadableLogRecord before exporting
+            # Note: resource should not be None at this point as it's set during Logger.emit()
+            resource = log_record.resource if log_record.resource is not None else Resource.create({})
             readable_log_record = ReadableLogRecord(
                 log_record=log_record.log_record,
-                resource=log_record.resource,
+                resource=resource,
                 instrumentation_scope=log_record.instrumentation_scope,
                 limits=log_record.limits,
             )
@@ -199,9 +202,11 @@ def __init__(
 
     def on_emit(self, log_record: ReadWriteLogRecord) -> None:
         # Convert ReadWriteLogRecord to ReadableLogRecord before passing to BatchProcessor
+        # Note: resource should not be None at this point as it's set during Logger.emit()
+        resource = log_record.resource if log_record.resource is not None else Resource.create({})
         readable_log_record = ReadableLogRecord(
             log_record=log_record.log_record,
-            resource=log_record.resource,
+            resource=resource,
             instrumentation_scope=log_record.instrumentation_scope,
             limits=log_record.limits,
         )