学习笔记【黑马python培训】

更新时间:2019年07月26日 11时12分40秒来源:黑马程序员论坛

Celey使用

使用流程：创建Celery包 ==> 创建main.py文件 ==> 在main.py文件中从celery中导入Celery类，创建Celery实例 ==> 进行配置（创建config.py配置文件，配置连接的数据库）==> 创建任务 ==> 注册任务 ==> 编写任务代码 ==> 启动Celery服务 ==> 调用任务

详细流程：

- 安装Celery：

  ```bash
  $ pip install -U Celery
  ```

- [Celery官方文档](http://docs.celeryproject.org/en/latest/index.html)

> **定义Celery包，并且创建main.py文件**

> **在main.py中创建Celery实例**

> celery_tasks.main.py

```python
# celery启动文件
from celery import Celery

# 创建celery实例
celery_app = Celery('meiduo')
```

> **加载Celery配置**

> celery_tasks.config.py

```python
# 指定消息队列的位置
broker_url= 'amqp://guest:guest@192.168.103.158:5672'
# 根据要连接的数据库来更改ip和端口
```

> celery_tasks.main.py

```python
# celery启动文件
from celery import Celery

# 创建celery实例
celery_app = Celery('meiduo')
# 加载celery配置
celery_app.config_from_object('celery_tasks.config')
```

> **注册任务：celery_tasks.main.py**

```python
# celery启动文件
from celery import Celery

# 创建celery实例
celery_app = Celery('meiduo')
# 加载celery配置
celery_app.config_from_object('celery_tasks.config')
# 自动注册celery任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])
```

> **2.定义任务：celery_tasks.sms.tasks.py**

```python
# bind：保证task对象会作为第一个参数自动传入
# name：异步任务别名
# retry_backoff：异常自动重试的时间间隔第n次(retry_backoff×2^(n-1))s
# max_retries：异常自动重试次数的上限
@celery_app.task(bind=True, name='函数名', retry_backoff=重复执行的时间间隔)
def 函数名(self, 参数):
try:
      要执行的任务
except Exception as e:
      logger.error(e)
      # 有异常自动重试三次
      raise self.retry(exc=e, max_retries=3)
if send_ret != 0:
      # 有异常自动重试三次
      raise self.retry(exc=Exception('发送短信失败'), max_retries=3)

return 返回值
```

4. 启动Celery服务

```bash
$ celery -A celery_tasks.main worker -l info
# 要根据所在的位置填写对应的文件路径
# 启动Celery就是执行main.py文件，所以才要进行导入配置，应用注册
```

> - `-A`指对应的应用程序, 其参数是项目中 Celery实例的位置。
> - `worker`指这里要启动的worker。
> - `-l`指日志等级，比如`info`等级。

5. 调用任务

```python
任务名.delay(自定义任务的参数)
```

推荐了解热门学科

java培训	Python人工智能	Web前端培训	PHP培训
区块链培训	影视制作培训	C++培训	产品经理培训
UI设计培训	新媒体培训	产品经理培训	Linux运维
大数据培训	智能机器人软件开发

传智播客是一家致力于培养高素质软件开发人才的科技公司，“黑马程序员”是传智播客旗下高端IT教育品牌。自“黑马程序员”成立以来，教学研发团队一直致力于打造精品课程资源，不断在产、学、研3个层面创新自己的执教理念与教学方针，并集中“黑马程序员”的优势力量，针对性地出版了计算机系列教材50多册，制作教学视频数+套，发表各类技术文章数百篇。

传智播客从未停止思考

传智播客副总裁毕向东在2019IT培训行业变革大会提到，“传智播客意识到企业的用人需求已经从初级程序员升级到中高级程序员，具备多领域、多行业项目经验的人才成为企业用人的首选。”

中级程序员和初级程序员的差别在哪里?
项目经验。毕向东表示，“中级程序员和初级程序员最大的差别在于中级程序员比初级程序员多了三四年的工作经验，从而多出了更多的项目经验。“为此，传智播客研究院引进曾在知名IT企业如阿里、IBM就职的高级技术专家，集中研发面向中高级程序员的课程，用以满足企业用人需求，尽快补全IT行业所需的人才缺口。

何为中高级程序员课程?

传智播客进行了定义。中高级程序员课程，是在当前主流的初级程序员课程的基础上，增加多领域多行业的含金量项目，从技术的广度和深度上进行拓展。“我们希望用5年的时间，打造上百个高含金量的项目，覆盖主流的32个行业。”传智播客课程研发总监于洋表示。

黑马程序员热门视频教程【点击播放】

Python入门教程完整版（懂中文就能学会）	零起点打开Java世界的大门
C++\| 匠心之作从0到1入门学编程	PHP\|零基础入门开发者编程核心技术
Web前端入门教程_Web前端html+css+JavaScript	软件测试入门到精通

上海中心

学习笔记【黑马python培训】

相关阅读