Star 历史趋势
数据来源: GitHub API · 生成自 Stargazers.cn
README.md

AI Hunter

面向外贸与 B2B 场景的自动化客户挖掘系统,基于 FastAPI、LangGraph、多 Agent 流水线与可配置多模型能力。

Python FastAPI React LangGraph

AI Hunter 是一个面向外贸与 B2B 线索挖掘场景的开源版项目。你只需要提供公司官网、产品文档或产品关键词,再指定目标市场,系统就会自动完成公司理解、关键词生成、网页搜索、线索提取和联系方式发现。

官方链接

定制化方案:Hermes + Skill

如果你需要更灵活的客户挖掘方案,我们提供基于 Hermes + Skill 的可定制化服务:

  • Hermes Agent 负责判断、策略、查询生成和决策,Python 脚本负责搜索、抓取、去重等确定性操作
  • Skill 插件化:核心能力封装为可复用的 Skill,按需组合,而非固定流水线
  • b2b-lead-hunter Skill:提供完整的 B2B 线索挖掘能力——多通道搜索(有机搜索、B2B 平台、Google Maps、竞品渠道、行业协会)、公司官网深度研读、联系方式提取(邮箱/电话/社媒/决策人)、证据驱动的线索评分与优先级排序、多格式导出(JSONL/CSV)
  • 质量优先:先小规模 Pilot 验证再全量执行,每条线索可溯源、有证据支撑
  • 合规优先:仅采集公开数据,不自动发送邮件,尊重隐私法规

如有定制需求,欢迎通过官网联系我们。

开源仓库范围

这次公开的开源仓库只保留以下内容:

  • backend/:FastAPI + LangGraph 主服务
  • frontend/:React + Vite 前端
  • 必要的配置示例和文档

以下模块不进入公开仓库:

  • license-server/
  • license-server-v2/
  • landing/

当前版本边界

当前开源版已经开放“客户挖掘 + 邮件草稿生成 + 邮件发送配置”主链路,但仍有一些边界:

  • 邮件自动发送建议通过 campaign / scheduler 链路使用,不建议把详情页当成完整营销自动化系统
  • 邮件发送依赖你自己配置 SMTP / IMAP、授权码与安全策略,仓库不会提供任何第三方邮箱账号
  • 非本机访问 API 时,如果没有配置 API_ACCESS_TOKEN,接口默认只允许 localhost 访问

功能特性

  • 多 Agent 流水线:Insight -> KeywordGen -> Search -> LeadExtract -> Evaluate
  • 双模型协作:推理模型负责 ReAct 决策,普通模型负责抽取、生成与改写
  • 输入灵活:支持官网 URL、PDF/Excel/CSV/Word/Markdown/TXT 等文件、或纯关键词
  • 多搜索通道:Google Search、Google Maps、B2B 平台站内搜索
  • 智能抓取:针对官网、B2B 列表页、内容页等不同 URL 自适应抓取策略
  • 联系方式发现:支持提取邮箱、电话、地址、社媒链接等结构化信息
  • AI 邮件生成:可基于 ICP、官网洞察与历史邮件样例生成 3 步开发信序列
  • 邮件预览与审核:支持在详情页预览生成邮件、人工批准/拦截、手动发送与回信检测
  • 邮件自动发送:支持把已批准邮件序列创建为 campaign,并通过 scheduler 持久化发送
  • 实时进度流:FastAPI + SSE 推送任务进展,前端实时展示各阶段状态
  • 成本可观测:接入 Langfuse 后可记录 LLM 调用成本、Token 与延迟
  • 可替换模型:统一通过 LiteLLM 接入 OpenAI、Anthropic、OpenRouter、Groq、GLM、Moonshot、MiniMax
  • 继续挖掘参数可控:支持设置目标线索数、最大轮数、每轮最少新增线索阈值

架构图

flowchart LR
    A[React Frontend\n任务创建 / 列表 / 详情 / SSE] --> B[FastAPI API]
    B --> C[LangGraph Pipeline]
    C --> C1[InsightAgent]
    C --> C2[KeywordGenAgent]
    C --> C3[SearchAgent]
    C --> C4[LeadExtractAgent]
    C --> C5[Evaluate]

    C1 --> D[LiteLLM]
    C2 --> D
    C4 --> D
    D --> D1[MiniMax / OpenAI / Anthropic / OpenRouter / Groq / GLM / Moonshot]

    C3 --> E[Tavily]
    C3 --> F[Serper]
    C4 --> G[Jina Reader]

    B --> H[SQLite / JSON 持久化]
    B --> I[SSE Stream]
    I --> A

