|
24 | 24 | SeverityNumber, |
25 | 25 | get_logger_provider, |
26 | 26 | ) |
27 | | -from opentelemetry.sdk._logs import Logger, LoggerProvider, ReadWriteLogRecord |
| 27 | +from opentelemetry.sdk._logs import Logger, LoggerProvider |
28 | 28 | from opentelemetry.util.types import _ExtendedAttributes |
29 | 29 |
|
30 | 30 | _logger = logging.getLogger(__name__) |
@@ -53,18 +53,18 @@ def emit(self, event: Event) -> None: |
53 | 53 | if isinstance(self._logger, NoOpLogger): |
54 | 54 | # Do nothing if SDK is disabled |
55 | 55 | return |
56 | | - log_record = ReadWriteLogRecord( |
57 | | - LogRecord( |
58 | | - timestamp=event.timestamp or time_ns(), |
59 | | - observed_timestamp=None, |
60 | | - severity_text=None, |
61 | | - severity_number=event.severity_number or SeverityNumber.INFO, |
62 | | - body=event.body, |
63 | | - attributes=event.attributes, |
64 | | - ), |
65 | | - resource=getattr(self._logger, "resource", None), |
| 56 | + # Create an API LogRecord and pass it to the logger. The SDK Logger |
| 57 | + # will wrap this into a ReadWriteLogRecord and attach resource and |
| 58 | + # instrumentation scope. |
| 59 | + api_log_record = LogRecord( |
| 60 | + timestamp=event.timestamp or time_ns(), |
| 61 | + observed_timestamp=None, |
| 62 | + severity_text=None, |
| 63 | + severity_number=event.severity_number or SeverityNumber.INFO, |
| 64 | + body=event.body, |
| 65 | + attributes=event.attributes, |
66 | 66 | ) |
67 | | - self._logger.emit(log_record) |
| 67 | + self._logger.emit(api_log_record) |
68 | 68 |
|
69 | 69 |
|
70 | 70 | class EventLoggerProvider(APIEventLoggerProvider): |
|
0 commit comments