Skip to content

Commit 245d757

Browse files
authored
Merge pull request #102 from adf-python/feature/101
ログファイルのローテートを削除し、メッセージ送信のデバッグログを削除
2 parents cf4dbf9 + 02afafe commit 245d757

File tree

2 files changed

+12
-11
lines changed

2 files changed

+12
-11
lines changed

adf_core_python/core/agent/agent.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@
2424
from rcrs_core.connection.URN import Entity as EntityURN
2525
from rcrs_core.messages.AKAcknowledge import AKAcknowledge
2626
from rcrs_core.messages.AKConnect import AKConnect
27+
from rcrs_core.messages.controlMessageFactory import ControlMessageFactory
2728
from rcrs_core.messages.KAConnectError import KAConnectError
2829
from rcrs_core.messages.KAConnectOK import KAConnectOK
2930
from rcrs_core.messages.KASense import KASense
30-
from rcrs_core.messages.controlMessageFactory import ControlMessageFactory
3131
from rcrs_core.worldmodel.changeSet import ChangeSet
3232
from rcrs_core.worldmodel.entityID import EntityID
3333
from rcrs_core.worldmodel.worldmodel import WorldModel
@@ -214,11 +214,6 @@ def update_step_info(
214214

215215
self.think()
216216

217-
self.logger.debug(
218-
f"send messages: {self._message_manager.get_send_message_list()}",
219-
message_manager=self._message_manager,
220-
)
221-
222217
self._message_manager.coordinate_message(
223218
self._agent_info, self._world_info, self._scenario_info
224219
)

adf_core_python/core/logger/logger.py

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
import logging
2+
import os
23
import sys
3-
from logging.handlers import RotatingFileHandler
4+
from datetime import datetime
45

56
import structlog
67
from structlog.dev import ConsoleRenderer
@@ -51,6 +52,13 @@ def get_agent_logger(name: str, agent_info: AgentInfo) -> structlog.BoundLogger:
5152

5253

5354
def configure_logger() -> None:
55+
# 既存のログファイルが存在する場合、日付付きでバックアップする
56+
log_file = "agent.log"
57+
if os.path.exists(log_file):
58+
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
59+
backup_file = f"agent_{timestamp}.log"
60+
os.rename(log_file, backup_file)
61+
5462
structlog.configure(
5563
processors=[
5664
structlog.stdlib.add_log_level,
@@ -65,16 +73,14 @@ def configure_logger() -> None:
6573
wrapper_class=structlog.stdlib.BoundLogger,
6674
cache_logger_on_first_use=True,
6775
)
76+
6877
handler_stdout = logging.StreamHandler(sys.stdout)
6978
handler_stdout.setFormatter(
7079
structlog.stdlib.ProcessorFormatter(processor=ConsoleRenderer())
7180
)
7281
handler_stdout.setLevel(logging.INFO)
7382

74-
handler_file = RotatingFileHandler(
75-
"agent.log", maxBytes=1024 * 1024 * 1024, backupCount=5
76-
)
77-
handler_file.doRollover()
83+
handler_file = logging.FileHandler(log_file)
7884
handler_file.setFormatter(
7985
structlog.stdlib.ProcessorFormatter(processor=JSONRenderer())
8086
)

0 commit comments

Comments
 (0)