用户上传/输入 Prompt
FastAPI │ ← JWT 认证 + 套餐检查
提交任务到 Celery
Redis │◄────│ Celery Worker │
(消息队列)
漏斗拦截
(并行上限) │
│ │ 2. KeyRouter 轮询 │
│ │ 3. 调用第三方 API │
│ │ 4. 上传到 OSS │
│ │ 5. 回写 DB + 扣费 │
▼ │ 6. 释放漏斗槽位 │
│ PostgreSQL │
│ + Paimon │ ← TTL 定时清理
│ OSS │ ← 按套餐权重 TTL 过期删除
引入 Redis/Celery 等异步任务队列，支持多任务漏斗拦截与并行控制。
实现后端异步状态持久化，支持用户切出网页或锁屏时的断点计费。
严格执行 Excel 配置导入时的数据库表隔离与事务安全，严禁影响核心业务数据。
接入第三方对象存储并实现基于套餐权重的 TTL 定时销毁机制。
使用Docker, 方便部署。
需求 实现
异步任务队列 Celery + Redis，4 个队列（default / image_generation / billing / ttl_cleanup）
漏斗拦截 Redis 计数器 + QueueFunnel，按 user_id:model_name 限制并行
断点计费 HeartbeatLog 每 30s 心跳，超时 120s 自动暂停任务
API 密钥池 加权轮询 + 自动剔除（失败率 >80% / 连续失败 >10 次）+ 定时恢复
Excel 导入 ImportContext 全量校验 → staging 表 → MERGE，任一失败整体回滚
对象存储 TTL S3 元数据标记 ttl_expires_at，Celery Beat 每 5 分钟扫描清理
前端 C 端 暗黑模式，Mobile 单栏 / PC 三栏（队列-生成器-参数）自适应
Admin 端 套餐 CRUD + 密钥池管理 + 导入 Modal
评论