diff --git a/config.toml b/config.toml index ff76a9f..fef0ed3 100644 --- a/config.toml +++ b/config.toml @@ -84,6 +84,10 @@ base = [ "chongming_config", "chongming_password", "chongming_stream_manager", + "chongming_mqtt", + "chongming_mqtt.mqtt_forward", + "chongming_mqtt.mqtt_subscribe", + "chongming_mqtt.internal_mqtt", "aiosqlite", "aiofiles.os", "sqlmodel", diff --git a/public/config.toml b/public/config.toml index b0641c5..b7fb129 100644 --- a/public/config.toml +++ b/public/config.toml @@ -48,6 +48,20 @@ allow_headers = ["*"] allow_methods = ["*"] allow_origins = ["*"] +[production.mqtt] +enabled = true +host = "0.0.0.0" +port = 1883 + +# MQTT Bridge 额外订阅主题推荐声明在各插件自己的配置里: +# config/workers//config.toml → [[workers.mqtt_topics]] +# (如 aibox_sophon_adapter 插件的 /board_ping 心跳主题) +# 全局 [.mqtt].custom_topics 仍可作为通用兜底(可选,不推荐)。 + +[production.mqtt.broker] +# amqtt Broker 可选配置,默认允许匿名连接 +# 详细参数参考: https://github.com/Yakifo/amqtt + [production.module_system] path = [ "resources/app.mbank", diff --git a/pyproject.toml b/pyproject.toml index 233b7e8..e1e6abb 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -29,6 +29,7 @@ dependencies = [ "bytedance", "chongming_stream_manager", "uvloop>=0.22.1", + "chongming-mqtt", ] description = "基于 modules-bank 的 fastapi 打包脚手架" name = "chongming-zenoh" @@ -59,6 +60,7 @@ chongming-worker = { git = "http://124.71.68.6:3000/chongming/chongming-utils-wo bytedance = { git = "http://124.71.68.6:3000/chongming/bytedance.git" } chongming-stream-manager = { git = "http://124.71.68.6:3000/chongming/chongming-stream-manager.git" } chongming-database = { git = "http://124.71.68.6:3000/chongming/chongming-utils-database.git" } +chongming-mqtt = { git = "http://124.71.68.6:3000/chongming/chongming-mqtt.git" } [project.scripts] build = "chongming.scripts.build:build" diff --git a/uv.lock b/uv.lock index 4e4ef6f..725a57a 100644 --- a/uv.lock +++ b/uv.lock @@ -290,6 +290,14 @@ name = "chongming-jwt" version = "0.1.0" source = { git = "http://124.71.68.6:3000/chongming/chongming-utils-jwt.git#09489e74e6140859e7bbe5bd09343fbe5faf8a9a" } +[[package]] +name = "chongming-mqtt" +version = "0.1.0" +source = { git = "http://124.71.68.6:3000/chongming/chongming-mqtt.git#5ca88d4de88a1f7ee79d881653801a0f32513c96" } +dependencies = [ + { name = "amqtt" }, +] + [[package]] name = "chongming-password" version = "0.1.0" @@ -329,6 +337,7 @@ dependencies = [ { name = "chongming-config" }, { name = "chongming-database" }, { name = "chongming-jwt" }, + { name = "chongming-mqtt" }, { name = "chongming-password" }, { name = "chongming-request" }, { name = "chongming-stream-manager" }, @@ -366,6 +375,7 @@ requires-dist = [ { name = "chongming-config", git = "http://124.71.68.6:3000/chongming/chongming-utils-config.git" }, { name = "chongming-database", git = "http://124.71.68.6:3000/chongming/chongming-utils-database.git" }, { name = "chongming-jwt", git = "http://124.71.68.6:3000/chongming/chongming-utils-jwt.git" }, + { name = "chongming-mqtt", git = "http://124.71.68.6:3000/chongming/chongming-mqtt.git" }, { name = "chongming-password", git = "http://124.71.68.6:3000/chongming/chongming-utils-password.git" }, { name = "chongming-request", git = "http://124.71.68.6:3000/chongming/chongming-utils-request.git" }, { name = "chongming-stream-manager", git = "http://124.71.68.6:3000/chongming/chongming-stream-manager.git" },