标签：png 定时 通过 worker 加载 指定 ima imp cal
工程结构说明：
__init__.py：实例化celery，并加载配置模块
celeryconfig.py：配置模块
task1：任务1，实现加法
task2：任务2，实现乘法
app.py：应用，任务生产者
1、__init__.py：实例化celery，并加载配置模块
# -*- coding: utf-8 -*- from celery import Celery myapp=Celery(‘demo‘) #通过Celery实例加载配置模块celeryconfig.py myapp.config_from_object(‘celerywithconfig.celeryconfig‘)
2、celeryconfig.py：配置模块
# -*- coding: utf-8 -*- ‘‘‘ Created on 2019年8月28日 @author: lenovo ‘‘‘ BROKER_URL=‘redis://localhost:6379/1‘ CELERY_RESULT_BACKEND=‘redis://localhost:6379/2‘ CELERY_TIMEZONE=‘Asia/Shanghai‘#不指定时区的话默认采用UTC #导入指定的任务模块 CELERY_IMPORTS=( ‘celerywithconfig.task1‘, ‘celerywithconfig.task2‘, )
3、task1：任务1，实现加法
# -*- coding: utf-8 -*- ‘‘‘ Created on 2019年8月28日 @author: lenovo ‘‘‘ import time #从__init__.py中导入实例化的Celery myapp from celerywithconfig import myapp @myapp.task def add(x,y): time.sleep(3) return x+y
4、task2：任务2，实现乘法
# -*- coding: utf-8 -*- ‘‘‘ Created on 2019年8月28日 @author: lenovo ‘‘‘ import time from celerywithconfig import myapp @myapp.task def multiply(x,y): time.sleep(4) return x * y
5、app.py：应用，任务生产者
# -*- coding: utf-8 -*- ‘‘‘ Created on 2019年8月28日 @author: lenovo ‘‘‘ from celerywithconfig import task1 from celerywithconfig import task2 task1.add.delay(2, 4) task2.multiply.delay(4, 5) print ‘end...‘
6、启动worker，监听任务
cd到src路径下，执行命令python -m celery -A celerywithconfig worker --loglevel=info
7、执行app.py，生产任务
8、查看任务消费情况：worker日志显示同时接收到了2个任务，并分别进行了消费：
9、查看任务消费情况：消费结果成功保存在backend中：
python 关于celery的异步任务队列的基本使用（celery+redis）【采用配置文件设置】
标签：png 定时 通过 worker 加载 指定 ima imp cal
原文地址：https://www.cnblogs.com/apple2016/p/11422388.html
