讲师中心 微信公众号
AI工具推荐 视频效率加速

如何在 Uvicorn 多进程部署中确保 FastAPI 的定时任务仅执行一次

冬萱姑娘_6646

冬萱姑娘_6646

发布时间:2026-02-22 10:24:01

|

624人浏览过

|

来源于php中文网

原创

如何在 Uvicorn 多进程部署中确保 FastAPI 的定时任务仅执行一次

本文介绍在 fastapi + uvicorn 多工作进程(workers > 1)部署场景下,避免生命周期(lifespan)中启动的定时任务被重复执行的核心方案:将调度器移至主进程初始化,并选用 backgroundscheduler 替代 asyncioscheduler。

本文介绍在 fastapi + uvicorn 多工作进程(workers > 1)部署场景下,避免生命周期(lifespan)中启动的定时任务被重复执行的核心方案:将调度器移至主进程初始化,并选用 backgroundscheduler 替代 asyncioscheduler。

在使用 Uvicorn 以多进程模式(如 workers=2)运行 FastAPI 应用时,每个工作进程都会独立执行 lifespan 事件——这意味着若在 lifespan 中初始化并启动 AsyncIOScheduler,所有工作进程都会各自运行一套调度器,导致定时任务(如每秒执行一次的 test())被多次并发触发,违背单例预期。

根本原因在于:Uvicorn 的多进程模型采用 fork 派生(Unix)或 spawn 启动(Windows),每个 worker 是完全独立的 Python 进程,拥有各自的事件循环、内存空间和调度器实例。lifespan 在每个 worker 内部被单独调用,因此无法天然实现“仅一个进程执行”的语义。

✅ 正确解法是:将调度器脱离 FastAPI 生命周期管理,提升至主进程(parent process)中初始化和启停。这确保全局仅存在一个调度器实例,且其生命周期与 Uvicorn 主进程对齐。

推荐使用 APScheduler 的 BackgroundScheduler(非异步版),因其基于线程而非事件循环,更适合作为主进程中的后台守护服务:

Uvicorn 0.52.1
Uvicorn 0.52.1

Uvicorn 0.52.1 是 Python ASGI Web 服务器,提供异步应用服务及 WebSocket 支持,常用于 FastAPI、Starlette 等应用的开发和部署。本下载为官方 PyPI 通用 wheel 包,可使用 pip 安装,并由包管理器处理所需依赖。

下载
from fastapi import FastAPI
from datetime import datetime
from apscheduler.schedulers.background import BackgroundScheduler
import uvicorn

def test():
    print(f"Test scheduler {datetime.now()}")

app = FastAPI()

if __name__ == "__main__":
    # ✅ 在主进程(parent)中创建并启动调度器
    scheduler = BackgroundScheduler()
    scheduler.add_job(
        test,
        trigger="cron",
        second="0-30",  # 每分钟第 0–30 秒各触发一次(即每秒一次)
        coalesce=True,   # 防止因延迟导致的任务堆积
        max_instances=1  # 确保同一任务不会并发执行
    )
    scheduler.start()

    # ⚠️ 注意:必须在 uvicorn.run() 之后、程序退出前显式 shutdown
    try:
        uvicorn.run("main:app", workers=2, host="127.0.0.1", port=5000)
    finally:
        scheduler.shutdown(wait=True)  # 安全等待正在运行的任务完成

? 关键要点说明:

  • 不使用 lifespan:避免在每个 worker 中重复初始化调度器;
  • BackgroundScheduler vs AsyncIOScheduler:前者基于 threading.Timer,可安全运行于主线程;后者依赖 asyncio 事件循环,而主进程无活跃 event loop,且多 worker 下仍会重复;
  • coalesce=True 和 max_instances=1:防止因系统负载导致任务堆积或并发执行,强化单次语义;
  • scheduler.shutdown(wait=True):确保应用退出前完成清理,避免僵尸线程或资源泄漏;
  • 信号处理补充(进阶):如需优雅响应 SIGTERM(例如 Docker 停止),可结合 signal 模块注册钩子,但上述 try/finally 已覆盖绝大多数场景。

? 补充建议:若业务逻辑涉及数据库写入、文件操作或外部 API 调用等有状态行为,还需考虑分布式锁(如 Redis Lock)作为兜底方案,但对纯定时触发、无共享状态的轻量任务,主进程单例调度器已足够可靠。

综上,通过将调度器上提至主进程并选用线程安全的 BackgroundScheduler,即可在保持 Uvicorn 多进程高并发能力的同时,严格保障定时任务的全局唯一性与执行确定性。

热门AI工具

更多
SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

2053

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

3194

2023.10.07

Python FastAPI异步API开发_Python怎么用FastAPI构建异步API
Python FastAPI异步API开发_Python怎么用FastAPI构建异步API

Python FastAPI 异步开发利用 async/await 关键字,通过定义异步视图函数、使用异步数据库库 (如 databases)、异步 HTTP 客户端 (如 httpx),并结合后台任务队列(如 Celery)和异步依赖项,实现高效的 I/O 密集型 API,显著提升吞吐量和响应速度,尤其适用于处理数据库查询、网络请求等耗时操作,无需阻塞主线程。

119

2025.12.22

Python 微服务架构与 FastAPI 框架
Python 微服务架构与 FastAPI 框架

本专题系统讲解 Python 微服务架构设计与 FastAPI 框架应用,涵盖 FastAPI 的快速开发、路由与依赖注入、数据模型验证、API 文档自动生成、OAuth2 与 JWT 身份验证、异步支持、部署与扩展等。通过实际案例,帮助学习者掌握 使用 FastAPI 构建高效、可扩展的微服务应用,提高服务响应速度与系统可维护性。

554

2026.02.06

Python Web框架FastAPI 全栈开发教程合集
Python Web框架FastAPI 全栈开发教程合集

以 FastAPI 为核心,讲解现代 Python Web API 的高效开发方式,涵盖路由定义与路径参数/查询参数/请求体绑定、Pydantic 模型的数据校验与序列化、依赖注入(Depends)系统的分层设计、中间件与 CORS 配置、OAuth2 + JWT 认证流程、后台任务(BackgroundTasks)、WebSocket 实时通信、SQLAlchemy 异步 ORM 集成、自动生成 OpenAPI/Swagger 交互文

616

2026.05.09

Python FastAPI异步微服务与高性能接口设计
Python FastAPI异步微服务与高性能接口设计

本专题聚焦 Python FastAPI 框架在高性能接口与微服务开发中的应用,讲解异步请求处理、依赖注入机制、路由设计、数据库异步操作以及接口性能优化策略。结合实际项目案例,帮助开发者构建高并发、低延迟的现代化后端服务架构。

519

2026.06.16

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

5947

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

2528

2023.08.10

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

0

2026.10.22

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Uvicorn官方部署指南
Uvicorn官方部署指南

共0课时 | 0人学习

Uvicorn官方安装与入门手册
Uvicorn官方安装与入门手册

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn