Feat:增加日志的筛选和过滤功能

astrbot/core/event_bus.py

@@ -13,7 +13,7 @@
 import asyncio
 from asyncio import Queue
 
-from astrbot.core import logger
+from astrbot.core import LogManager, logger
 from astrbot.core.astrbot_config_mgr import AstrBotConfigManager
 from astrbot.core.pipeline.scheduler import PipelineScheduler
 
@@ -40,14 +40,18 @@ async def dispatch(self) -> None:
             conf_info = self.astrbot_config_mgr.get_conf_info(event.unified_msg_origin)
             conf_id = conf_info["id"]
             conf_name = conf_info.get("name") or conf_id
-            self._print_event(event, conf_name)
-            scheduler = self.pipeline_scheduler_mapping.get(conf_id)
-            if not scheduler:
-                logger.error(
-                    f"PipelineScheduler not found for id: {conf_id}, event ignored."
-                )
-                continue
-            asyncio.create_task(scheduler.execute(event))
+            with LogManager.contextualize(
+                umo=event.unified_msg_origin,
+                platform_id=event.get_platform_id(),
+            ):
+                self._print_event(event, conf_name)
+                scheduler = self.pipeline_scheduler_mapping.get(conf_id)
+                if not scheduler:
+                    logger.error(
+                        f"PipelineScheduler not found for id: {conf_id}, event ignored."
+                    )
+                    continue
+                asyncio.create_task(scheduler.execute(event))
 
     def _print_event(self, event: AstrMessageEvent, conf_name: str) -> None:
         """用于记录事件信息