示例一
from celery import Celery
我们这里案例使用redis作为broker
app = Celery(‘demo‘, broker=‘redis://127.0.0.1/1‘)
创建任务函数
@app.task
def my_task():
print("任务函数正在执行....")
启动命令
celery -A tasks worker --loglevel=info
Python 意外退出 解决办法：celery work 后面加 --pool solo
图例
原文：https://www.cnblogs.com/wxdIng/p/14961339.html