工作流

flowchart TD
    A[输入官网 / 上传文档 / 产品关键词] --> B[InsightAgent\n理解公司与产品]
    B --> C[KeywordGenAgent\n生成搜索词]
    C --> D[SearchAgent\n聚合搜索结果]
    D --> E[LeadExtractAgent\n抽取结构化线索]
    E --> F[Evaluate\n判断是否继续]
    F -->|继续| C
    F -->|结束| G[EmailCraft\n可选生成邮件序列]
    G --> H[返回 leads / 邮件 / 成本 / 阶段结果]

当前停止逻辑由以下参数控制:

  • target_lead_count:目标线索总数
  • max_rounds:最多迭代轮数
  • min_new_leads_threshold:单轮最少新增线索数

这个版本已经修正了“目标线索数设为 200 时,系统因隐藏动态阈值而过早停止”的问题。现在会按你显式配置的 min_new_leads_threshold 来判断是否继续。

有界面模式

前端现在也已经对齐到 producer / consumer 思路,不再把“新建任务”当成一个浏览器里直接等待完成的长请求。

当前有界面模式的真实行为是:

  1. 新建任务 页面填写官网、关键词、地区、模板样例等信息
  2. 点击提交后,前端会创建一个 automation job
  3. consumer 领取这个 job 时,会先准备 template_seed
  4. 然后再创建真实 hunt,执行搜索、抽取、评估、邮件生成
  5. hunt 完成后自动创建 campaign,并交给 EmailScheduler 消费发送
  6. 首页和详情页优先展示 job 队列状态,只有在真实 hunt 已创建后,才继续下钻到 hunt 详情

这意味着:

  • 前端负责 提交任务 + 查看队列 + 查看 Hunt / Campaign 状态
  • 后端负责 真正执行 producer / consumer + scheduler
  • 有界面和无界面现在走的是同一套底层任务系统,不再是两套分裂逻辑
  • 队列任务详情页会展示 job 状态 / 尝试次数 / 目标线索数 / 当前线索数 / Hunt 阶段 / 最近错误
  • Dashboard 还会展示 运营摘要卡 + 最近发现企业 / 最近发送邮件 / 最近回复 事件流
  • 继续挖掘不再直接调用旧的同步 resume,而是基于当前 hunt 创建新的后续 queue job

邮件能力

当前版本的邮件链路分成 3 层:

  1. 可以先基于官网洞察与历史模板样例预生成一版 template seed
  2. 线索挖掘完成后,可选开启 AI 邮件生成
  3. 在任务详情页中预览、审核、手动发送、手动查回信
  4. 把已批准的邮件序列创建为 campaign,再进入自动发送 / 自动回信检测

邮件生成

  • 新建任务或继续挖掘时可以开启 AI 邮件生成
  • 也可以先调用 POST /api/v1/email-template-seeds/prepare 预生成模板种子,再把 template_seed 带进 hunt
  • 可以不提供模板,系统会自动生成模板策略和 3 步英文开发信
  • 也可以提供历史邮件样例与备注,系统会先提取你的风格再生成
  • 如果请求里已经带了 template_seed,邮件生成会优先复用这份种子,只对具体 lead 做轻量个性化,而不是每次从零起草模板策略
  • 生成结果会包含:
    • template_seed
    • template_profile
    • template_plan
    • validation_summary
    • review_summary

邮件预览与审核

  • 任务详情页支持预览每一组邮件序列
  • 可查看主题、正文、模板来源、生成模式、验证状态、review 问题、模板表现
  • 可人工:
    • 批准草稿
    • 拦截草稿
    • 手动发送单封邮件
    • 手动检查回信

自动发送与 campaign

  • 自动发送不再依赖任务详情页里的临时内存队列
  • 正确做法是:
    1. 先完成邮件生成
    2. 只把已批准 / 可发送的序列创建为 campaign
    3. 启动 campaign
    4. 由后端 scheduler 持久化发送

SMTP / IMAP 与授权码

邮件发送前,需要在前端 Settings 页面或 backend/.env 中配置邮箱参数。

如果你希望直接在浏览器里保存这些配置,需要先开启:

  • SETTINGS_API_ENABLED=true

最少需要准备:

  • EMAIL_FROM_ADDRESS
  • EMAIL_SMTP_HOST
  • EMAIL_SMTP_PORT
  • EMAIL_SMTP_USERNAME
  • EMAIL_SMTP_PASSWORD

如果要自动检测回信,还需要:

  • EMAIL_IMAP_HOST
  • EMAIL_IMAP_PORT
  • EMAIL_IMAP_USERNAME
  • EMAIL_IMAP_PASSWORD

