Django应用celery实现多进程异步和定时任务的宝典

后端

2023-03-27 10:35:08

Celery：提升 Django 应用程序性能的利器

对于现代化的 Django 应用程序，优化性能至关重要。Celery 是一款强大的任务队列库，可帮助您提高应用程序的响应速度和效率。

Celery 的优势

使用 Celery，您可以：

异步处理耗时任务： 将耗时的任务推迟到后台执行，释放主应用程序线程。
提高响应时间： 用户无需等待任务完成即可继续与应用程序交互。
支持定时任务： 根据设定的时间表自动执行任务。
并行任务执行： 同时处理多个任务，加快处理速度。

安装和配置

安装 Celery 库：

pip install celery

配置 Django 设置：

INSTALLED_APPS = [
    'celery',
]

CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/1'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

创建任务

from celery import task

@task
def long_task():
    # 耗时的任务代码
    return "Task completed!"

调用任务

from celery import Celery

celery = Celery('my_task_queue')

celery.send_task('long_task')

定时任务

from celery import crontab
from celery.schedules import crontab

@task
def long_task():
    # 耗时的任务代码
    return "Task completed!"

celery.conf.beat_schedule = {
    'long_task': {
        'task': 'long_task',
        'schedule': crontab(minute=0, hour='*/1'),
    },
}