task.py 每當(dāng)調(diào)用它就會(huì)生成一個(gè)任務(wù)存在redis隊(duì)列中，redis隊(duì)列啟用的話(huà)會(huì)執(zhí)行task中的某一方法調(diào)用一些sdk的xxx，這就是worker
mian.py用于配置中間人，生成一個(gè)對(duì)象供task.py調(diào)用

#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')
# 監(jiān)控sms中的task發(fā)出的任務(wù)
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('任務(wù)函數(shù)被調(diào)用了%s,%s' % (a,b))