队列

celery

异步任务队列/作业队列

安装

pip install eventlet
pip install celery

创建任务

文件：tasks.py

import time
from celery import Celery

celery = Celery('tasks', broker='redis://10.0.5.33:6379')

@celery.task
def sendmail(mail):
    print('sending mail to %s...' % mail['to'])
    time.sleep(2.0)
    print('mail sent.')

运行任务

celery -A tasks worker -l info -P eventlet

调用任务

from tasks import sendmail
sendmail.delay(dict(to='celery@python.org'))