Cloud Run容器运行FastAPI并行后台任务时停止处理

问题场景 #

• 本地运行的FastAPI应用通过BackgroundTasks启动后台任务，任务完成后写入Supabase数据库，多任务同时运行正常
• 部署到Cloud Run（配置CPU始终分配、6核6GB内存）后，单个后台任务运行正常，但多任务同时启动时，运行一段时间后所有任务终止，容器关闭且无数据写入数据库
• 资源使用从未超出配置限制，超时设置为3600秒，并发限制调至40（甚至设为1时问题仍存在）
• Cloud Run控制台无后台任务相关日志，但客户端轮询任务状态的请求日志可正常查看

核心原因分析 #

1. Cloud Run容器生命周期与请求绑定 #

Cloud Run容器的存活依赖活跃请求：即使开启了CPU始终分配，当触发后台任务的请求处理完成后，若没有持续的活跃请求（比如轮询间隔过长），容器仍可能被系统回收，导致未完成的后台任务中断。

2. FastAPI后台任务的线程池瓶颈 #

FastAPI默认基于Uvicorn的线程池处理后台任务，默认线程数有限。当后台任务数量超过线程池容量，或任务因阻塞（如数据库连接等待）占用线程时，会导致线程池耗尽，进而影响主请求处理，甚至触发容器健康检查失败。

3. Supabase连接池适配问题 #

本地环境与Cloud Run的网络差异可能引发数据库连接问题：比如Cloud Run动态出站IP被Supabase防火墙限制，或连接池配置过小，多任务同时请求连接导致池耗尽，任务阻塞后触发容器回收。

4. 日志采集配置缺失 #

后台任务的日志未输出到标准输出流（stdout/stderr），或日志配置不正确，导致Cloud Run无法采集到任务相关日志，难以排查问题。

解决方案 #

1. 维持容器活跃状态 #

• 缩短客户端轮询后台任务状态的间隔，确保容器始终有活跃请求；或使用Server-Sent Events（SSE）建立长连接，直到任务完成
• 设置Cloud Run最小实例数为至少1，避免容器被完全回收

2. 优化后台任务的线程/异步配置 #

• 调整Uvicorn启动参数，增加线程池容量，例如：

uvicorn main:app --host 0.0.0.0 --port 8080 --workers 2 --threads 12

• 将同步后台任务改为异步实现，结合asyncio减少线程阻塞：

from fastapi import BackgroundTasks
from supabase import create_client
import asyncio

supabase = create_client(SUPABASE_URL, SUPABASE_KEY)

async def async_task():
    # 异步执行数据库写入
    await supabase.table("task_results").insert({"status": "completed"}).execute()

@app.post("/trigger-task")
async def trigger_task(background_tasks: BackgroundTasks):
    background_tasks.add_task(async_task)
    return {"task_id": "xxx", "status": "started"}

3. 修复Supabase连接配置 #

• 配置Cloud Run VPC连接器固定出站IP，将该IP添加到Supabase防火墙白名单
• 调整Supabase客户端的连接池参数，增加最大连接数：

supabase = create_client(
    SUPABASE_URL,
    SUPABASE_KEY,
    options={"pool_size": 20, "max_overflow": 10}
)

4. 配置正确的日志输出 #

• 使用Python标准logging模块输出日志到标准流，替代print：

import logging

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s | %(levelname)s | %(message)s",
    handlers=[logging.StreamHandler()]
)
logger = logging.getLogger(__name__)

def background_task():
    logger.info("后台任务启动")
    # 任务逻辑
    logger.info("后台任务完成，写入数据库")

• 检查Cloud Run日志过滤规则，确保未排除后台任务的日志条目

5. 添加健康检查端点 #

• 在FastAPI中添加健康检查接口：

@app.get("/health")
def health_check():
    return {"status": "healthy"}

• 在Cloud Run控制台配置健康检查，定期访问/health端点，避免容器因无响应被判定为不健康而关闭

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