Method format

fastdeploy/logger/formatters.py:91–128

Format log record, with new support for attributes expansion and otelSpanID/otelTraceID fields. Supports field expansion and adds thread, timestamp and other information. Args: record (LogRecord): Log record object. Returns: str: Log message s

(self, record)

        return s1.lower()

    def format(self, record):
        """
        Format log record, with new support for attributes expansion and otelSpanID/otelTraceID fields.
        Supports field expansion and adds thread, timestamp and other information.
        Args:
            record (LogRecord): Log record object.
        Returns:
            str: Log message string.
        """

        try:
            log_fields = {
                "thread": record.thread,
                "thread_name": record.threadName,
                "timestamp": int(time.time() * 1000),
            }

            if hasattr(record, "attributes") and isinstance(record.attributes, dict):
                for k, v in record.attributes.items():
                    log_fields[self._camel_to_snake(k)] = v

            # filter out null values.
            log_fields = {k: v for k, v in log_fields.items() if not (isinstance(v, str) and v == "")}

            log_str = " ".join(f"[{k}={v}]" for k, v in log_fields.items())
            if log_str:
                record.msg = f"{log_str} {record.msg}"

            # Add OpenTelemetry-related fields.
            if hasattr(record, "otelSpanID") and record.otelSpanID is not None:
                record.msg = f"[otel_span_id={record.otelSpanID}] {record.msg}"
            if hasattr(record, "otelTraceID") and record.otelTraceID is not None:
                record.msg = f"[otel_trace_id={record.otelTraceID}] {record.msg}"

        except:
            pass

        return super().format(record)