环境:Docker
postgres:16-alpine+asyncpg0.30.0 +SQLAlchemy2.0.42 · Python 3.13
会话、消息、任务、执行步骤、工具调用的数据建模
一次 AI Agent 请求从用户输入到最终返回结果,经历了多个环节。我们要记录的不只是"最终答案",而是整个过程的每一步——谁说了什么、系统做了什么、用了哪些工具、每一步用了多久、失败时是什么原因。
2026/6/25大约 14 分钟
环境:Docker
postgres:16-alpine+asyncpg0.30.0 +SQLAlchemy2.0.42 · Python 3.13
一次 AI Agent 请求从用户输入到最终返回结果,经历了多个环节。我们要记录的不只是"最终答案",而是整个过程的每一步——谁说了什么、系统做了什么、用了哪些工具、每一步用了多久、失败时是什么原因。
环境:Docker
rabbitmq:3-management+aio-pika9.6.2 · Python 3.13
后端收到一个 AI 任务请求(比如代码审查),不能一直阻塞等结果——任务可能跑几分钟。消息队列把"接收请求"和"处理任务"解耦:
HTTP POST /tasks ──→ RabbitMQ ──→ Worker 异步处理
↑ │
立即返回 task_id 更新状态到 Redis/DB