fix: 使用 f-string 改进日志记录格式
This commit is contained in:
@@ -71,7 +71,7 @@ class PlatformIOManager:
|
|||||||
try:
|
try:
|
||||||
await driver.stop()
|
await driver.stop()
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.exception("回滚驱动停止失败: driver_id=%s", driver.driver_id)
|
logger.exception(f"回滚驱动停止失败: driver_id={driver.driver_id}")
|
||||||
raise
|
raise
|
||||||
|
|
||||||
self._started = True
|
self._started = True
|
||||||
@@ -104,7 +104,7 @@ class PlatformIOManager:
|
|||||||
await driver.stop()
|
await driver.stop()
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
stop_errors.append(f"{driver.driver_id}: {exc}")
|
stop_errors.append(f"{driver.driver_id}: {exc}")
|
||||||
logger.exception("驱动停止失败: driver_id=%s", driver.driver_id)
|
logger.exception(f"驱动停止失败: driver_id={driver.driver_id}")
|
||||||
|
|
||||||
self._started = False
|
self._started = False
|
||||||
self._deduplicator.clear()
|
self._deduplicator.clear()
|
||||||
@@ -448,9 +448,8 @@ class PlatformIOManager:
|
|||||||
|
|
||||||
if not self._receive_route_table.has_binding_for_driver(envelope.route_key, envelope.driver_id):
|
if not self._receive_route_table.has_binding_for_driver(envelope.route_key, envelope.driver_id):
|
||||||
logger.info(
|
logger.info(
|
||||||
"忽略未登记到接收路由表的入站消息: route=%s driver=%s",
|
f"忽略未登记到接收路由表的入站消息: route={envelope.route_key} "
|
||||||
envelope.route_key,
|
f"driver={envelope.driver_id}"
|
||||||
envelope.driver_id,
|
|
||||||
)
|
)
|
||||||
return False
|
return False
|
||||||
|
|
||||||
@@ -461,7 +460,7 @@ class PlatformIOManager:
|
|||||||
dedupe_key = self._build_inbound_dedupe_key(envelope)
|
dedupe_key = self._build_inbound_dedupe_key(envelope)
|
||||||
if dedupe_key is not None:
|
if dedupe_key is not None:
|
||||||
if not self._deduplicator.mark_seen(dedupe_key):
|
if not self._deduplicator.mark_seen(dedupe_key):
|
||||||
logger.info("忽略重复入站消息: dedupe_key=%s", dedupe_key)
|
logger.info(f"忽略重复入站消息: dedupe_key={dedupe_key}")
|
||||||
return False
|
return False
|
||||||
|
|
||||||
await self._inbound_dispatcher(envelope)
|
await self._inbound_dispatcher(envelope)
|
||||||
|
|||||||
Reference in New Issue
Block a user