Django中如何使用Celery执行异步任务

Django使用Celery执行异步任务

在Django项目中执行耗时操作时，使用Celery能避免阻塞主线程，提高用户体验。以下是集成Celery的完整流程。

第1步：安装Celery

在虚拟环境中安装Celery及其依赖：

pip install celery==4.4.7

注意：此版本较旧，生产环境建议使用最新稳定版。

第2步：配置项目环境

配置消息代理和后端存储，用于任务队列和结果保存。

2.1 修改setting.py

添加以下设置：

CELERY_BROKER_URL = 'redis://127.0.0.1:6379/1'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/1'
CELERY_RESULT_SERIALIZER = 'json'

2.2 创建celery.py

在与setting同级目录下新建celery.py文件：

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoFunction.settings')

app = Celery('test_celery')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks(['CeleryFunc'])

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

替换'DjangoFunction.settings'为你的实际Django设置模块名。

2.3 创建__init__.py

同一目录下新建__init__.py：

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app

__all__ = ['celery_app']

第3步：定义异步任务

在Django APP中新建tasks.py文件：

import time
from loguru import logger

import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoFunction.settings')
django.setup()

from DjangoFunction import celery_app

@celery_app.task(bind=True)
def my_asynch_task(self):
    """我的异步任务"""
    logger.info('开始执行异步任务')
    time.sleep(3)
    print('------', self.request.id)
    logger.info('结束执行异步任务')
    return 10

确保替换导入路径为实际项目模块。

第4步：调用异步任务

在views.py中调用任务：

from rest_framework.views import APIView
from rest_framework.response import Response
from CeleryFunc.tasks import my_asynch_task

class AsyncAPIView(APIView):
    def get(self, request, format=None):
        try:
            result = my_asynch_task.delay()
            resp = {'code': 200, 'message': 'success'}
        except Exception as e:
            resp = {'code': 300, 'message': str(e)}
        return Response(resp)

使用delay()方法触发自定义任务，返回Task对象供查询状态。

第5步：启动Celery Worker

在终端运行以下命令启动Worker：

celery worker -A DjangoFunction -l info -P eventlet

替换'DjangoFunction'为你的项目主模块名，监听并处理异步任务。可通过日志观察任务执行情况。

项目结构参考

典型的项目目录布局如下：

总结

通过上述步骤，您可以在Django应用中成功集成Celery来执行异步任务。关键在于正确配置消息代理、定义任务模块，并确保Worker进程持续运行。以上就是Django使用Celery执行异步任务的详细内容，更多关于Python并发编程的资料请关注本站其它相关文章！