注意:

  • 很多邮箱服务商不允许直接使用登录密码,而是需要在邮箱后台开启 IMAP / SMTP
  • 通常还要生成 应用密码客户端授权码第三方客户端授权码
  • 必须先在 Settings 页面测试 SMTP / IMAP 连接成功,系统才允许开启自动发送和自动回信检测
  • 当前设置页已内置常见国内邮箱服务商模板,包括:
    • QQ 邮箱
    • 腾讯企业邮箱
    • 网易 163 / 126
    • 网易企业邮箱
    • 阿里云企业邮箱
    • 手动填写

项目结构

AI_Find_Customer/
├── backend/                # FastAPI + LangGraph 主服务
│   ├── agents/             # 各类 Agent
│   ├── api/                # 路由、SSE、持久化接口
│   ├── config/             # 配置读取
│   ├── graph/              # StateGraph 与流程控制
│   ├── tools/              # 搜索、抓取、LLM、解析工具
│   ├── observability/      # Langfuse 等观测能力
│   └── tests/              # pytest 测试
├── frontend/               # React 前端
├── README.md
└── .gitignore

环境要求

  • Python 3.11+
  • Node.js 18+ 或 Bun
  • 至少一个 LLM API Key
  • 至少一个搜索 API Key

快速开始

1. 克隆仓库

git clone https://github.com/xiongQvQ/AI_Find_Customer.git
cd AI_Find_Customer

2. 启动后端

cd backend
python3 -m venv .venv
source .venv/bin/activate
pip install --upgrade pip
pip install -r requirements.txt
cp .env.example .env
uvicorn api.app:app --host 127.0.0.1 --port 8000

后端默认地址:

  • API:http://127.0.0.1:8000
  • Swagger:http://127.0.0.1:8000/docs

3. 启动前端

cd frontend
bun install
bun run dev

前端默认地址:

  • http://localhost:3000

配置文件放哪里

所有运行时密钥与邮件参数都放在 backend/.env,也可以通过前端 Settings 页面保存。

正确做法:

  1. 复制 backend/.env.examplebackend/.env
  2. backend/.env 内填写模型、搜索、邮件相关配置
  3. 不要把密钥写进前端代码
  4. 如果要使用前端 Settings 页面在线保存,请在 .env 中额外设置 SETTINGS_API_ENABLED=true
  5. 前端 Settings 页面保存的内容会写回后端 .env

常见邮件相关变量示例:

EMAIL_FROM_NAME=Your Company
EMAIL_FROM_ADDRESS=sales@example.com
EMAIL_REPLY_TO=sales@example.com
EMAIL_SMTP_HOST=smtp.exmail.qq.com
EMAIL_SMTP_PORT=465
EMAIL_SMTP_USERNAME=sales@example.com
EMAIL_SMTP_PASSWORD=your-app-password
EMAIL_IMAP_HOST=imap.exmail.qq.com
EMAIL_IMAP_PORT=993
EMAIL_IMAP_USERNAME=sales@example.com
EMAIL_IMAP_PASSWORD=your-app-password
EMAIL_USE_TLS=true
EMAIL_AUTO_SEND_ENABLED=false
EMAIL_REPLY_DETECTION_ENABLED=false
EMAIL_LLM_MODEL=minimax/MiniMax-M2.1-highspeed
EMAIL_REASONING_MODEL=minimax/MiniMax-M2.5
EMAIL_LLM_REQUESTS_PER_MINUTE=60
EMAIL_REASONING_REQUESTS_PER_MINUTE=30
EMAIL_REQUIRE_APPROVAL_BEFORE_SEND=true
EMAIL_OPENAI_API_KEY=
EMAIL_ANTHROPIC_API_KEY=
EMAIL_OPENROUTER_API_KEY=
EMAIL_GROQ_API_KEY=
EMAIL_ZAI_API_KEY=
EMAIL_MOONSHOT_API_KEY=
EMAIL_MINIMAX_API_KEY=

如果你担心 MiniMax 的 RPM 被搜索主链路和邮件链路一起打满,建议单独配置:

  • EMAIL_LLM_MODEL
  • EMAIL_REASONING_MODEL
  • EMAIL_LLM_REQUESTS_PER_MINUTE
  • EMAIL_REASONING_REQUESTS_PER_MINUTE

这样邮件生成、自动修复、邮件 ReAct 会走单独模型和单独限速,不会和主流程抢同一个默认模型额度。

