使用Python httpx-sse实现Server-sent events异步调用遇阻求助

核心问题定位 #

既然httpx-sse同步客户端正常、非SSE异步接口正常、sseclient也能获取事件，说明问题出在异步API的调用方式上，而非服务端或基础配置。以下是具体修复步骤：

1. 使用httpx-sse专属异步连接方法 #

不要用普通的client.get()发起异步请求，必须使用httpx_sse.connect_async()来建立SSE流连接，这是异步模式下正确的初始化方式：

import asyncio
import httpx
from httpx_sse import connect_async

async def fetch_sse():
    # 初始化异步客户端（保持你的原有配置）
    async with httpx.AsyncClient(
        base_url="https://example.com/v2api",
        headers={"api-key": "你的API密钥"},
        timeout=None  # SSE需要禁用超时
    ) as client:
        # 用connect_async建立SSE连接
        async with connect_async(
            client,
            "/data/sse",
            params={"layerList": "你的参数值"}
        ) as event_source:
            # 用aiter_sse()异步迭代事件
            async for event in event_source.aiter_sse():
                # 过滤空数据事件（部分SSE服务会发送心跳空事件）
                if event.data:
                    print(f"收到SSE事件: {event.data}")

# 启动异步任务
asyncio.run(fetch_sse())

2. 排查异步上下文问题 #

• 确保代码在异步事件循环中执行：比如用asyncio.run()、在FastAPI/Starlette等异步框架的路由函数中调用，不要在同步函数里直接调用异步方法。
• 检查是否有未处理的异常：可以在代码中添加try-except捕获错误，比如：

async for event in event_source.aiter_sse():
    try:
        if event.data:
            print(event.data)
    except Exception as e:
        print(f"SSE处理错误: {e}")

3. 验证连接状态与响应头 #

在建立连接后，先打印响应头确认SSE连接是否正确建立：

async with connect_async(...) as event_source:
    print("响应头:", event_source.response.headers)
    # 确认Content-Type为text/event-stream
    assert event_source.response.headers.get("Content-Type") == "text/event-stream"
    async for event in event_source.aiter_sse():
        ...

如果Content-Type不对，说明服务端没有正确识别异步请求的SSE格式，可能需要显式设置Accept头：

async with connect_async(
    client,
    "/data/sse",
    params={"layerList": "你的参数值"},
    headers={"Accept": "text/event-stream"}
) as event_source:
    ...

4. 强制使用HTTP/1.1 #

httpx异步客户端默认可能启用HTTP/2，如果服务端对HTTP/2的SSE支持有问题，可以强制回退到HTTP/1.1：

async with httpx.AsyncClient(
    base_url="https://example.com/v2api",
    headers={"api-key": "你的API密钥"},
    timeout=None,
    http2=False  # 禁用HTTP/2
) as client:
    ...

内容的提问来源于stack exchange，提问作者rbaleksandar