如何用FastAPI流式传输含静态文件与超链接的HTML页面？

如何使用FastAPI流式传输来自其他服务、包含静态文件和超链接的HTML页面？

补充背景 #

微服务架构中常见网关层设计，用于将外部请求转发至各个后端微服务的公开API，架构示意图如下：

=============== Docker Network =============
                            ||                                        ||
                            ||           -------> Backend Service A   ||
                            ||          /                             ||
                            ||         /                              ||
External Request ===> Gateway Service * --------> Backend Service B   ||
                            ||         \                              ||
                            ||          \                             ||
                            ||           -------> Backend Service C   ||
                            ||                                        ||
                            ============================================

针对API场景，FastAPI有一套成熟的转发方案，但该方案在处理包含静态文件和内部超链接的HTML页面时失效——因为后端服务仅在Docker内部网络可达，RedirectResponse无法直接使用，且页面中的静态资源链接、超链接都是内部服务地址，外部请求无法直接访问。

解决方案 #

核心思路是在网关层代理HTML请求的同时，重写页面中所有内部链接和静态资源路径，结合StreamingResponse流式返回处理后的内容，具体实现步骤如下：

1. 流式获取后端服务的HTML响应 #

用HTTP客户端（如httpx）以流式方式向后端内部服务发起请求，逐块读取响应内容：

import httpx
from fastapi import FastAPI
from starlette.responses import StreamingResponse

app = FastAPI()

async def fetch_backend_html():
    async with httpx.AsyncClient() as client:
        # 后端服务的内部访问地址
        backend_html_url = "http://backend-service-b/internal-dashboard"
        # 流式获取响应
        async with client.stream("GET", backend_html_url) as resp:
            async for chunk in resp.aiter_text():
                # 对每块内容执行链接重写
                modified_chunk = rewrite_internal_paths(chunk)
                yield modified_chunk

2. 重写内部链接与静态资源路径 #

编写函数将页面中的内部路径替换为网关的公开访问路径，确保外部请求能通过网关代理到后端：

def rewrite_internal_paths(content: str) -> str:
    # 替换静态资源根路径，比如把"/static/"映射为网关的"/backend-b/static/"
    content = content.replace('/static/', '/backend-b/static/')
    # 替换页面内的超链接，把内部路由映射为网关的代理路由
    content = content.replace('href="/', 'href="/backend-b/')
    # 替换图片、脚本等资源的src属性
    content = content.replace('src="/', 'src="/backend-b/')
    # 可根据实际页面内容补充其他需要替换的属性，如srcset、data-src等
    return content

3. 用StreamingResponse返回处理后的页面 #

在FastAPI路由中返回流式响应，确保大页面也能快速加载：

@app.get("/backend-b/dashboard")
async def serve_backend_dashboard():
    return StreamingResponse(fetch_backend_html(), media_type="text/html")

4. 代理静态资源请求 #

针对重写后的静态资源路径，添加对应的代理路由，确保外部请求能获取到后端的静态文件：

@app.get("/backend-b/static/{path:path}")
async def proxy_static_resources(path: str):
    async with httpx.AsyncClient() as client:
        backend_static_url = f"http://backend-service-b/static/{path}"
        async with client.stream("GET", backend_static_url) as resp:
            return StreamingResponse(
                resp.aiter_raw(),
                media_type=resp.headers.get("content-type", "application/octet-stream")
            )

关键注意事项 #

• 流式处理避免一次性加载大体积页面，提升前端响应速度；
• 链接重写需覆盖页面所有资源引用属性，可根据实际HTML结构调整替换规则；
• 若后端有复杂路由，可使用正则表达式实现更灵活的批量替换；
• 确保网关服务在Docker内部网络中能正常访问所有后端服务。

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