全栈工程师-后端开发-Django_Django高级主题：Celery异步任务与定时任务.docx

PAGE1

PAGE1

Django高级主题：Celery异步任务与定时任务

1Celery基础概念

Celery是一个分布式任务队列，用于处理大量异步任务。它使用消息代理（如RabbitMQ、Redis等）来在生产者和消费者之间传递消息，使得任务可以在多个工作节点上并行执行。Celery支持任务的延迟执行、定时执行、任务状态跟踪和结果存储等功能，非常适合用于Django项目中处理耗时的后台任务。

2Celery在Django中的安装与配置

2.1安装Celery

pipinstallcelery

2.2配置Celery

在Django项目中创建一个celery.py文件，配置Celery的基本参数：

#myproject/celery.py

from__future__importabsolute_import,unicode_literals

importos

fromceleryimportCelery

os.environ.setdefault(DJANGO_SETTINGS_MODULE,myproject.settings)

app=Celery(myproject)

app.config_from_object(django.conf:settings,namespace=CELERY)

app.autodiscover_tasks()

在settings.py中添加Celery的配置：

#myproject/settings.py

CELERY_BROKER_URL=amqp://guest:guest@localhost:5672//

CELERY_RESULT_BACKEND=rpc://

2.3启动Celery工作节点

celery-Amyprojectworker--loglevel=info

3创建Celery任务

在Django应用中创建一个任务：

#myapp/tasks.py

from__future__importabsolute_import,unicode_literals

fromceleryimportshared_task

@shared_task

defadd(x,y):

returnx+y

4异步任务处理

在视图中调用Celery任务：

#myapp/views.py

fromdjango.httpimportJsonResponse

from.tasksimportadd

defindex(request):

result=add.delay(16,16)

returnJsonResponse({task_id:result.task_id})

获取任务状态：

#myapp/views.py

fromdjango.httpimportJsonResponse

from.tasksimportadd

defcheck_status(request,task_id):

result=add.AsyncResult(task_id)

returnJsonResponse({status:result.status,result:result.result})

5定时任务与Crontab

在celery.py中添加定时任务配置：

#myproject/celery.py

from__future__importabsolute_import,unicode_literals

importos

fromceleryimportCelery

fromcelery.schedulesimportcrontab

os.environ.setdefault(DJANGO_SETTINGS_MODULE,myproject.settings)

app=Celery(myproject)

app.config_from_object(django.conf:settings,namespace=CELERY)

app.autodiscover_tasks()

app.conf.beat_schedule={

add-every-30-seconds:{

task:myapp.tasks.add,

schedule:30.0,

args:(16,16)

},

send-email-every-day:{

task:myapp.tasks.sen