新版的不再是 from celery.task import Task

而是from celery import Task

另外URLpatterb的写法也不一样，9:11在讲URL

下面这个总结里的我就没用上。因为djcelery在新版celery中不支持。旧版celery又装不上。

我最后还是使用了前一个章节的

@app.task
def dj_cron_task():

这种形式去完成了本节内容。

监控工具：flower

Install : pip install flower

在Django中使用celery

1、install：pip install django-celery

2、Worker：python manage.py celery worker -Q queue

3、Beat：python manage.py celery beat

创建项目

#django-admin.py startproject imooc

#pip install django==1.8

在Django中使用Celery

使用Celery

1、Worker：celery -A task worker --loglevel=info

2、Beat：Celery -A task beat

3、Help：celery workker --help

# celery 配置

# 有些情况下防止死锁
CELERYD_FORCE_EXECV = True

# 设置并发的worker数量
CELERYD_CONCURRENCY = 4

# 允许重试
CELERY_ACKS_LATE = True

# 每个worker最多允许执行100个任务被销毁，可以防止内存泄漏
CELERY_MAX_TASKS_PER_CHILD = 100


# 单个任务的最大运行时间
CELERYD_TASK_TIME_LIMIT = 12 * 30