new_celery_config specifies Celery configuration via environment variables.
Reason this release was yanked:
Does not handle false values. Upgrade to 0.1.2 or newer.
Project description
Celery is a distributed task queue library for Python. It accepts some of its configuration via environment variables–but some configuration needs to be specified as Python code.
new_celery_config is a Python package that lets you set any top-level Celery key using an environment variable containing YAML.
Installation
The latest stable can be installed via pip:
python3 -m pip install new-celery-config
Usage
(Usage) as a module
To set configuration values, you must set an environment variables for each top-level key (as documented in the Celery documentation).
Each environment variable is prefixed with NEW_CELERY_, followed by the config key name in lowercase. The value for each environment variable must be valid YAML (or JSON–remember that JSON is a subset of YAML).
You must also set the environment variable CELERY_CONFIG_MODULE to new_celery_config.as_module to enable Celery to read all of the other environment variables that you have set.
For example, setting these environment variables in the shell looks like:
export CELERY_CONFIG_MODULE=new_celery_config.as_module
export NEW_CELERY_broker_url='transport://userid:password@hostname:port/virtual_host'
export NEW_CELERY_broker_transport_options='{"visibility_timeout": 36000}'
And in your Python code, initialize the Celery object as follows:
app = Celery()
If you want to change the name of the CELERY_CONFIG_MODULE, you can use the config_from_envvar function. For example:
export ARBITRARY_CELERY_CONFIG_MODULE=new_celery_config.as_module
app.config_from_envvar("ARBITRARY_CELERY_CONFIG_MODULE")
You can test that the configuration works by examining the app.conf object:
print(app.conf.broker_transport_options)
# prints out {'visibility_timeout': 36000}
Usage (as an object)
Celery also accepts configuration in the form of a Python object. If you prefer this way, you can give Celery a new_celery_config.Config object. For example:
from celery import Celery
import new_celery_config
app = Celery()
app.config_from_object(new_celery_config.Config())
Contributing changes to new_celery_config
If you want to make changes to new_celery_config, you can clone this repository. You can run make in the root directory to show commands relevant to development.
- For example:
make fmt automatically formats Python code.
make lint runs pylint and mypy to catch errors.
make test runs unit tests.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for new_celery_config-0.1.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c396bb5482a52da32eac5496a9ab8d0972765857980768ff4cbcf289b0619bad |
|
MD5 | 6075590dbacde1d5222ddfcce0e96081 |
|
BLAKE2b-256 | f85cf156a60993bb389fdd7c576bd1252523e9ba5053f1e3643b076a19efa678 |