pip install -U "celery[redis]"

pip install eventlet # celery 4.0+版本以后不支持在windows运行，还需额外安装eventlet库

celery -A tasks worker --loglevel=info
celery -A task worker --loglevel=info -P eventlet
celery -A tasks control rate_limit tasks.add 10/m

from celery import Celery
app = Celery('tasks', broker='pyamqp://guest:guest@14.222.31.232//')
@app.tasks
def add(x, y):
    print("input is {} {}".format(x,y))
    return x + y
if __name__ == '__main__':
    print('task start....')
    result = add.delay(2,3)
    print('task end....')
    print(result)

from task import add
add.delay(3,4)

print(result.ready())
获取运行结果
判断
result.get(timeout=1)

redis://:password@hostname:port/db_number

pip install celery
pip install redis

pip install django-celery-beat

CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

CELERYBEAT_SCHEDULE = {
    # 每过10秒执行以下task1.add的定时任务
    'task1':{
        'task': 'course-task',
        'schedule': timedelta(seconds=10),
        'options':{
            'queue': 'beat_tasks'
        }
    },
}

启动处理
celery multi start w1 -A proj -l info
有计划任务的还需要单独加一条下面的（配置好CELERY_BEAT_SCHEDULER的情况下）
celery multi start w1 -A proj beat -l info
如果没配置好，就用下面这条
celery -A todo beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler