celery的使用

task.py 每当调用它就会生成一个任务存在redis队列中，redis队列启用的话会执行task中的某一方法调用一些sdk的xxx，这就是worker
mian.py用于配置中间人，生成一个对象供task.py调用

#main.py
from celery import Celery

# /home/python/Desktop/untitled1/celery_tasks/main.py
# 定义celery的名字
celery_app = Celery('my_celery')
# 加载配置
celery_app.config_from_object('celery_tasks.config')
# 监控sms中的task发出的任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])

#config.py
broker_url = 'redis://127.0.0.1:6379/14'

#tasks.py
from celery_tasks.main import celery_app

@celery_app.task(name='my_first_task')
def task_func(a, b):
    print('任务函数被调用了%s,%s' % (a,b))