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 Celery

app = Celery(
    'celery_tasks.tasks',
    broker='redis://127.0.0.1:6379/8',
    backend='redis://127.0.0.1:6379/9',
)
复制代码

还能够这样写，以下：

from celery import Celery

app = 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'

# 设置代理人broker
broker_url='redis://127.0.0.1:6379/8'
复制代码

tasks.py文件修改成:

from celery import Celery
from . import celeryconfig # 导入配置文件

app = Celery('celery_tasks.tasks')

# 从单独的配置模块中加载配置
app.config_from_object(celeryconfig)
复制代码

更多配置: docs.celeryproject.org/en/latest/u…