我有一个需要初始化 Celery 和其他东西(例如数据库)的应用程序。我想要一个包含应用程序配置的 .ini 文件。这应该在运行时传递给应用程序。
开发.init:
[celery]
broker=amqp://localhost/
backend=amqp://localhost/
task.result.expires=3600
[database]
# database config
# ...
芹菜配置.py:
from celery import Celery
import ConfigParser
config = ConfigParser.RawConfigParser()
config.read(...) # Pass this from the command line somehow
celery = Celery('myproject.celery',
broker=config.get('celery', 'broker'),
backend=config.get('celery', 'backend'),
include=['myproject.tasks'])
# Optional configuration, see the application user guide.
celery.conf.update(
CELERY_TASK_RESULT_EXPIRES=config.getint('celery', 'task.result.expires')
)
# Initialize database, etc.
if __name__ == '__main__':
celery.start()
要启动 Celery,我调用:
celery worker --app=myproject.celeryconfig -l info
无论如何都可以传入配置文件而不做一些丑陋的事情,比如设置环境变量?