Cara melaksanakan tugas berjadual dan tugas berkala dalam FastAPI-Tutorial Python-php.cn

Cara melaksanakan tugas berjadual dan tugas berkala dalam FastAPI

WBOY

Lepaskan： 2023-07-30 15:53:12

asal

3577 orang telah melayarinya

Cara melaksanakan tugas berjadual dan tugas berkala dalam FastAPI

Pengenalan:
FastAPI ialah rangka kerja Python moden dan berprestasi tinggi yang memfokuskan pada membina aplikasi API. Walau bagaimanapun, kadangkala kita perlu melaksanakan tugas berjadual dan tugas berkala dalam aplikasi FastAPI. Artikel ini menerangkan cara melaksanakan tugas ini dalam aplikasi FastAPI dan menyediakan contoh kod yang sepadan.

1. Pelaksanaan tugas berjadual

Menggunakan perpustakaan APScheduler
APScheduler ialah perpustakaan Python yang berkuasa untuk menjadualkan dan mengurus tugas berjadual. Ia menyokong berbilang penjadual tugas, seperti berdasarkan tarikh, selang masa dan ungkapan Cron. Berikut ialah langkah untuk menggunakan APScheduler untuk melaksanakan tugas berjadual dalam FastAPI:
1. Pasang pustaka APScheduler: Jalankan arahan pip install apscheduler dalam terminal untuk memasang pustaka 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()

Salin selepas log masuk

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

from fastapi import FastAPI
from .tasks import scheduler

app = FastAPI()

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

Salin selepas log masuk

使用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")

Salin selepas log masuk

from fastapi import FastAPI
from .tasks import app as celery_app

app = FastAPI()

app.mount("/tasks", celery_app)

Salin selepas log masuk

Menggunakan perpustakaan Saderi
Saderi ialah perpustakaan baris gilir tugas teragih yang berkuasa yang menyokong tugas tak segerak dan berjadual. Berikut ialah langkah untuk menggunakan Celery untuk melaksanakan tugas berjadual dalam 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()

Salin selepas log masuk

```
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='*'),
    },
}
```
Salin selepas log masuk
2. Pelaksanaan tugasan berkala
1. Gunakan perpustakaan APScheduler
2. APScheduler library juga menyokong penjadualan tugasan berkala. Berikut ialah langkah untuk menggunakan APScheduler untuk melaksanakan tugas berkala dalam aplikasi FastAPI:
Pasang perpustakaan APScheduler: Rujuk langkah 1 dalam artikel sebelumnya.
Buat modul tugasan berkala: rujuk langkah 2 dalam artikel sebelumnya.

rrreee
- Menggunakan perpustakaan Saderi
- Perpustakaan Saderi juga menyokong penjadualan tugasan berkala. Berikut ialah langkah untuk melaksanakan tugas berkala menggunakan Celery dalam aplikasi FastAPI:
Pasang perpustakaan Saderi: Rujuk langkah 1 dalam artikel sebelumnya.
🎜Buat modul tugasan berkala: rujuk langkah 2 dalam artikel sebelumnya. 🎜🎜🎜🎜rrreee🎜Kesimpulan: 🎜Dengan menggunakan perpustakaan APScheduler atau Celery, kami boleh melaksanakan tugas berjadual dan tugas berkala dengan mudah dalam aplikasi FastAPI. Contoh kod yang disediakan di atas boleh digunakan sebagai rujukan untuk membantu anda melaksanakan fungsi tugas ini dengan cepat dalam projek FastAPI anda. Walaupun perkara di atas adalah contoh mudah, anda boleh melanjutkan dan menyesuaikan logik tugas anda sendiri berdasarkan contoh ini. 🎜🎜Bahan rujukan: 🎜🎜🎜Dokumentasi rasmi APSscheduler: https://apscheduler.readthedocs.io/🎜🎜Dokumentasi rasmi Celery: https://docs.celeryproject.org/🎜🎜🎜 (Artikel ini untuk rujukan sahaja rujuk situasi sebenar Laraskan dan ubah suai sewajarnya jika perlu)🎜.
Atas ialah kandungan terperinci Cara melaksanakan tugas berjadual dan tugas berkala dalam FastAPI. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!