A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© liujin407 初级黑马   /  2019-5-31 17:49  /  980 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

- 构成
  - 代理人broker:指定队列存储到哪里去
  - 工人worker:从队列中取任务执行,本质就是一个新进程、线程、协程
  - 队列queue:将任务放到队列中,逐个执行
  - 任务task:耗时的代码
- 安装celery:pip install celery
- 实现过程:
  - 新建celry_tasks包,用于写任务的代码
  - 新建main.py,创建celery对象
  - 新建config.py,指定配置,当前为指定rabbitmq为队列
  - 新建sms包,新建tasks.py,在这个文件中写任务代码
  - 定义方法send_sms,剪切耗时代码
  - 添加装饰器@app.task()
  - 在main.py中识别这个任务
  - 调用:任务.delay(参数)
  - 新进程:celery -A celery_tasks.main worker -l info

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马