django celery

Posted 2020-12-24 yitiaodahe

1.安装：

pip install celery celery-with-redis django-celery

2.用途

　为了提升用户体验，使用celery可以异步执行耗时或者定时的操作，views可以先返回view执行结果

3.操作原理：

• 任务task：就是一个Python函数
• 队列queue：将需要执行的任务加入到队列中
• 工人worker：在一个新进程中，负责执行队列中的任务
• 代理人broker：负责调度，在布置环境中使用redis

4.操作步骤

　　参考文献：http://docs.jinkan.org/docs/celery/

　　　　　　　https://www.cnblogs.com/znicy/p/5626040.html

　　1.settings 

　　　　

INSTALLED_APPS = [
    ‘django.contrib.admin‘,
    ‘django.contrib.auth‘,
    ‘django.contrib.contenttypes‘,
    ‘django.contrib.sessions‘,
    ‘django.contrib.messages‘,
    ‘django.contrib.staticfiles‘,
    ‘booktest‘,
    ‘tinymce‘,
    ‘haystack‘,
    ‘djcelery‘,

　　import djcelery
　　djcelery.setup_loader()
　　# os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘test6.settings‘)
　　BROKER_URL = ‘redis://127.0.0.1:6379/0‘
　　CELERY_IMPORTS = (‘booktest.task‘)

　　2.在应用目录创建task.py文件：

　　　　

import django
django.setup()
import time
from celery import task

@task
def sayhello():
    print(‘hello ...‘)
    time.sleep(15)
    print(‘world ...‘)

　　3.view中添加task任务

　　　　

from .task import *

...

sayhello.delay()

　　4.

python manage.py migrate
python manage.py celery worker --loglevel=info

　　注意：python manage celery work执行出现django路径错误，可以在task.py中导入django的setting