python - 无法使用 celery 启用 SSL

Question

我有带有 celery 的 Django 应用程序，运行良好。

app = Celery('backend', broker='amqp://guest:guest@localhost:5672//',)

然后我尝试使用 SSL 加密连接:

app = Celery('backend', broker='amqp://guest:guest@localhost:5672//',)
app.config_from_object('django.conf:settings', namespace='CELERY')

并使用settings.py:

import ssl

CELERY_BROKER_USE_SSL = {
  'keyfile': '/var/ssl/server-key.pem',
  'certfile': '/var/ssl/server-crt.pem',
  'ca_certs': '/var/ssl/ca-crt.pem',
  'cert_reqs': ssl.CERT_REQUIRED
}

按照 https://stackoverflow.com/a/34712536/6153117 中的描述定义证书但是当运行celery -A backend worker时，我收到了错误

[2018-03-04 16:27:16,771: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [SSL: UNKNOWN_PROTOCOL] unknown protocol (_ssl.c:645).
Trying again in 2.00 seconds...

[2018-03-04 16:27:18,794: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [SSL: UNKNOWN_PROTOCOL] unknown protocol (_ssl.c:645).
Trying again in 4.00 seconds...

Answer 1

对于 celery ssl，ssl_listeners 端口是 5671，并且您在broker_url 中提到了 5672，它用于 TCP 监听器。你需要改变它。

希望对您有所帮助。