celery 基础教程（三）：配置

标签：序列化   time   file   pac   eager   color   前言   limit   trie   

前言

如果你使用默认的加载器，你必须创建 celeryconfig.py 模块并且保证它在python路径中。

一、加载配置方法

 1.基础方法 

可以设置一些选项来改变 Celery 的工作方式。这些选项可以直接在 app 实例上进行设置，或者也可以使用一个指定的配置模块

配置使用 app.conf 变量保存：

>>> app.conf.timezone
‘Europe/London‘

你可以直接设置配置值：

>>> app.conf.enable_utc = True

或者使用 update 方法同时更新多个配置项。

>>> app.conf.update(
...     enable_utc=True,
...     timezone=‘Europe/London‘,
...)

实际的配置对象由多个字典决定，配置项按以下顺序查询：
1. 运行时的配置修改
2. 配置模块（如果声明）
3. 默认配置（celery.app.defaults）

你还可以使用 app.add_defaults() 方法添加新的默认配置源。

2.config_from_object

app.config_from_object() 方法从一个配置对象加载配置。

它可以是一个配置模块，或者任意包含配置属性的对象。

注意任何前面设置的配置在调用 config_from_object 方法后都将被重置。如果你想设置附加的配置应该在调用这个方法之后。

示例1： 使用模块名
app.config_from_object() 方法的参数可以是一个 python 模块的全限定名称，或者一个 python 属性名，例如：”celeryconfig”，”myproj.config.celery”，或者 “myproj.config:CeleryConfig”：

from celery import Celery

app = Celery()
app.config_from_object(‘celeryconfig‘)

celeryconfig 模块内容如下形式：
celeryconfig.py:

enable_utc = True
timezone = ‘Europe/London‘

只要 import celeryconfig 能正常运行，应用实例就能加载它。

示例2：传递一个模块对象
你还可以传递一个已经加载的模块对象，但是不作为常规建议。

建议使用模块名的方式加载，因为这种情况下当prefork池使用时，配置模块不必序列化。如果遇到配置问题或者序列化错误，可以尝试使用模块名的方式加载配置。

import celeryconfig

from celery import Celery

app = Celery()
app.config_from_object(celeryconfig)

示例3：使用配置类/对象

from celery import Celery

app = Celery()

class Config:
    enable_utc = True
    timezone = ‘Europe/London‘

app.config_from_object(Config)
# or using the fully qualified name of the object:
#   app.config_from_object(‘module:Config‘)

二、配置文件示例

以下是配置示例，你可以从这个开始。它包括运行一个基本Celery应用的所有基础设置。

## Broker settings.
broker_url = ‘amqp://guest:guest@localhost:5672//‘

# List of modules to import when the Celery worker starts.
imports = (‘myapp.tasks‘,)

## Using the database to store task state and results.
result_backend = ‘db+sqlite:///results.db‘

task_annotations = {‘tasks.add‘: {‘rate_limit‘: ‘10/s‘}}

三、新的小写设置

与以前版本的不同，除了设置项名称变为小写字母外，还有一个前缀的重命名，例如 celerybeat_ 变为 beat_，celeryd_ 变为 worker，以及很多顶级 celery_ 设置重命名成了 task_ 前缀。

Celery 仍然能读取老的配置文件，所以并不仓促迁移到新的设置格式。

celery 基础教程（三）：配置

标签：序列化   time   file   pac   eager   color   前言   limit   trie   

原文地址：https://www.cnblogs.com/qiu-hua/p/12706135.html