我可以使用环境变量来使Celery worker连接到不同的worker吗?

问题描述 投票:-1回答:1

我按照手册描述的方式开始了芹菜工作者......

$ stoneid salimfadhley$ celery worker

 -------------- [email protected] v4.2.1 (windowlicker)
---- **** ----- 
--- * ***  * -- Darwin-18.2.0-x86_64-i386-64bit 2018-11-13 14:00:20
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> app:         default:0x10fb4ee48 (.default.Loader)
- ** ---------- .> transport:   amqp://guest:**@localhost:5672//
- ** ---------- .> results:     disabled://
- *** --- * --- .> concurrency: 8 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** ----- 
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery


[2018-11-13 14:00:21,065: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 2.00 seconds...

我可以提供一些配置(最好通过环境变量),以便工作人员连接到不同的代理地址吗?

根据手册,我可以使用-b标志通过命令行指定代理URL,我可以将worker包装在一个脚本中,该脚本提取环境变量并将其填充到celery worker的命令行参数中...但我可以绕过这个吗?是否有一个我可以设置的环境变量,工人会选择哪个?

我实际上是在Docker容器中运行它 - 提供此信息的最简单方法是作为环境变量。

docker celery
1个回答
1
投票

大多数设置可以通过env vars设置。命名约定是CELERY_的前缀,然后是设置名称的大写。

在这种情况下,设置为broker_url,因此env var是CELERY_BROKER_URL

© www.soinside.com 2019 - 2024. All rights reserved.