Django 2.1.7 Celery 4.3.0 配置

Django 2.1.7 Celery 4.3.0 配置

相关篇章：

​​Django 2.1.7 Celery 4.3.0 示例，解决Task handler raised error: ValueError('not enough values to unp...​​​​Django 2.1.7 集成Celery 4.3.0 从介绍到入门​​

上一篇中从介绍到入门已经讲解了Celery如何安装以及调用。本篇章来看看关于配置这块的内容。

配置

Celery使用简单，配置也非常简单。Celery有很多配置选项能够使得celery能够符合我们的需要，但是默认的几项配置已经足够应付大多数应用场景了。

配置信息可以直接在app中设置，或者通过专有的配置模块来配置。

1.直接通过app来配置

from celery import Celeryapp = Celery( 'celery_tasks.tasks', broker='redis://127.0.0.1:6379/8', backend='redis://127.0.0.1:6379/9',)

还可以这样写，如下：

from celery import Celeryapp = Celery('celery_tasks.tasks')# 增加配置app.conf.update( result_backend='redis://127.0.0.1:6379/9', broker_url='redis://127.0.0.1:6379/8',)

使用​​app.conf.update​​​的方法更新配置的指定参数与前面的有些不一样。例如：前面写​​broker='redis://127.0.0.1:6379/8',​​​，后面的配置写成​​broker_url='redis://127.0.0.1:6379/8',​​

2.专有配置文件

对于比较大的项目，我们建议配置信息作为一个单独的模块。我们可以通过调用app的函数来告诉Celery使用我们的配置模块。

配置模块的名字我们取名为celeryconfig, 这个名字不是固定的，我们可以任意取名，建议这么做。我们必须保证配置模块能够被导入。

下面我们在tasks.py模块 同级目录下创建配置模块celeryconfig.py:

# 设置结果存储result_backend='redis://127.0.0.1:6379/9'# 设置代理人brokerbroker_url='redis://127.0.0.1:6379/8'

tasks.py文件修改为:

from celery import Celeryfrom . import celeryconfig # 导入配置文件app = Celery('celery_tasks.tasks')# 从单独的配置模块中加载配置app.config_from_object(celeryconfig)

更多配置: ​​http://docs.celeryproject.org/en/latest/userguide/configuration.html#configuration​​

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。