refactor(sdk): 统一 SDK logger 入口，消除散落的 loguru 直接导入

新增 _internal/sdk_logger.py 作为 SDK 唯一日志出口，通过 logger.patch()
注入 plugin_tag、short_levelname、版本号等上下文字段，替换 12 个模块中
原有的 from loguru import logger 和 loader.py 里的 stdlib logging。

- decorator_lifecycle/cli/context/peer/supervisor/transport/worker/session_waiter/star: 改为从 sdk_logger 导入
- handler_dispatcher: 含方法内延迟导入也一并迁移
- loader: 移除 _LOGGER (logging.getLogger)，全部改用 loguru + {} 格式串
- test_sdk_plugin_config_bridge: caplog 改为 monkeypatch 适配 loguru

Author: whatevertogo

astrbot-sdk/src/astrbot_sdk/_internal/decorator_lifecycle.py

@@ -6,7 +6,6 @@
 from dataclasses import dataclass, field
 from typing import Any
 
-from loguru import logger
 from pydantic import ValidationError
 
 from ..context import Context as RuntimeContext
@@ -23,6 +22,7 @@
     get_validate_config_meta,
 )
 from ..star import Star
+from .sdk_logger import logger
 from .star_runtime import bind_star_runtime
 
 _RUNTIME_STATE_ATTR = "__astrbot_decorator_runtime_state__"

astrbot-sdk/src/astrbot_sdk/_internal/sdk_logger.py

@@ -0,0 +1,50 @@
+from __future__ import annotations
+
+import os
+
+from loguru import logger as _raw_loguru_logger
+
+try:
+    from astrbot.core.config.default import VERSION as _ASTRBOT_VERSION
+except Exception:  # noqa: BLE001
+    _ASTRBOT_VERSION = ""
+
+_SHORT_LEVEL_NAMES = {
+    "DEBUG": "DBUG",
+    "INFO": "INFO",
+    "WARNING": "WARN",
+    "ERROR": "ERRO",
+    "CRITICAL": "CRIT",
+}
+
+
+def _get_short_level_name(level_name: str) -> str:
+    return _SHORT_LEVEL_NAMES.get(level_name.upper(), level_name[:4].upper())
+
+
+def _build_source_file(pathname: str | None) -> str:
+    if not pathname:
+        return "unknown"
+    dirname = os.path.dirname(pathname)
+    return (
+        os.path.basename(dirname) + "." + os.path.basename(pathname).replace(".py", "")
+    )
+
+
+def _patch_record(record: dict) -> None:
+    extra = record["extra"]
+    extra.setdefault("plugin_tag", "[Core]")
+    extra.setdefault("short_levelname", _get_short_level_name(record["level"].name))
+    level_no = record["level"].no
+    version_tag = (
+        f" [v{_ASTRBOT_VERSION}]" if _ASTRBOT_VERSION and level_no >= 30 else ""
+    )
+    extra.setdefault("astrbot_version_tag", version_tag)
+    extra.setdefault("source_file", _build_source_file(record["file"].path))
+    extra.setdefault("source_line", record["line"])
+    extra.setdefault("is_trace", False)
+
+
+logger = _raw_loguru_logger.patch(_patch_record)
+
+__all__ = ["logger"]

astrbot-sdk/src/astrbot_sdk/cli.py

@@ -30,8 +30,8 @@
 from typing import Any
 
 import click
-from loguru import logger
 
+from ._internal.sdk_logger import logger
 from .errors import AstrBotError
 from .runtime.bootstrap import run_plugin_worker, run_supervisor, run_websocket_server
 from .runtime.loader import load_plugin, load_plugin_spec, validate_plugin_spec

astrbot-sdk/src/astrbot_sdk/context.py

@@ -37,9 +37,8 @@
 from pathlib import Path
 from typing import Any
 
-from loguru import logger as base_logger
-
 from ._internal.plugin_logger import PluginLogger
