celery的使用

celery:芹菜
-是什么,用来干什么?
-用python写的执行定时任务和异步任务的框架

-执行异步任务:
1 创建任务:tasks.py
2 把任务添加到队列中:add_task.py
3 开启work,执行任务
-用命令:celery -A tasks worker -l info
-在windows下:celery worker -A tasks -l info -P eventlet
4 查看任务执行结果:task_result.py
-多任务结构
-重点:执行work的时候:celery worker -A celery_task -l info -P eventlet

-定时任务执行
-指定一个时间点执行任务
apply_async(args=[4, 3], eta=task_time)
-每天某个时间执行
详情看代码
-启动一个beat,负责调度,添加任务：celery beat -A celery_task -l info
-启动work执行任务：celery worker -A celery_task -l info -P eventlet
-django中使用
-上面讲的多任务结构方式

## Django中使用Celery

在项目目录下创建celeryconfig.py
import djcelery
djcelery.setup_loader()
CELERY_IMPORTS=(
    'app01.tasks',
)
#有些情况可以防止死锁
CELERYD_FORCE_EXECV=True
# 设置并发worker数量
CELERYD_CONCURRENCY=4
#允许重试
CELERY_ACKS_LATE=True
# 每个worker最多执行100个任务被销毁，可以防止内存泄漏
CELERYD_MAX_TASKS_PER_CHILD=100
# 超时时间
CELERYD_TASK_TIME_LIMIT=12*30

在app01目录下创建tasks.py
from celery import task
@task
def add(a,b):
    with open('a.text', 'a', encoding='utf-8') as f:
        f.write('a')
    print(a+b)

视图函数views.py
from django.shortcuts import render,HttpResponse
from app01.tasks import add
from datetime import datetime
def test(request):
    # result=add.delay(2,3)
    ctime = datetime.now()
    # 默认用utc时间
    utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())
    from datetime import timedelta
    time_delay = timedelta(seconds=5)
    task_time = utc_ctime + time_delay
    result = add.apply_async(args=[4, 3], eta=task_time)
    print(result.id)
    return HttpResponse('ok')

settings.py
INSTALLED_APPS = [
    ...
    'djcelery',
    'app01'
]

...

from djagocele import celeryconfig
BROKER_BACKEND='redis'
BOOKER_URL='redis://127.0.0.1:6379/1'
CELERY_RESULT_BACKEND='redis://127.0.0.1:6379/2'