先来看一份伪代码和生产者消费者模式
生产者---消费者模式
首先安装celery
再看看大体步骤 下面在自己具体实现一次
Linux下启动Celery服务:
celery -A celery文件夹下的main文件 worker -l info
Windows下启动celery服务:
celery -A 自己定义的celery任务的main文件 worker -l info -P eventlet
如果是在Windows下, 需要再安装一个包 叫: eventlet pip install eventlet 启动命令后面要加 -P eventlet 否则会报错
自己实现
1首先定义一个celery包
包里面是这样:
注意: 任务包里的任务文件只能叫tasks.py, 这是固定的, 不能起别的名字!!!
任务包里的任务文件只能叫tasks.py, 这是固定的, 不能起别的名字!!!
任务包里的任务文件只能叫tasks.py, 这是固定的, 不能起别的名字!!!
重要事情说三遍
再来看每一个文件夹里的内容
首先看main文件:
再来看config配置文件
最后看任务包中的tasks文件
最后启动celery, 之后在调用就可以了
在terminal启动命令:
celery -A 自己定义的celery任务的main文件 worker -l info -P eventlet
如果是在Windows下, 需要再安装一个包 叫: eventlet pip install eventlet 启动命令后面要加 -P eventlet 否则会报错
调用异步任务:
异步任务执行我们定义的任务不会在控制台上输出, 它在我们开启Celery的terminal里输出