modify: mqtt

This commit is contained in:
2026-07-27 14:25:29 +08:00
parent 3ee018e3dd
commit edf777fcaa
13 changed files with 207 additions and 459 deletions
+7 -9
View File
@@ -17,7 +17,7 @@
- **自动化模型生成**:`gen_models` 脚本根据 TOML 配置生成请求/响应 Pydantic 模型(含 MQTT)
- **JWT 鉴权**:Rust 实现,路由级别 `auth_required` 控制
- **Argon2id 密码哈希**:Rust 实现的高性能密码安全方案
- **对象存储代理**:集成 nanio(S3 兼容)文件上传/下载
- **文件存储**:本地文件系统上传/下载
- **构建打包**:支持 PyInstaller / Nuitka 一键打包为独立可执行文件
- **Vue 3 前端**:Element Plus UI、Pinia 状态管理、自动生成类型安全的 API 客户端
@@ -87,7 +87,6 @@ uv run serve # 启动服务(开发模式,热重载)
| ------- | ---------------------------- | ------------------------ |
| HTTP | `http://localhost:8000` | REST API + Swagger 文档 |
| MQTT | `mqtt://localhost:1883` | 内嵌 Broker,Worker 桥接 |
| Nanio | `http://localhost:9000` | S3 兼容对象存储 |
| Swagger | `http://localhost:8000/docs` | OpenAPI 文档 |
### 前端开发
@@ -121,13 +120,12 @@ graph TB
```
uv run serve → FastAPI lifespan:
1. setup_nanio() — 本地 S3 子进程
2. setup_s3() — boto3 S3 客户端
3. setup_zenoh() — Zenoh peer 会话
4. setup_worker_manager() — WorkerManager + liveliness 刷新
5. load_workers() — 动态 import 插件 → 启动 Worker 协程
6. register_routes() — 扫描 config/workers/ 生成 HTTP 路由
7. setup_mqtt() — 内嵌 Broker + MQTT→Worker 桥接
1. setup_storage() — 本地文件系统存储
2. setup_zenoh() — Zenoh peer 会话
3. setup_worker_manager() — WorkerManager + liveliness 刷新
4. load_workers() — 动态 import 插件 → 启动 Worker 协程
5. register_routes() — 扫描 config/workers/ 生成 HTTP 路由
6. setup_mqtt() — 内嵌 Broker + MQTT→Worker 桥接
```
---