From 5b848744acd5c6f23da4f887174de992968963aa Mon Sep 17 00:00:00 2001 From: chakcy <947105045@qq.com> Date: Fri, 7 Aug 2026 14:28:21 +0800 Subject: [PATCH] =?UTF-8?q?modify:=20chongming-mqtt=20=E5=BA=94=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- workers/aibox_sophon_adapter/config.toml | 36 ++++++++++++++++++++++++ 1 file changed, 36 insertions(+) diff --git a/workers/aibox_sophon_adapter/config.toml b/workers/aibox_sophon_adapter/config.toml index 77c0439..ff8be5e 100644 --- a/workers/aibox_sophon_adapter/config.toml +++ b/workers/aibox_sophon_adapter/config.toml @@ -44,6 +44,42 @@ enabled = true uri = "mqtt://admin:Mixc%402021@dg.datagoo.cn:48081" # %40 是 @ 的 URL 编码 topic = "/board_ping" # 转发目标主题 +# ====== 外部 MQTT 订阅（本插件直接订阅外部 Broker，不走网关 Bridge） ====== +# enabled: 是否启用外部订阅 +# uri: 外部 Broker 地址（mqtt://user:pass@host:port，密码中特殊字符需 URL 编码） +# topics: 订阅主题列表，每项包含 +# topic: 订阅主题，支持 +（单级）/ #（多级，须在末尾）通配符 +# handler: 处理函数名，按序从插件 router 模块、插件包自身查找 +# 若该函数首个参数为 Pydantic 模型，则以消息 JSON 构造模型后调用； +# 否则将消息 JSON 作为关键字参数展开调用 +# reply_topic: 可选，回复主题；处理后返回值（非 None）发布到该主题 +# 支持 {1} {2}... 占位符（填充 topic 通配符捕获值） +[workers.config.mqtt_subscribe] +enabled = true +uri = "mqtt://admin:Mixc%402021@dg.datagoo.cn:48081" + + # 边缘应用控制器：请求-响应协议 + # 请求: 发布到 /edge_app_controller，消息 {"command": "query_status", ...} + # 回复: 处理结果发布到 /edge_app_controller_reply，统一封装 {"code": 0, "msg": "ok", "data": {...}} + [[workers.config.mqtt_subscribe.topics]] + topic = "/edge_app_controller" # 订阅主题（外部请求） + handler = "edge_app_controller" # 处理函数（按 command 分发） + reply_topic = "/edge_app_controller_reply" # 回复主题 + +# ====== 内部 MQTT 请求-响应客户端 ====== +# 供外部订阅 handler 内部对任意应用进程发起请求-响应（主题显式传入，不依赖 chongming 协议） +# uri: 目标 Broker（默认内部 127.0.0.1:1883；如需连外部可改为外部地址） +# 使用示例（handler 内）: +# resp = await internal_mqtt.request( +# request_topic="/other_app/request", # 目标应用监听的请求主题 +# response_topic="/other_app/reply/#", # 目标应用回复的主题（支持 +/# 或 {rid} 模板） +# payload={"BoardId": ...}, +# timeout=30, +# ) +[workers.config.internal_mqtt] +enabled = false +uri = "mqtt://127.0.0.1:1883" + [workers.config.alarm_retention] max_records = 100 # 最多保留的告警记录数，设为 0 表示不限制