multi_tenant.py:app.py 的并发/多租户版,用 /api/v1/auth/register 并发创建多个租户(各自独立 workspace + Session),同时跑 N 轮链式 对话,校验真并发、多轮上下文按 thread 各自保持、租户隔离 (search 仅见己有线程 + 跨租户 GET 404)。轮数/租户数可配 (DF_TURNS / DF_TENANTS),唯一邮箱可重复跑且不触发限流。 Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
apps/ — 基于 DeerFlow 的应用
这个目录用于存放消费 DeerFlow 智能体能力的上层应用。每个应用一个子文件夹。
为什么放在这里
DeerFlow 的代码有一条严格的依赖方向(见根 CLAUDE.md):
backend/packages/harness/deerflow/ ← 可发布的 Agent 框架(deerflow.*)
backend/app/ ← Gateway / IM 通道(app.*)
apps/ ← 你的应用(消费 deerflow,不反向依赖) ← 本目录
规则:app 可以依赖 deerflow,deerflow 不能依赖 app / apps。本目录放在 backend/ 之外、与 frontend/ 平级,天然符合这条边界。
两种集成模式
| 模式 | 适用场景 | 怎么连 | 示例 |
|---|---|---|---|
| HTTP Gateway(REST+SSE) | 上层是别的服务 / 多语言 | 调 http://localhost:2026/api/* |
examples/http-chat/ |
| 内嵌 DeerFlowClient | 上层本身是 Python,进程内直接当 SDK 调 | from deerflow.client import DeerFlowClient |
examples/embedded-chat/ |
还有第三种:LangGraph SDK(
langgraph_sdk.get_client(url=".../api"),graph idlead_agent),用于接入 LangGraph 生态工具链。需要的话照 HTTP 示例的鉴权流程拿 cookie 即可。
运行示例(每个示例自带 run.sh)
# ① HTTP 模式:需要先起 Gateway(dev-gateway 或 dev-full 都行)
# run.sh 会自动探测网关地址:优先 :2026,回退 :8001
./apps/examples/http-chat/run.sh
DF_BASE=http://localhost:8001 ./apps/examples/http-chat/run.sh # 也可手动指定
# ② 内嵌模式:不需要起任何服务,run.sh 自动进 backend uv 环境运行
./apps/examples/embedded-chat/run.sh
http-chat 的 run.sh 优先用 uv run --no-project --with requests(临时环境,不污染系统),没有 uv 才回退到本地 .venv + pip;可用 DF_BASE / DF_EMAIL / DF_PASSWORD 覆盖。embedded-chat 的 run.sh 自动定位 backend/、加载 .env 后用 uv run 启动,依赖 config.yaml 里有可用模型。
多租户并发验证(HTTP 模式)
examples/http-chat/multi_tenant.py 是 app.py 的并发 / 多租户版:用 /api/v1/auth/register 并发创建多个租户(每个注册用户自带独立 workspace),各自一个 requests.Session(独立 cookie)同时跑 N 轮链式对话,并校验:① 真并发(对话时间窗重叠);② 多轮上下文按 thread_id 各自保持(第 2 轮起每轮都依赖上一轮结果);③ 租户隔离(POST /api/threads/search 仅见己有线程,跨租户 GET /api/threads/{id} 返回 404)。
# 前提:已起 Gateway(dev-gateway 或 dev-full)
DF_BASE=http://localhost:8001 DF_TENANTS=4 DF_TURNS=10 \
uv run --no-project --with requests python apps/examples/http-chat/multi_tenant.py
环境变量:DF_BASE(网关地址,默认 :8001)、DF_TENANTS(并发租户数,默认 3)、DF_TURNS(每租户轮数,默认 10)。每次运行用唯一邮箱新建租户,可重复跑,不撞 email、也不触发登录限流(/register 不限流;setup-status 全程只调一次以避开 60s/IP 限流)。
前置:先把 DeerFlow 跑起来
在仓库根目录:
make dev # 起 Gateway(8001) + 前端(3000) + nginx(2026),统一入口 http://localhost:2026
确保 config.yaml 里至少配了一个可用模型 + API key。
本地调试脚本(推荐)
make dev 是前台阻塞运行。日常调试更顺手的是仓库根 scripts/ 下两个生命周期脚本,子命令统一为 start / stop / restart / status / logs / run:
| 脚本 | 起什么 | 入口 | 适合 |
|---|---|---|---|
scripts/dev-gateway.sh |
只起 Gateway | http://localhost:8001 |
调后端 API / 接入示例,起得快 |
scripts/dev-full.sh |
Gateway + 前端 + nginx | http://localhost:2026 |
连前端一起调,完整体验 |
./scripts/dev-gateway.sh start # 后台启动,等就绪后返回
./scripts/dev-gateway.sh status # PID / 端口 / HTTP 健康检查
./scripts/dev-gateway.sh logs # tail -f 跟随日志(不影响服务)
./scripts/dev-gateway.sh stop
./scripts/dev-full.sh start # 全量栈后台启动(首次装依赖)
SKIP_INSTALL=1 ./scripts/dev-full.sh start # 跳过依赖安装,重启更快
./scripts/dev-full.sh status # 三服务一览
./scripts/dev-full.sh run # 前台运行(= make dev,gateway 带热重载)
环境变量:PORT=(换端口)、NO_RELOAD=1(关热重载,断点更稳)、SKIP_INSTALL=1(全量栈跳过装依赖)。
鉴权(HTTP 模式必读)
Gateway 是 fail-closed 的——除少数公开路径外所有请求都要带会话 cookie:
GET /api/v1/auth/setup-status→ 是否还没管理员- 首次
POST /api/v1/auth/initialize(JSON{email,password})建第一个管理员;之后POST /api/v1/auth/login/local(表单username=邮箱 +password) - 成功后 Session 里有
access_token(HttpOnly) +csrf_token两个 cookie - 所有写请求(POST/PUT/DELETE/PATCH)必须带
X-CSRF-Token头 =csrf_token值
多租户:当前
docs/multi-tenant-redesign分支的 API Key 鉴权中间件尚未接入,外部系统暂时只能走会话 cookie。等Authorization: Bearer dfk_live_...落地后再补无人值守接入。每个注册用户即一个独立租户(自带 workspace);并发与隔离行为可用上面的multi_tenant.py验证。
新建一个应用
mkdir apps/my-app
# 放你的代码;HTTP 模式参照 examples/http-chat,内嵌模式参照 examples/embedded-chat