feat: ログファイルのローテートを削除し、メッセージ送信のデバッグログを削除

Author: shima004

adf_core_python/core/agent/agent.py

@@ -24,10 +24,10 @@
 from rcrs_core.connection.URN import Entity as EntityURN
 from rcrs_core.messages.AKAcknowledge import AKAcknowledge
 from rcrs_core.messages.AKConnect import AKConnect
+from rcrs_core.messages.controlMessageFactory import ControlMessageFactory
 from rcrs_core.messages.KAConnectError import KAConnectError
 from rcrs_core.messages.KAConnectOK import KAConnectOK
 from rcrs_core.messages.KASense import KASense
-from rcrs_core.messages.controlMessageFactory import ControlMessageFactory
 from rcrs_core.worldmodel.changeSet import ChangeSet
 from rcrs_core.worldmodel.entityID import EntityID
 from rcrs_core.worldmodel.worldmodel import WorldModel
@@ -214,11 +214,6 @@ def update_step_info(
 
         self.think()
 
-        self.logger.debug(
-            f"send messages: {self._message_manager.get_send_message_list()}",
-            message_manager=self._message_manager,
-        )
-
         self._message_manager.coordinate_message(
             self._agent_info, self._world_info, self._scenario_info
         )

adf_core_python/core/logger/logger.py

@@ -1,6 +1,7 @@
 import logging
+import os
 import sys
-from logging.handlers import RotatingFileHandler
+from datetime import datetime
 
 import structlog
 from structlog.dev import ConsoleRenderer
@@ -51,6 +52,13 @@ def get_agent_logger(name: str, agent_info: AgentInfo) -> structlog.BoundLogger:
 
 
 def configure_logger() -> None:
+    # 既存のログファイルが存在する場合、日付付きでバックアップする
+    log_file = "agent.log"
+    if os.path.exists(log_file):
+        timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
+        backup_file = f"agent_{timestamp}.log"
+        os.rename(log_file, backup_file)
+
     structlog.configure(
         processors=[
             structlog.stdlib.add_log_level,
@@ -65,16 +73,14 @@ def configure_logger() -> None:
         wrapper_class=structlog.stdlib.BoundLogger,
         cache_logger_on_first_use=True,
     )
+
     handler_stdout = logging.StreamHandler(sys.stdout)
     handler_stdout.setFormatter(
         structlog.stdlib.ProcessorFormatter(processor=ConsoleRenderer())
     )
     handler_stdout.setLevel(logging.INFO)
 
-    handler_file = RotatingFileHandler(
-        "agent.log", maxBytes=1024 * 1024 * 1024, backupCount=5
-    )
-    handler_file.doRollover()
+    handler_file = logging.FileHandler(log_file)
     handler_file.setFormatter(
         structlog.stdlib.ProcessorFormatter(processor=JSONRenderer())
     )