flask最简celery

1、创建文件夹--celery_tasks

...

2、创建文件--celery_tasks/__init__.py

×××××××××××××××××所有的异步任务都放在这个里面×××××××××××××

×××××××××××××××××所有的异步任务都放在这个里面×××××××××××××
from celery_tasks.celery_app import app_celery
import time


@app_celery.task
def send_mail():
    from app.models import UserBalance
    print(UserBalance)
    print('邮件开始发送....')
    time.sleep(10)
    print('邮件发送结束！')

3、创建文件--celery_tasks/celery_app.py

from celery import Celery
app_celery = Celery("celery_app", broker="redis://127.0.0.1:6379/0", backend="redis://127.0.0.1:6379/0")
app_celery.autodiscover_tasks(["celery_tasks"])

4、开启celery

celery worker -A celery_tasks.celery_app -B -l info

5、调用

send_mail.delay()

6、搞定， 看着好low， 不过真的是可以用.