比如L站邮箱注册L站 三级之后注册邮箱再注册L站…

try:
        response = requests.post(
            url, headers=headers, json=data, stream=True)

        # 检查Dify平台的响应状态
        if response.status_code != 200:
            raise HTTPException(
                status_code=response.status_code, detail="Dify API request failed")

        # 定义生成器函数，用于逐步转发Dify的流式响应
        def generate():
            for chunk in response.iter_content(chunk_size=None):
                if chunk:
                    yield chunk

        # 使用StreamingResponse实现流式转发
        return StreamingResponse(
            generate(),
            media_type=response.headers.get(
                "Content-Type", "application/json")
        )
    except Exception as e:
        raise HTTPException(status_code=500, detail=str(e))

# 为什么不能使用httpx？出现问题：连接建立后立即断开！
    async with httpx.AsyncClient(timeout=httpx.Timeout(None)) as client:
        try:
            async with client.stream("POST", url, headers=headers, json=data) as response:
                if response.status_code != 200:
                    # 读取流式响应的内容
                    error_content = await response.aread()
                    try:
                        error_detail = json.loads(error_content)
                    except json.JSONDecodeError:
                        error_detail = error_content.decode("utf-8")
                    raise httpx.HTTPStatusError(
                        f"HTTP错误: {response.status_code}, 详情: {error_detail}",
                        request=None,
                        response=response,
                    )

                async def stream_response():
                    try:
                        async for chunk in response.aiter_bytes():
                            yield chunk
                    except httpx.StreamClosed:
                        logger.warning("Stream closed by server or client")
                return StreamingResponse(stream_response(), media_type=response.headers.get(
                    "Content-Type", "application/json"))
        except httpx.TimeoutException:
            logger.error("请求超时")
            return HTTPException(status_code=504, detail="请求超时")
        except httpx.HTTPStatusError as exc:
            logger.error(f"HTTP错误: {exc.response.status_code}")
            raise HTTPException(
                status_code=exc.response.status_code, detail=error_detail)