Celery Flower 使用 Redis 和 SSL 在 Broker Stats 上返回 500 秒

问题描述

我刚刚安装了芹菜花。

它非常适合向我展示实时任务、处理它们的队列、cpu 使用情况和处理时间。

我还想访问代理页面,以便监控队列长度。

我遇到的问题是 SSL。

代理页面返回 500。查看日志,我看到以下堆栈跟踪。

2020-12-24T21:19:21.828079+00:00 app[web.1]: [W 201224 21:19:21 connection:255] Secure redis scheme specified (rediss) with no ssl options,defaulting to insecure SSL behavIoUr.
2020-12-24T21:19:21.854471+00:00 app[web.1]: [W 201224 21:19:21 connection:255] Secure redis scheme specified (rediss) with no ssl options,defaulting to insecure SSL behavIoUr.
2020-12-24T21:19:21.878474+00:00 app[web.1]: [E 201224 21:19:21 web:1793] Uncaught exception GET /broker (...)
2020-12-24T21:19:21.878479+00:00 app[web.1]: HTTPServerRequest(protocol='http',host='...herokuapp.com',method='GET',uri='/broker',version='HTTP/1.1',remote_ip='...')
2020-12-24T21:19:21.878480+00:00 app[web.1]: Traceback (most recent call last):
2020-12-24T21:19:21.878481+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/tornado/web.py",line 1704,in _execute
2020-12-24T21:19:21.878481+00:00 app[web.1]: result = await result
2020-12-24T21:19:21.878482+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/tornado/gen.py",line 234,in wrapper
2020-12-24T21:19:21.878482+00:00 app[web.1]: yielded = ctx_run(next,result)
2020-12-24T21:19:21.878482+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/tornado/gen.py",line 162,in _fake_ctx_run
2020-12-24T21:19:21.878483+00:00 app[web.1]: return f(*args,**kw)
2020-12-24T21:19:21.878483+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/views/broker.py",line 31,in get
2020-12-24T21:19:21.878485+00:00 app[web.1]: http_api=http_api,broker_options=broker_options,broker_use_ssl=broker_use_ssl)
2020-12-24T21:19:21.878485+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/utils/broker.py",line 237,in __new__
2020-12-24T21:19:21.878486+00:00 app[web.1]: return RedisSsl(broker_url,*args,**kwargs)
2020-12-24T21:19:21.878486+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/utils/broker.py",line 220,in __init__
2020-12-24T21:19:21.878486+00:00 app[web.1]: super(RedisSsl,self).__init__(broker_url,**kwargs)
2020-12-24T21:19:21.878487+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/utils/broker.py",line 134,in __init__
2020-12-24T21:19:21.878487+00:00 app[web.1]: self.redis = self._get_redis_client()
2020-12-24T21:19:21.878488+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/utils/broker.py",line 155,in _get_redis_client
2020-12-24T21:19:21.878488+00:00 app[web.1]: return redis.Redis(**self._get_redis_client_args())
2020-12-24T21:19:21.878489+00:00 app[web.1]: File "/app/.heroku/python/lib/python3.6/site-packages/flower/utils/broker.py",line 225,in _get_redis_client_args
2020-12-24T21:19:21.878489+00:00 app[web.1]: client_args.update(self.broker_use_ssl)
2020-12-24T21:19:21.878554+00:00 app[web.1]: TypeError: 'nonetype' object is not iterable
2020-12-24T21:19:21.881667+00:00 app[web.1]: [W 201224 21:19:21 connection:255] Secure redis scheme specified (rediss) with no ssl options,defaulting to insecure SSL behavIoUr.

看起来我需要以某种方式将证书传递给 broker_use_ssl,但我不确定在哪里或如何传递。

这一切都部署在 Heroku 上。 rediss URL 是我的生产应用程序中的内容,flower 是一个单独的应用程序。

芹菜上有{"ssl_cert_reqs": ssl.CERT_NONE}

部署在heroku上的花看起来像

requirements.txt 如下

celery==4.4.4
future==0.18.2
flower==0.9.7 
redis==3.5.3

然后是我尝试传入 ssl.CERT_NONEprocfile,它返回 0。它不起作用。

web: flower --port=$PORT --broker=$broKER_URL --basic_auth=$FLOWER_BASIC_AUTH --broker_use_ssl={"ssl_cert_reqs": 0}

谁能解释一下如何设置这些配置选项?

谢谢

解决方法

两天前与 broker_use_ssl 相关的修复似乎是从 mergedmaster。不确定它是否只是改进或错误修复。有一个相关的问题 here。请注意,最新版本尚未包含此修复程序(4 天前发布)。

无论如何,您可以尝试以下方法:

  1. 与您传递 --broker_use_ssl 值的方式有关 - 也许您需要对引号进行转义,例如:--broker_use_ssl={\"ssl_cert_reqs\": 0}--broker_use_ssl="{\"ssl_cert_reqs\": 0}"
  2. 尝试通过 configuration file 而不是命令行传递您的设置,例如:flower --conf=celeryconfig.py - 这样您就不需要处理转义,您可以像以前一样设置值( {"ssl_cert_reqs": 0}).
  3. 使用 master 分支查看最后一次提交是否解决了您的问题。

祝你好运!