Behavioral guidelines to reduc…

# requests → httpx 异步迁移指南（12接口版）

一、核心迁移要点

1. 基础替换对照

• import requests → import httpx
• requests.get/post() → await client.get/post()
• requests.Session() → httpx.AsyncClient()
• 函数需改为 async def，调用处加 await

2. 推荐代码结构

```python

import asyncio

import httpx

async def fetch(client: httpx.AsyncClient, url: str):

for attempt in range(3): # 保留重试逻辑

try:

resp = await client.get(url, timeout=10.0)

resp.raise_for_status()

return resp.json()

except (httpx.HTTPStatusError, httpx.RequestError):

if attempt == 2:

raise

await asyncio.sleep(2 ** attempt) # 指数退避

async def main():

async with httpx.AsyncClient(

timeout=httpx.Timeout(10.0, connect=5.0), # 保留超时设置

limits=httpx.Limits(max_connections=20),

) as client:

urls = [...] # 12个接口

results = await asyncio.gather(

*[fetch(client, u) for u in urls]

)

return results

asyncio.run(main())

```

二、关键差异注意点

• 超时：httpx 用 httpx.Timeout(total, connect=...)，默认超时与 requests 不同（httpx 默认 5 秒），务必显式设置还原原行为
• 重试：requests 的 urllib3 Retry 不能直接用；httpx 可配合 tenacity 库或手写循环（如上）
• 并发：12个接口可用 asyncio.gather 并发；如怕限流，用 asyncio.Semaphore 控制并发数
• 响应对象：resp.json()、resp.text、resp.status_code 用法基本一致，resp.content 对应原 resp.content
• headers/params/data：传参方式一致；json= 参数也一致
• 不要混用：一个函数内不能既同步又异步，整个调用链都要异步化

三、迁移后验证清单

1. 对比迁移前后 12 个接口的响应数据是否一致

2. 验证异常场景（断网、502）下重试次数与退避间隔正确

3. 确认超时触发时间与原版接近

4. 检查是否有 Missing greenlet 类报错（说明同步异步混用）

5.