如果你希望邮件链路连 API Key 都彻底独立,还可以额外配置:

  • EMAIL_OPENAI_API_KEY
  • EMAIL_ANTHROPIC_API_KEY
  • EMAIL_OPENROUTER_API_KEY
  • EMAIL_GROQ_API_KEY
  • EMAIL_ZAI_API_KEY
  • EMAIL_MOONSHOT_API_KEY
  • EMAIL_MINIMAX_API_KEY

设置后,邮件链路会优先使用这些专用 Key;留空时才回退到主链路的 Key。

邮件发送与模板轮换的当前行为:

  • 如果没有配置 EMAIL_* 专用模型、RPM、API Key,邮件链路会自动回退到主链路配置
  • campaign 入队时会把同一企业下发现的多个唯一企业邮箱都展开成独立发送序列,而不是只保留一个 target_email
  • 真正的频控仍由 EmailScheduler 统一执行,受 EMAIL_DAILY_SEND_LIMITEMAIL_HOURLY_SEND_LIMIT 约束
  • 同一模板分组默认每发送满 100 个收件目标就自动起下一版模板种子,避免一套文案长时间不变

支持的输入与上传限制

支持输入:

  • 官网 URL
  • 产品关键词
  • 目标客户画像
  • 目标地区
  • 上传文件作为补充语料

当前后端允许上传的文件类型:

  • .txt
  • .md
  • .pdf
  • .docx
  • .doc
  • .xlsx
  • .xls
  • .csv
  • .json

默认单文件大小限制:

  • 50 MB

推荐默认模型

推荐优先使用 MiniMax,因为当前代码里已经完整支持:

  • MINIMAX_API_KEY
  • MINIMAX_API_BASE
  • LiteLLM provider 适配
  • reasoning_modelllm_model 分开配置

推荐起步配置:

LLM_MODEL=minimax/MiniMax-M2.1-highspeed
REASONING_MODEL=minimax/MiniMax-M2.5
MINIMAX_API_KEY=your-minimax-key
MINIMAX_API_BASE=https://api.minimax.io/v1

如果你要长期跑无界面自动外呼,推荐把邮件链路单独拆出去,例如:

LLM_MODEL=minimax/MiniMax-M2.1-highspeed
REASONING_MODEL=minimax/MiniMax-M2.5
EMAIL_LLM_MODEL=openrouter/google/gemini-flash-1.5
EMAIL_REASONING_MODEL=openrouter/deepseek/deepseek-r1

这样主链路继续跑 MiniMax,邮件生成和修复走另一套模型,不会互相卡 RPM。

MINIMAX_API_BASE 说明:

  • 国际站默认:https://api.minimax.io/v1
  • 中国大陆可选:https://api.minimaxi.com/v1
  • 如果你不确定,先使用 https://api.minimax.io/v1

无界面部署到 VPS

如果你不需要前端界面,只想在 VPS 上持续执行“模板准备 -> 挖掘 -> 生成邮件 -> 自动发送”,现在有两种模式:

  • 简单模式:headless_worker.py 适合单机串行跑,一轮 hunt 完成后再开始下一轮
  • 队列模式:hunt_queue.py producer + api.app 内嵌 consumer 适合当前默认的生产者-消费者结构

如果你要真正的生产者-消费者,当前推荐拆成两个常驻进程:

  • API 服务:负责 hunt、内嵌 consumer、template seed prewarm、campaign API、发送 scheduler、回信检测
  • Producer 服务:持续往 hunt_jobs 队列写入新的挖掘任务

这套结构本质上就是两层生产者-消费者:

  • 第一层生产者:backend/scripts/hunt_queue.py producer
  • 第一层消费者:api.app 内嵌 AutomationConsumer
  • 模板预热:api.app 内嵌 TemplateSeedWorker
  • 第二层消费者:api.app 内置的 EmailScheduler

当前真实逻辑再具体一点:

  1. hunt_queue.py producer 把 hunt payload 持久化写入 SQLite 的 hunt_jobs
  2. TemplateSeedWorker 先为 queued job 预热 template_seed
  3. AutomationConsumer 领取 job,直接在进程内创建真实 hunt
  4. consumer 轮询这个 hunt,直到状态变成 completed
  5. hunt 完成后,如果开启了邮件生成,consumer 会自动创建并启动 campaign
  6. campaign 创建时,会把可发送的邮件序列写进 SQLite:
    • lead_email_sequences
    • email_messages
  7. EmailScheduler 后台循环每 60 秒扫描一次 email_messages 里的 pending 记录
  8. 到时间的邮件会被发送,发送后更新状态为 sent / failed
  9. EmailReply 后台循环按配置间隔扫描 IMAP 回信,命中后会停掉后续跟进

