Python中Flask怎么利用多线程并发处理外部第三方API请求-Python教程-PHP中文网

flask视图中不能直接串行调用requests，因会阻塞主线程导致响应延迟、超时和500错误；应使用全局threadpoolexecutor并发发起http请求，并显式配置超时、异常处理及密钥管理。

python中flask怎么利用多线程并发处理外部第三方api请求

Flask 本身是同步框架，不能原生并发执行耗时的第三方 API 请求；直接在视图里用 requests.get() 串行调用，会卡住整个 worker。必须靠线程池把阻塞 I/O 拆出去跑，才能真正释放主线程、提升吞吐。

为什么不能直接在 Flask 视图里用 requests 发起多个请求

Flask 的默认开发服务器（Werkzeug）虽支持 threaded=True，但那只是让「多个 HTTP 请求能被不同线程同时接收和分发」，不是让你在单个视图函数里并发发起外部调用。一旦你在视图中写：

resp1 = requests.get("https://api.a.com/data")
resp2 = requests.get("https://api.b.com/data")

这两行仍是顺序执行：第二行必须等第一行 DNS、连接、响应全部完成才开始。网络慢或对方挂了，整个请求就卡死，还可能拖垮所有其他请求。

常见错误现象包括：

接口响应时间从几百毫秒飙升到几十秒，且波动极大
日志里反复出现 ConnectionError 或 Timeout，但没被捕获，导致 500 错误暴露堆栈
高并发下 CPU 占用不高，但请求数一上去就大量超时或排队

用 ThreadPoolExecutor 管理并发 HTTP 请求

这是 Python 标准库中最稳、最易控的方式。它不依赖协程、不改 Flask 架构，只把阻塞操作挪到后台线程池执行，主线程专注收发 HTTP。

关键点：

python全能编程助手

SkillSub Pro - Python 题解与代码注释双功能技能功能概述SkillSub Pro - Python 题解与代码注释双功能技能是一项面向实际任务的技能，主要用于SkillSub Pro 是一个 Python 题解生成与代码注释的双功能合体技能，专为学生、算法学习者和开发者设计；✅ 一个技能，两种用途：；核心要点📝 题解模式：输入题目/题号，自动生成完整 Python 题解（含详细注释、解题思路、复杂度分析）；💬 注释模式：输入 Python 代码，自动添加详细中。它将相关步骤、

下载

线程池要定义在全局或应用生命周期内（比如 app.config 或模块级变量），避免每次请求都新建，否则开销反超收益
max_workers 不宜过大（通常 3–10），HTTP 请求本质是 I/O 密集，不是 CPU 密集，线程太多反而增加调度开销和连接竞争
每个子任务函数必须自己处理异常和超时，不能指望主线程兜底

示例：

from concurrent.futures import ThreadPoolExecutor
import requests
<p>executor = ThreadPoolExecutor(max_workers=5)</p><p>def fetch_one(url, headers=None):
try:
resp = requests.get(url, timeout=(3, 10), headers=headers)
resp.raise_for_status()
return resp.json()
except requests.exceptions.RequestException as e:
return {"error": str(e), "url": url}</p><p>@app.route("/aggregate")
def aggregate():
urls = [
"<a href="https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c">https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c</a>",
"<a href="https://www.php.cn/link/ef246753a70fce661e16668898810624">https://www.php.cn/link/ef246753a70fce661e16668898810624</a>",
"<a href="https://www.php.cn/link/c2148796071914983ed6b6e9dbbff735">https://www.php.cn/link/c2148796071914983ed6b6e9dbbff735</a>"
]
futures = [executor.submit(fetch_one, u) for u in urls]
results = [f.result() for f in futures]  # 阻塞等待全部完成
return {"results": results}
</p>

超时、异常、密钥管理必须显式控制

第三方 API 不可靠是常态，不设限等于给服务埋雷。

timeout=(3, 10) 必须拆成连接超时 + 读取超时，只写 timeout=10 在 DNS 失败时仍会卡满 10 秒
必须单独捕获 requests.exceptions.Timeout、ConnectionError、SSLError、HTTPError，不能只 except Exception
API Key、token 一律从环境变量读取：os.getenv("API_KEY")，绝不能硬编码进源码
如果第三方要求带 Authorization 或 Content-Type，必须通过 headers 参数传，且确保每个线程调用都携带完整上下文