+from ._internal.sdk_logger import logger as base_logger
 from ._internal.star_runtime import current_star_instance
 from ._message_types import normalize_message_type
 from .clients import (

astrbot-sdk/src/astrbot_sdk/runtime/capability_dispatcher.py

@@ -21,10 +21,9 @@
 from collections.abc import AsyncIterator, Sequence
 from typing import Any, cast, get_type_hints
 
-from loguru import logger
-
 from .._internal.invocation_context import caller_plugin_scope
 from .._internal.plugin_logger import PluginLogger
+from .._internal.sdk_logger import logger
 from .._internal.star_runtime import bind_star_runtime
 from .._internal.typing_utils import unwrap_optional
 from ..context import CancelToken, Context

astrbot-sdk/src/astrbot_sdk/runtime/handler_dispatcher.py

@@ -29,15 +29,14 @@
 from dataclasses import dataclass
 from typing import Any, cast, get_type_hints
 
-from loguru import logger
-
 from .._internal.command_model import (
     parse_command_model_remainder,
     resolve_command_model_param,
 )
 from .._internal.injected_params import legacy_arg_parameter_names
 from .._internal.invocation_context import caller_plugin_scope
 from .._internal.plugin_logger import PluginLogger
+from .._internal.sdk_logger import logger
 from .._internal.star_runtime import bind_star_runtime
 from .._internal.typing_utils import unwrap_optional
 from ..clients.llm import LLMResponse
@@ -411,7 +410,7 @@ def _build_args(
         injected_payloads: _InjectedEventPayloads | None = None,
     ) -> list[Any]:
         """构建 handler 参数列表。"""
-        from loguru import logger
+        from .._internal.sdk_logger import logger
 
         signature = inspect.signature(handler)
         injected_args: list[Any] = []

astrbot-sdk/src/astrbot_sdk/runtime/loader.py

@@ -60,7 +60,6 @@
 import importlib.abc
 import inspect
 import json
-import logging
 import os
 import re
 import shutil
@@ -83,6 +82,7 @@
     plugin_capability_prefix,
     validate_plugin_id,
 )
