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))
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容