几个关键实现细节:

  • lead_extract 会先按官网域名去重,再做深度抓取,避免同一家公司被多个官网 URL 重复送进 LLM
  • template_seed 负责把“模板策略生成”和“线索挖掘”解耦,所以 producer / consumer 不需要等整批 lead 全部完成后再决定模板方向
  • email_messages 是真正的持久化发送队列,适合 producer / consumer 长期运行
  • 如果一个 lead 抽到了多个企业邮箱,campaign 会为每个唯一邮箱建立独立 sequence 和 message 队列项
  • 模板不会无限复用同一个 seed;超过模板发送上限后会自动生成新版本继续跑

也就是说,现在已经是两层持久化队列:

  • 第一层队列:hunt_jobs 负责“待执行的客户挖掘任务”
  • 第二层队列:email_messages 负责“待发送的邮件消息”

当前两层队列都不是 Redis / MQ,而是 SQLite 持久化队列:

  • hunt_jobs
    • 入队:producer 创建 job
    • 出队:consumer claim 一个 queued job
    • 结果:completed / failed / requeued
  • email_messages
    • 入队:创建 campaign 时写入待发送消息
    • 出队:scheduler 轮询 pending + scheduled_at <= now
    • 结果:sent / failed / cancelled

自动任务配置

cd backend
cp automation_job.example.json automation_job.json

然后编辑 automation_job.json。如果你希望系统长期持续运行,而不是只跑一轮,推荐把单轮任务限制在“尽量挖满一批,但仍然有边界”,例如:

{
  "website_url": "https://www.gdushun.com/",
  "description": "Find electrical distributors, importers and wholesalers who may buy micro switches, rotary switches and anti-dumping switches.",
  "product_keywords": ["micro switch", "rotary switch", "anti-dumping switch"],
  "target_customer_profile": "Electrical distributors, importers and wholesalers",
  "target_regions": ["United States"],
  "target_lead_count": 100,
  "max_rounds": 20,
  "min_new_leads_threshold": 1,
  "enable_email_craft": true,
  "email_template_examples": ["<your sample outreach email>"],
  "email_template_notes": "Keep the tone professional, concise, and suitable for foreign trade cold outreach."
}

这组参数的真实语义是:

  • 单个 hunt 以 100 个 lead 为目标
  • 最多跑 20
  • 只要单轮还能新增 1 个 lead,就继续
  • 但整个系统通过 producer / consumer 持续入队和消费,所以整体不会停

backend/automation_job.example.json 已经按这组推荐值更新,可以直接复制后开始跑持续任务。

不建议把“单个 hunt”做成无限执行;更合理的是“单个 hunt 有边界,但队列系统 7x24 持续运行”。

启动 API

cd backend
source .venv/bin/activate
uvicorn api.app:app --host 0.0.0.0 --port 8000

启动 headless worker

这是兼容保留的串行模式。它仍然可用,但不是当前推荐的长期运行方式。

cd backend
source .venv/bin/activate
python scripts/headless_worker.py \
  --payload-file ./automation_job.json \
  --continuous \
  --auto-start-campaign \
  --cycle-interval-seconds 60 \
  --status-poll-seconds 15

上面这条命令的语义是:

  • 每轮如果开启邮件生成,会先准备一份 template_seed
  • 然后再挖到 target_lead_count
  • 然后自动生成邮件
  • 然后自动建 campaign
  • 然后把邮件写入持久化待发送队列
  • 发送由后台 scheduler 按时间消费

启动推荐的 queue 模式

先准备任务模板:

cd backend
cp automation_job.example.json automation_job.json

启动 producer:

cd backend
source .venv/bin/activate
python scripts/hunt_queue.py producer \
  --payload-file ./automation_job.json \
  --continuous \
  --enqueue-interval-seconds 60 \
  --max-pending-jobs 3

这条命令表示:

  • 每 60 秒检查一次
  • 如果 hunt_jobs 里排队中和执行中的任务少于 3 个,就继续入队

默认情况下,不需要再单独启动 consumer。api.app 已内嵌:

  • AutomationConsumer
  • TemplateSeedWorker
  • EmailScheduler
  • EmailReply

只有当你明确关闭:

AUTOMATION_EMBEDDED_CONSUMER_ENABLED=false

时,才需要单独启动 consumer:

cd backend
source .venv/bin/activate
python scripts/hunt_queue.py consumer \
  --continuous \
  --poll-seconds 15 \
  --retry-delay-seconds 120 \
  --status-poll-seconds 15

