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…