django集成celery实践：构建异步任务示例

本文将详细介绍如何在Django框架中集成Celery进行异步任务开发，以提升Web应用的用户体验。项目背景是在用户触发操作后，执行一个耗时的后台处理程序，通过 Celery 实现任务的异步执行，避免HTTP请求阻塞，让用户无需等待即可继续浏览其他内容。项目采用的开发环境包括Windows 7、Python 2.7、PyCharm 5、Celery 3.1.25 和 Django 1.9.4。 一、项目功能 项目旨在解决长时间运行任务导致的用户等待问题。设计了一个包含两个页面的简单应用：一个页面用于提交加法计算任务，另一个页面显示所有任务的详细状态，如任务ID和状态（成功或执行中）。 二、项目结构 项目采用了RabbitMQ作为消息中间件（Broker），用于任务队列的管理，而结果存储则选择了`django-celery`，将其结果保存在数据库中。 三、开始编程 1. 安装`django-celery`库： ``` pip install django-celery ``` 2. 创建Django工程`test_celery`，并在工程中创建一个名为`tools`的app，用于存放工具类函数和执行的任务。同时，还需要创建一个`celery.py`文件，用于配置Celery。 3. 编辑`settings.py`，配置Celery的Broker和Backend： ```python # celery设置 import djcelery djcelery.setup_loader() BROKER_URL = 'pyamqp://guest@localhost//' # 配置broker BROKER_POOL_LIMIT = 0 CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend' # 配置backend INSTALLED_APPS = [ 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'tools', # 添加你的应用 'djcelery', ] ``` 四、Celery任务定义与调用 1. 在`tools`应用中创建一个名为`tasks.py`的文件，定义Celery任务： ```python from celery import shared_task @shared_task def add(x, y): return x + y ``` 2. 在视图函数中调用这个任务，并返回任务的唯一标识符（task_id）： ```python from tasks import add def submit_task(request): task = add.delay(5, 3) # 异步提交任务 return HttpResponse(task.id) ``` 3. 创建一个视图用于显示任务状态： ```python from celery.result import AsyncResult def task_status(request, task_id): task = AsyncResult(task_id) if task.state == 'SUCCESS': result = task.get() return HttpResponse("Task ID: {}, Result: {}".format(task_id, result)) else: return HttpResponse("Task ID: {}, Status: {}".format(task_id, task.state)) ``` 五、URL配置 在`urls.py`中添加对应视图的URL路由，以便用户访问提交任务和查看任务状态的页面。 通过以上步骤，我们就成功地在Django中集成了Celery，实现了异步任务处理。用户可以通过提交任务页面发起计算请求，然后立即查看任务状态页面以获取任务执行的最新进展，提高了Web应用的响应速度和用户体验。