I want to know if celery supports TLS enabled RabbitMQ configuration?
and if yes then how we can make it work or any workaround possible
I have tried by using below source in my celery.py file of my Django application
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
import ssl
os.environ.setdefault('DJANGO_SETTINGS_MODULE', '<app_name>.settings')
BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
app = Celery('<app_name>')
app.conf.broker_use_ssl = {
'keyfile': '<path>/client_key.pem',
'certfile': '<path>/client_certificate.pem',
'ca_certs': '<path>/ca_certificate.pem',
'cert_reqs': ssl.CERT_REQUIRED
}
app.conf.broker_url = 'amqps://rabbitmq.example.com:5671/vhostname'
app.conf.broker_login_method = 'EXTERNAL'
app.autodiscover_tasks()
through the above code I am able to connect to the rabbitMQ server
but background tasks are not processing
I highly appreciate your help onto this
Top comments (0)