Class DatabaseLogHandler

src/core/db_logs.py:41–86

将日志写入 app_logs 表。 为避免递归写日志，emit 内部不再产生日志。

class DatabaseLogHandler(logging.Handler):
    """
    将日志写入 app_logs 表。
    为避免递归写日志，emit 内部不再产生日志。
    """

    def __init__(self, min_level: int = logging.INFO):
        super().__init__(level=min_level)
        self._local = threading.local()

    def emit(self, record: logging.LogRecord) -> None:
        if getattr(self._local, "busy", False):
            return
        if record.levelno < self.level:
            return
        if _should_skip_record(record):
            return

        message = ""
        exception_text = None
        try:
            self._local.busy = True
            message = record.getMessage()
            if record.exc_info:
                exception_text = "".join(traceback.format_exception(*record.exc_info))[-4000:]
            elif record.exc_text:
                exception_text = str(record.exc_text)[-4000:]

            with get_db() as db:
                db.add(
                    AppLog(
                        level=record.levelname,
                        logger=str(record.name or "root"),
                        module=str(record.module or ""),
                        pathname=str(record.pathname or ""),
                        lineno=int(record.lineno or 0),
                        message=str(message or ""),
                        exception=exception_text,
                        created_at=datetime.utcfromtimestamp(record.created),
                    )
                )
                db.commit()
        except Exception:
            self.handleError(record)
        finally:
            self._local.busy = False


def install_database_log_handler(min_level: int = logging.INFO) -> bool: