我按照手册描述的方式开始了芹菜工作者......
$ 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容器中运行它 - 提供此信息的最简单方法是作为环境变量。
大多数设置可以通过env vars设置。命名约定是CELERY_的前缀,然后是设置名称的大写。
在这种情况下,设置为broker_url
,因此env var是CELERY_BROKER_URL
。