modify: mqtt日志问题
This commit is contained in:
@@ -130,14 +130,17 @@ async def create_workers(session, config, count=1, worker_manager=None):
|
|||||||
from .mqtt_forward import MQTTForwardClient
|
from .mqtt_forward import MQTTForwardClient
|
||||||
mqtt_fwd_uri = mqtt_fwd.get("uri", "")
|
mqtt_fwd_uri = mqtt_fwd.get("uri", "")
|
||||||
mqtt_fwd_topic = mqtt_fwd.get("topic", "/board_ping")
|
mqtt_fwd_topic = mqtt_fwd.get("topic", "/board_ping")
|
||||||
|
logger.warning(f"[MQTTForward] 配置已加载: enabled={mqtt_fwd_enabled}, uri={mqtt_fwd_uri}, topic={mqtt_fwd_topic}")
|
||||||
if mqtt_fwd_uri:
|
if mqtt_fwd_uri:
|
||||||
mqtt_fwd_client = MQTTForwardClient(uri=mqtt_fwd_uri, topic=mqtt_fwd_topic)
|
mqtt_fwd_client = MQTTForwardClient(uri=mqtt_fwd_uri, topic=mqtt_fwd_topic)
|
||||||
try:
|
try:
|
||||||
await mqtt_fwd_client.start()
|
await mqtt_fwd_client.start()
|
||||||
logger.info(f"[MQTTForward] 外部转发已启用: {mqtt_fwd_uri} → {mqtt_fwd_topic}")
|
logger.warning(f"[MQTTForward] 外部转发已启用: {mqtt_fwd_uri} → {mqtt_fwd_topic}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.warning(f"[MQTTForward] 启动失败,将跳过转发: {e}")
|
logger.warning(f"[MQTTForward] 启动失败,将跳过转发: {e}")
|
||||||
mqtt_fwd_client = None
|
mqtt_fwd_client = None
|
||||||
|
else:
|
||||||
|
logger.warning(f"[MQTTForward] mqtt_forward 未启用,配置内容: {mqtt_fwd}")
|
||||||
|
|
||||||
set_global_var("db", db)
|
set_global_var("db", db)
|
||||||
set_global_var("heartbeat_timeout", hb_timeout)
|
set_global_var("heartbeat_timeout", hb_timeout)
|
||||||
|
|||||||
@@ -55,6 +55,7 @@ class MQTTForwardClient:
|
|||||||
"reconnect_retries": -1, # 无限重连
|
"reconnect_retries": -1, # 无限重连
|
||||||
"reconnect_max_interval": 30, # 最大重连间隔(秒)
|
"reconnect_max_interval": 30, # 最大重连间隔(秒)
|
||||||
"keep_alive": 60,
|
"keep_alive": 60,
|
||||||
|
"connection_timeout": 10, # 连接超时(秒),避免永久挂起
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
# 手动初始化 session 并设置解码后的凭据(绕过 amqtt urlparse 不解码 %40 的问题)
|
# 手动初始化 session 并设置解码后的凭据(绕过 amqtt urlparse 不解码 %40 的问题)
|
||||||
|
|||||||
@@ -95,7 +95,11 @@ async def board_ping(request: BoardPingRequest, worker_id: str = "") -> dict:
|
|||||||
|
|
||||||
# 转发心跳数据到外部 MQTT Broker
|
# 转发心跳数据到外部 MQTT Broker
|
||||||
if mqtt_forward is not None:
|
if mqtt_forward is not None:
|
||||||
await mqtt_forward.publish(ping_data)
|
success = await mqtt_forward.publish(ping_data)
|
||||||
|
if not success:
|
||||||
|
logger.warning("[MQTTForward] 心跳转发失败")
|
||||||
|
else:
|
||||||
|
logger.warning("[MQTTForward] mqtt_forward 客户端为 None,跳过转发")
|
||||||
|
|
||||||
logger.debug(
|
logger.debug(
|
||||||
f"[Heartbeat] {board_id}: temp={request.BoardTemp}, "
|
f"[Heartbeat] {board_id}: temp={request.BoardTemp}, "
|
||||||
|
|||||||
Reference in New Issue
Block a user