# tasks.py
from celery import Celery

celery_app = Celery('tasks', broker="redis://10.0.2.20/15")


@celery_app.task
def add(x, y):
    print(x + y)
    return x + y
# celery_app.autodiscover_tasks(['celery_tasks.sms',"celery_tasks.emailTask","celery_tasks.html"])

if __name__ == '__main__':
    result = add.delay(30, 42)
    print(result)


celery -A tasks worker --loglevel=info

python tasks.py   

简单的实现 创建celery 任务队列以及 新建任务，并执行任务
扫码关注我们
微信号：SRE实战
拒绝背锅 运筹帷幄