FastAPI에서 예약된 작업과 정기 작업을 구현하는 방법-파이썬 튜토리얼-php.cn

FastAPI에서 예약된 작업과 정기 작업을 구현하는 방법

WBOY

풀어 주다： 2023-07-30 15:53:12

원래의

3576명이 탐색했습니다.

FastAPI에서 예약된 작업과 정기적인 작업을 구현하는 방법

소개:
FastAPI는 API 애플리케이션 구축에 초점을 맞춘 현대적이고 고성능 Python 프레임워크입니다. 그러나 때로는 FastAPI 애플리케이션에서 예약된 작업과 정기적인 작업을 수행해야 하는 경우도 있습니다. 이 문서에서는 FastAPI 애플리케이션에서 이러한 작업을 구현하는 방법을 설명하고 해당 코드 예제를 제공합니다.

1. 예약된 작업 구현

APScheduler 라이브러리 사용
APScheduler는 예약된 작업을 예약하고 관리하는 강력한 Python 라이브러리입니다. 날짜, 시간 간격 및 Cron 표현식을 기반으로 하는 여러 작업 스케줄러를 지원합니다. 다음은 APScheduler를 사용하여 FastAPI에서 예약된 작업을 구현하는 단계입니다.
1. APScheduler 라이브러리 설치: 터미널에서 pip install apscheduler 명령을 실행하여 APScheduler 라이브러리를 설치합니다. pip install apscheduler来安装APScheduler库。
2. 创建一个定时任务模块：在FastAPI应用程序的根目录下，创建一个名为tasks.py的文件，用于定义定时任务。

from apscheduler.schedulers.background import BackgroundScheduler

scheduler = BackgroundScheduler()

@scheduler.scheduled_job('interval', seconds=10)
def job():
    print("This is a scheduled job")

scheduler.start()

로그인 후 복사

注册定时任务模块：在FastAPI应用程序的主文件中，导入定时任务模块并注册为FastAPI应用程序的一个子应用。

from fastapi import FastAPI
from .tasks import scheduler

app = FastAPI()

app.mount("/tasks", scheduler.app)

로그인 후 복사

使用Celery库
Celery是一个强大的分布式任务队列库，支持异步和定时任务。以下是在FastAPI中使用Celery实现定时任务的步骤：
1. 安装Celery库：在终端中运行命令pip install celery来安装Celery库。
2. 创建一个定时任务模块：在FastAPI应用程序的根目录下，创建一个名为tasks.py

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379')

@app.task
def job():
    print("This is a scheduled job")

로그인 후 복사

from fastapi import FastAPI
from .tasks import app as celery_app

app = FastAPI()

app.mount("/tasks", celery_app)

로그인 후 복사

Celery 라이브러리 사용
Celery는 비동기식 및 예약된 작업을 지원하는 강력한 분산 작업 대기열 라이브러리입니다. 다음은 Celery를 사용하여 FastAPI에서 예약된 작업을 구현하는 단계입니다.

from apscheduler.triggers.cron import CronTrigger

scheduler = BackgroundScheduler()

@scheduler.scheduled_job(CronTrigger.from_crontab('* * * * *'))
def job():
    print("This is a periodic job")

scheduler.start()

로그인 후 복사

```
from celery import Celery
from celery.schedules import crontab

app = Celery('tasks', broker='redis://localhost:6379')

@app.task
def job():
    print("This is a periodic job")

app.conf.beat_schedule = {
    'job': {
        'task': 'tasks.job',
        'schedule': crontab(minute='*'),
    },
}
```
로그인 후 복사
2. 정기 작업 구현
1. APScheduler 라이브러리 사용
2. APScheduler 라이브러리는 정기 작업 예약도 지원합니다. 다음은 APScheduler를 사용하여 FastAPI 애플리케이션에서 정기적인 작업을 구현하는 단계입니다.
APScheduler 라이브러리 설치: 이전 문서의 1단계를 참조하세요.
주기적인 작업 모듈 만들기: 이전 문서의 2단계를 참조하세요.

rrreee
- 셀러리 라이브러리 사용
- 셀러리 라이브러리는 정기적인 작업 예약도 지원합니다. 다음은 FastAPI 애플리케이션에서 Celery를 사용하여 주기적 작업을 구현하는 단계입니다.
Celery 라이브러리 설치: 이전 기사의 1단계를 참조하세요.
🎜주기적인 작업 모듈 만들기: 이전 문서의 2단계를 참조하세요. 🎜🎜🎜🎜rrreee🎜결론: 🎜APScheduler 또는 Celery 라이브러리를 사용하면 FastAPI 애플리케이션에서 예약된 작업과 주기적 작업을 쉽게 구현할 수 있습니다. 위에 제공된 코드 예제는 FastAPI 프로젝트에서 이러한 작업 기능을 빠르게 구현하는 데 도움이 되는 참조로 사용될 수 있습니다. 위의 내용은 간단한 예이지만 이러한 예를 기반으로 자신만의 작업 논리를 추가로 확장하고 사용자 정의할 수 있습니다. 🎜🎜참고 자료: 🎜🎜🎜APScheduler 공식 문서: https://apscheduler.readthedocs.io/🎜🎜Celery 공식 문서: https://docs.celeryproject.org/🎜🎜🎜 (이 기사는 참고용입니다. 실제 상황에 기초하여 필요한 경우 그에 따라 조정하고 수정하세요)🎜.
위 내용은 FastAPI에서 예약된 작업과 정기 작업을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!