这条命令表示:

  • 每 15 秒看一次有没有新的 hunt job
  • 抢到 job 后执行 hunt
  • 失败时 120 秒后自动回到队列
  • hunt 完成后自动建 campaign 并启动

如果你要更强的挖掘吞吐,可以显式关闭 embedded consumer 后,再起多个独立 consumer 进程;否则不要让它和内嵌 consumer 并跑。

状态监控与飞书通知

无界面模式下,建议把监控拆成三层:

  • 实时状态接口
  • 周期汇总
  • 异常告警

当前版本已经新增这些接口:

GET /api/v1/automation/status
GET /api/v1/automation/metrics?hours=24
GET /api/v1/automation/health

它们会返回:

  • hunt_jobs 队列积压
  • 当前运行中的 hunt 数
  • email_messages 待发送 / 已发送 / 失败数量
  • 最近窗口新增企业数
  • 生成邮件序列数
  • 发送成功 / 失败 / 回复数
  • 最近失败示例

如果你想接飞书机器人,新增这些配置:

AUTOMATION_FEISHU_WEBHOOK_URL=https://open.feishu.cn/open-apis/bot/v2/hook/xxx
AUTOMATION_EVENT_NOTIFICATIONS_ENABLED=true
AUTOMATION_DISCOVERY_BATCH_SIZE=5
AUTOMATION_SEND_BATCH_SIZE=10
AUTOMATION_EVENT_FLUSH_INTERVAL_SECONDS=600
AUTOMATION_SUMMARY_ENABLED=true
AUTOMATION_SUMMARY_INTERVAL_SECONDS=7200
AUTOMATION_ALERTS_ENABLED=true
AUTOMATION_ALERT_INTERVAL_SECONDS=1800
AUTOMATION_ALERT_BACKLOG_THRESHOLD=20
AUTOMATION_ALERT_FAILED_MESSAGES_THRESHOLD=10

含义:

  • AUTOMATION_EVENT_NOTIFICATIONS_ENABLED=true 开启正常业务事件通知
  • AUTOMATION_DISCOVERY_BATCH_SIZE=5 默认每累计 5 家新企业推送一条飞书消息
  • AUTOMATION_SEND_BATCH_SIZE=10 默认每累计 10 封已发送邮件推送一条飞书消息
  • AUTOMATION_EVENT_FLUSH_INTERVAL_SECONDS=600 如果批量阈值一直没凑满,最多每 10 分钟也会冲刷一次事件通知
  • AUTOMATION_SUMMARY_ENABLED=true 每隔一段时间推一次汇总
  • AUTOMATION_SUMMARY_INTERVAL_SECONDS=7200 默认 2 小时推一次
  • AUTOMATION_ALERTS_ENABLED=true 开启基础告警
  • AUTOMATION_ALERT_BACKLOG_THRESHOLD=20 当 hunt 队列或邮件待发积压超过 20 时告警
  • AUTOMATION_ALERT_FAILED_MESSAGES_THRESHOLD=10 当最近窗口失败邮件数超过 10 时告警

当前飞书通知分成 4 类:

  • 任务失败 立即推送;包括创建 hunt 失败、hunt 执行失败、consumer 重试前失败
  • 新增企业 按批推送;默认累计 5 家推一次
  • 邮件已发送 按批推送;默认累计 10 封推一次
  • 周期汇总 定时推送整体运行情况

周期汇总消息会包含:

  • Hunt 已创建 / 成功完成 / Hunt 失败数量
  • 队列重试中 / 当前排队 / 当前运行 / 队列永久失败数量
  • 新增企业数与生成邮件序列数
  • 当前运行中的官网与阶段进度
  • 最近失败 Hunt 的网站、阶段、错误、是否在重试
  • 最近完成的网站、抓到的企业数、生成的邮件序列数
  • 待发送 / 已发送 / 失败 / 回复数
  • “为什么没发邮件”的直接解释
  • 失败原因 Top 与最近失败示例

测试阶段如果你想更快看到飞书消息,可以把这几个值调小:

AUTOMATION_DISCOVERY_BATCH_SIZE=1
AUTOMATION_SEND_BATCH_SIZE=1
AUTOMATION_EVENT_FLUSH_INTERVAL_SECONDS=60
AUTOMATION_SUMMARY_ENABLED=false
AUTOMATION_ALERTS_ENABLED=false

如果你想跳过人工审核,直接放行 needs_review 的邮件序列,可以在 .env 中设置:

EMAIL_REQUIRE_APPROVAL_BEFORE_SEND=false

systemd 常驻

仓库已经提供 systemd 示例文件:

推荐:

  • ai-hunter-api.service
  • ai-hunter-producer.service

ai-hunter-worker.service 是兼容保留的串行 worker 示例,不建议和 embedded consumer 一起长期并跑。

把里面的 /opt/ai-hunter/backend 改成你 VPS 的实际路径后:

sudo cp deploy/systemd/ai-hunter-api.service /etc/systemd/system/
sudo cp deploy/systemd/ai-hunter-producer.service /etc/systemd/system/
sudo systemctl daemon-reload
sudo systemctl enable --now ai-hunter-api
sudo systemctl enable --now ai-hunter-producer

无界面模式测试

本仓库已经补了针对无界面链路的测试。你可以直接执行:

pytest backend/tests/test_automation/test_job_queue.py \
  backend/tests/test_automation/test_metrics.py \
  backend/tests/test_automation/test_notifier.py \
  backend/tests/test_api/test_automation_routes.py \
  backend/tests/test_scripts/test_hunt_queue.py \
pytest backend/tests/test_scripts/test_headless_worker.py \
  backend/tests/test_api/test_email_routes.py \
  backend/tests/test_api/test_routes.py

这组测试覆盖了:

  • hunt_jobs 队列的入队、领取、完成、重试
  • automation status / metrics / health 接口
  • 飞书汇总与告警文案
  • producer 往 hunt 队列持续入任务
  • consumer 从 hunt 队列取任务并执行
  • worker 创建 hunt
  • 轮询 hunt 完成
  • 自动创建并启动 campaign
  • campaign 把邮件写入持久化发送队列
  • 发送资格判断和自动发送入口

API Key 申请入口与填写方式

1. MiniMax

官方入口:

建议流程:

  1. 注册并登录 MiniMax 平台
  2. 进入控制台后创建或查看 API Key
  3. 把 Key 填到 backend/.envMINIMAX_API_KEY
  4. 设置 LLM_MODELREASONING_MODEL

示例:

LLM_MODEL=minimax/MiniMax-M2.1-highspeed
REASONING_MODEL=minimax/MiniMax-M2.5
MINIMAX_API_KEY=your-minimax-key
MINIMAX_API_BASE=https://api.minimax.io/v1

2. Tavily

官方入口:

这个项目支持多个 Tavily Key 直接写到一个环境变量里,后端会按英文逗号拆分并轮询使用。

建议流程:

  1. 注册并登录 Tavily
  2. 在控制台创建 API Key
  3. 至少准备 2-3 个 Key
  4. 直接写进 TAVILY_API_KEY,中间用英文逗号连接,不要加空格

示例:

TAVILY_API_KEY=tvly-dev-xxx,tvly-prod-yyy,tvly-prod-zzz

3. Serper

官方入口:

SERPER_API_KEY 在这个项目里主要承担:

  • Google Search 补充搜索
  • Google Maps 搜索

示例:

SERPER_API_KEY=your-serper-key

4. Jina Reader

官方入口:

JINA_API_KEY 用于网页抓取与正文读取。

示例:

JINA_API_KEY=your-jina-key

5. Langfuse(可选)

官方入口:

如果你想看每次 LLM 调用的 Token、成本、时延,可以开启:

LANGFUSE_ENABLED=true
LANGFUSE_PUBLIC_KEY=your-public-key
LANGFUSE_SECRET_KEY=your-secret-key
LANGFUSE_HOST=https://cloud.langfuse.com

最小可运行配置

LLM_MODEL=minimax/MiniMax-M2.1-highspeed
REASONING_MODEL=minimax/MiniMax-M2.5
MINIMAX_API_KEY=your-minimax-key
MINIMAX_API_BASE=https://api.minimax.io/v1

SERPER_API_KEY=your-serper-key
TAVILY_API_KEY=tvly-key-1,tvly-key-2
JINA_API_KEY=your-jina-key

关键配置项说明

变量名作用默认建议
LLM_MODEL常规抽取/生成模型minimax/MiniMax-M2.1-highspeed
REASONING_MODELReAct 决策模型minimax/MiniMax-M2.5
MINIMAX_API_KEYMiniMax 密钥必填
TAVILY_API_KEY通用网页搜索,支持多个 key建议至少 2 个
SERPER_API_KEYGoogle / Google Maps 搜索建议配置
JINA_API_KEY网页正文抓取建议配置
DEFAULT_TARGET_LEAD_COUNT默认目标线索数200
DEFAULT_MAX_ROUNDS默认最大轮数10
MIN_NEW_LEADS_THRESHOLD每轮最少新增线索阈值5
API_ACCESS_TOKEN非本机访问时的接口令牌生产环境建议设置
SETTINGS_API_ENABLED是否启用前端 Settings 在线保存想用浏览器配置时设为 true

前后端联调说明

  • 前端默认通过 Vite 代理把 /api 转发到 http://localhost:8000
  • 如果后端配置了 API_ACCESS_TOKEN,前端需要额外设置 VITE_API_ACCESS_TOKEN
  • 未配置 API_ACCESS_TOKEN 时,后端只允许 localhost 访问,远程机器访问会返回 403

常用接口

  • POST /api/v1/upload:上传文件
  • POST /api/v1/hunts:创建新的客户挖掘任务
  • GET /api/v1/hunts:获取任务列表
  • GET /api/v1/hunts/{hunt_id}/status:查看任务状态
  • GET /api/v1/hunts/{hunt_id}/result:查看任务结果
  • GET /api/v1/hunts/{hunt_id}/cost:查看成本统计
  • GET /api/v1/hunts/{hunt_id}/stream:SSE 实时进度流
  • POST /api/v1/automation/jobs:创建 queue job
  • GET /api/v1/automation/jobs:查看 queue job 列表
  • GET /api/v1/automation/jobs/{job_id}:查看 queue job 详情
  • POST /api/v1/automation/jobs/from-hunt/{hunt_id}:基于已有 hunt 创建后续 queue job
  • POST /api/v1/automation/jobs/{job_id}/cancel:取消 queue job
  • POST /api/v1/automation/jobs/{job_id}/retry:把失败/完成的 job 重新入队
  • GET /api/v1/health:健康检查

常见问题

1. 为什么我把最大返回线索数设成 200,任务却提前停了?

看三个参数:

  • target_lead_count
  • max_rounds
  • min_new_leads_threshold

当前逻辑会在以下任一条件满足时结束:

  • 已达到目标线索数
  • 已达到最大轮数
  • 单轮新增线索数低于你配置的 min_new_leads_threshold

这个版本已经修正了“隐藏动态阈值导致过早停止”的问题。

2. 为什么前端 Settings 页面保存不了配置?

先检查 backend/.env 里是否开启了:

SETTINGS_API_ENABLED=true

如果这个开关没开,前端设置页可以展示,但后端不会挂载设置保存接口。

3. 为什么我已经配置了 SMTP / IMAP,还是不能自动发送或自动查回信?

因为现在不是“填了参数就算可用”,还要求你在 Settings 页面里先测试连接成功:

  • 自动发送依赖 SMTP 测试成功
  • 自动回信检测依赖 IMAP 测试成功
  • 只生成邮件草稿和预览,不依赖 SMTP / IMAP

常用开发命令

Backend

cd backend
python -m pytest tests/ -q
python -m pytest tests/ --cov=. --cov-report=term-missing
uvicorn api.app:app --reload --port 8000

Frontend

cd frontend
bun install
bun run dev
bun run build

深度检查后补充的文档点

这次按当前代码实现补上了几个以前容易漏掉的关键点:

  • Settings 页面已经是实际配置入口,但需要 SETTINGS_API_ENABLED=true
  • 非 localhost 访问默认需要 API_ACCESS_TOKEN
  • Tavily 支持多 Key 轮询
  • MIN_NEW_LEADS_THRESHOLD 已支持任务级配置
  • 邮件链路已经开放到“生成 / 预览 / 审核 / campaign 自动发送”
  • 自动发送与自动回信检测都要求先完成邮箱测试
  • Langfuse 的接入方式和环境变量说明

适用场景

  • 外贸工厂找海外经销商、批发商、渠道商
  • SaaS 或 B2B 服务公司寻找潜在客户
  • 根据产品资料自动反推目标客户画像与搜索词
  • 针对特定国家或区域进行批量线索挖掘

License

本项目采用 MIT License

关于 About

面向外贸与 B2B 场景的 AI 客户挖掘系统,基于 FastAPI、LangGraph 和 React,实现公司理解、关键词生成、网页搜索、线 索提取与联系方式发现AI-powered B2B lead hunting system built with FastAPI, LangGraph, and React for automated company research, keyword generation, web search, lead extraction, and contact discovery.
aiaitoolsb2bfind-customerllmprompt-engineeringpython

语言 Languages

Python79.3%
TypeScript20.5%
CSS0.1%
JavaScript0.1%
HTML0.0%

提交活跃度 Commit Activity

代码提交热力图
过去 52 周的开发活跃度
51
Total Commits
峰值: 49次/周
Less
More

核心贡献者 Contributors