celery（芹菜）异步任务定时任务周期任务

pip install celery

pro_cel
    ├── celery_task# celery相关文件夹
    │   ├── celery.py   # celery连接和配置相关文件,必须叫这个名字
    │   └── order_task.py    #  所有任务函数
    │   └── user_task.py    #  所有任务函数
    ├── celery_result.py # 检查结果
    └── add_task.py    # 触发任务

#这个文件名必须叫celery，生成celery对象

from celery import Celery
from datetime import timedelta
from celery.schedules import  crontab
broker = 'redis://127.0.0.1:6379/0'
backend = 'redis://127.0.0.1:6379/1'
app = Celery('test',broker=broker,backend=backend,
             #包含以下链各个任务文件，去响应的py文件中找任务，对多个任务做分类
             include=[
                 'celery_task.order_task',
                 'celery_task.user_task',
                    ]
             )

#时区
# app.conf.timezOne= 'Asia/Shanghai'
#是否使用UTC
# app.conf.enable_utc = False

from celery_task.celery import app
@app.task
def order_add(x,y):
    import time
    time.sleep(1)
    return x+y

from celery_task.celery import app
@app.task
def user_add(x,y):
    import time
    time.sleep(1)
    return x+y

from celery_task.order_task import order_add
from celery_task.user_task import user_add

# ret=order_add.delay(5,6)
ret=user_add.delay(10,60)
print(ret)

celery worker -A celery_task -l info -P eventlet    #放值的时候手动启动add_task文件

#用于提交任务的py文件
import celery_task_s1
#执行定时任务：3s钟以后执行add任务
from datetime import datetime
# v1 = datetime(2019, 7, 12, 11, 13, 56)
# print(v1)
# v2 = datetime.utcfromtimestamp(v1.timestamp())
# print(v2)
# #取出要执行任务的时间对象，调用apply_async方法，args是参数，eta是执行的时间
# result = celery_task_s1.add.apply_async(args=[1, 3], eta=v2)
# print(result.id) #这里需要注意的是result是个对象，你可以直接打印因为内部写了__str__

#第二种获取时间的方法
ctime = datetime.now()
# 默认用utc时间
utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())
from datetime import timedelta
#取10s之后的时间对象
time_delay = timedelta(secOnds=3)
task_time = utc_ctime + time_delay
result = celery_task_s1.add.apply_async(args=[4, 3], eta=task_time)
print(result.id) #这里需要注意的是result是个对象，你可以直接打印因为内部写了__str__

#任务提交完成后，需要启动worker，可以用命令启动：
# celery worker -A celery_task_s1 -l info
#windows上：celery worker -A celery_task_s1 -l info -P eventlet

#这个文件名必须叫celery，生成celery对象

from celery import Celery
from datetime import timedelta
from celery.schedules import  crontab
broker = 'redis://127.0.0.1:6379/0'
backend = 'redis://127.0.0.1:6379/1'
app = Celery('test',broker=broker,backend=backend,
             #包含以下链各个任务文件，去响应的py文件中找任务，对多个任务做分类
             include=[
                 'celery_task.order_task',
                 'celery_task.user_task',
                    ]
             )

#时区问题  每天的什么时候去执行任务
#时区
# app.conf.timezOne= 'Asia/Shanghai'
#是否使用UTC
# app.conf.enable_utc = False

#beat_schedule 定义定时任务的
app.conf.beat_schedule = {
    #名字随意命令
    'add-every-2-seconds':{
        #执行tasks1下的test_celery函数
        'task':'celery_task.order_task.order_add',
        #每隔2秒执行一次
        # 'schedule':1.0,  几秒钟几分钟几小时后schedule对应的参数
        # 'schedule':crontab(minute='*/1'),
        'schedule':timedelta(secOnds=10),
        #传递参数
        'args':(5,6)
    },
    # 'add-every-12-seconds':{
    #     'task':'celery_task.order_task.user_add',
    #     #每年4月11号，8点42分执行
    #     # 'schedule':crontab(minute=42,hour=8,day_of_mOnth=11,month_of_year=4),
    #     'schedule':crontab(minute=42,hour=8,day_of_mOnth=11,month_of_year=4),
    #     'args':(16,16)
    # }
}

celery beat -A celery_task -l info

celery worker -A celery_task -l info -P  eventlet

celery==3.1.25
django-celery==3.1.20 

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

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "untitled15.settings")
    import django
    django.setup()

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)

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')

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

...

from djagocele import celeryconfig    #from 这个django项目 import celeryconfig就是上面配置的文件
BROKER_BACKEND='redis'
BOOKER_URL='redis://127.0.0.1:6379/1'
CELERY_RESULT_BACKEND='redis://127.0.0.1:6379/2'