+from .._internal.sdk_logger import logger
 from .._internal.typing_utils import unwrap_optional
 from ..decorators import (
     ConversationMeta,
@@ -119,7 +119,6 @@
 HandlerKind: TypeAlias = Literal["handler", "hook", "tool", "session"]
 DiscoverySeverity: TypeAlias = Literal["warning", "error"]
 DiscoveryPhase: TypeAlias = Literal["discovery", "load", "lifecycle", "reload"]
-_LOGGER = logging.getLogger(__name__)
 _PLUGIN_IMPORT_LOCK = threading.RLock()
 _VALID_HANDLER_KINDS: tuple[HandlerKind, ...] = ("handler", "hook", "tool", "session")
 _PLUGIN_PACKAGE_PREFIX = "astrbot_ext_"
@@ -413,8 +412,8 @@ def _build_param_specs(handler: Any) -> list[ParamSpec]:
     try:
         type_hints = typing.get_type_hints(handler)
     except Exception as exc:
-        _LOGGER.warning(
-            "Failed to resolve type hints for handler %s: %s",
+        logger.warning(
+            "Failed to resolve type hints for handler {}: {}",
             getattr(handler, "__qualname__", repr(handler)),
             exc,
         )
@@ -648,22 +647,22 @@ def load_plugin_config_schema(plugin: PluginSpec) -> dict[str, Any]:
     try:
         schema_payload = json.loads(schema_path.read_text(encoding="utf-8"))
     except json.JSONDecodeError as exc:
-        _LOGGER.warning(
-            "Failed to parse SDK plugin config schema %s: %s",
+        logger.warning(
+            "Failed to parse SDK plugin config schema {}: {}",
             schema_path,
             exc,
         )
         return {}
     except OSError as exc:
-        _LOGGER.warning(
-            "Failed to read SDK plugin config schema %s: %s",
+        logger.warning(
+            "Failed to read SDK plugin config schema {}: {}",
             schema_path,
             exc,
         )
         return {}
     if not isinstance(schema_payload, dict):
-        _LOGGER.warning(
-            "SDK plugin config schema %s must be a JSON object, got %s",
+        logger.warning(
+            "SDK plugin config schema {} must be a JSON object, got {}",
             schema_path,
             type(schema_payload).__name__,
         )
@@ -716,15 +715,15 @@ def load_plugin_config(
             else {}
         )
     except json.JSONDecodeError as exc:
-        _LOGGER.warning(
-            "Failed to parse SDK plugin config %s: %s",
+        logger.warning(
+            "Failed to parse SDK plugin config {}: {}",
             config_path,
             exc,
         )
         existing_payload = {}
     except OSError as exc:
-        _LOGGER.warning(
-            "Failed to read SDK plugin config %s: %s",
+        logger.warning(
+            "Failed to read SDK plugin config {}: {}",
             config_path,
             exc,
         )
@@ -1016,14 +1015,12 @@ def _load_state(state_path: Path) -> dict[str, Any]:
         try:
             data = json.loads(state_path.read_text(encoding="utf-8"))
         except json.JSONDecodeError as exc:
-            _LOGGER.warning(
-                "Failed to parse plugin worker state %s: %s", state_path, exc
+            logger.warning(
+                "Failed to parse plugin worker state {}: {}", state_path, exc
             )
             return {}
         except OSError as exc:
-            _LOGGER.warning(
-                "Failed to read plugin worker state %s: %s", state_path, exc
-            )
+            logger.warning("Failed to read plugin worker state {}: {}", state_path, exc)
             return {}
         return data if isinstance(data, dict) else {}
 
@@ -1114,8 +1111,8 @@ def _load_component_instance(
             f"{_component_context(plugin, class_path=resolved_component.class_path, index=resolved_component.index)} "
             f"实例化失败：{exc}"
         ) from exc
-    _LOGGER.debug(
-        "Instantiated SDK plugin component %s for plugin %s",
+    logger.debug(
+        "Instantiated SDK plugin component {} for plugin {}",
         resolved_component.class_path,
         plugin.name,
     )
@@ -1263,7 +1260,7 @@ def load_plugin(plugin: PluginSpec) -> LoadedPlugin:
     仅支持 v4 新版 Star 组件（无参构造函数）。
     """
     with _PLUGIN_IMPORT_LOCK:
-        _LOGGER.debug("Loading SDK plugin %s from %s", plugin.name, plugin.plugin_dir)
+        logger.debug("Loading SDK plugin {} from {}", plugin.name, plugin.plugin_dir)
         _ensure_plugin_import_hook_installed()
         namespace = _register_plugin_import_namespace(plugin)
         _purge_plugin_bytecode(plugin.plugin_dir)
@@ -1304,8 +1301,8 @@ def load_plugin(plugin: PluginSpec) -> LoadedPlugin:
                 capabilities.extend(component_capabilities)
                 llm_tools.extend(component_tools)
 
-        _LOGGER.debug(
-            "Loaded SDK plugin %s: %d components, %d handlers, %d capabilities, %d llm tools, %d agents",
+        logger.debug(
+            "Loaded SDK plugin {}: {} components, {} handlers, {} capabilities, {} llm tools, {} agents",
             plugin.name,
             len(resolved_components),
             len(handlers),

astrbot-sdk/src/astrbot_sdk/runtime/peer.py

@@ -73,12 +73,11 @@
 from collections.abc import AsyncIterator, Awaitable, Callable, Sequence
 from typing import Any
 
-from loguru import logger
-
 from .._internal.invocation_context import (
     caller_plugin_scope,
     current_caller_plugin_id,
 )
+from .._internal.sdk_logger import logger
 from ..context import CancelToken
 from ..errors import AstrBotError, ErrorCodes
 from ..protocol.messages import (

astrbot-sdk/src/astrbot_sdk/runtime/supervisor.py

@@ -43,12 +43,11 @@
 from pathlib import Path
 from typing import IO, Any, cast
 
-from loguru import logger
-
 from .._internal.plugin_ids import (
     capability_belongs_to_plugin,
     plugin_capability_prefix,
 )
+from .._internal.sdk_logger import logger
 from ..errors import AstrBotError
 from ..protocol.descriptors import CapabilityDescriptor
 from ..protocol.messages import EventMessage, InitializeOutput, PeerInfo

astrbot-sdk/src/astrbot_sdk/runtime/transport.py

@@ -56,7 +56,7 @@
 from collections.abc import Awaitable, Callable, Sequence
 from typing import IO, Any
 
-from loguru import logger
+from .._internal.sdk_logger import logger
 
 MessageHandler = Callable[[str], Awaitable[None]]
 STDIO_SUBPROCESS_STREAM_LIMIT = 8 * 1024 * 1024