Flask实战第66天：celery实现异步任务

pip install celery

pip install eventlet

pip install redis

# task：任务
# broker（中间人）：存储任务的队列
# worker：真正执行任务的工作者
# backend：用来存储任务执行后的结果

from celery import Celery
import time

celery = Celery("tasks",
                broker="redis://10.2.2.120:6379/0",
                backend="redis://10.2.2.120:6379/0")

@celery.task   #加上此装饰器，这个函数就变成celery任务了(task)
def send_mail():
    print('邮件开始发送....')
    time.sleep(10)
    print('邮件发送结束！')

from tasks import send_mail

if __name__ == '__main__':
    send_mail.delay()     #这样调用，就会变成异步任务了，不会被阻塞

(bbs) D:\celery_demo>celery -A tasks.celery --pool=eventlet worker --loglevel=info