Celery SQS settings for Django

django_settings_celery_sqs.py

from kombu.utils.url import safequote
SQS = config('SQS', cast=bool, default=False)
if SQS:
    SQS_ACCESS_KEY = config('SQS_ACCESS_KEY', cast=str)
    SQS_SECRET_KEY = config('SQS_SECRET_KEY', cast=str)
    SQS_URL = config('SQS_URL', cast=str)

    CELERY_BROKER_URL = f'sqs://{safequote(SQS_ACCESS_KEY)}:{safequote(SQS_SECRET_KEY)}@'
    CELERY_TASK_DEFAULT_QUEUE = 'main-queue.fifo'
    CELERY_BROKER_TRANSPORT_OPTIONS = {
        'region': 'us-west-2',
        'predefined_queues': {
            'main-queue.fifo': {
                'url': SQS_URL,
                'access_key_id': SQS_ACCESS_KEY,
                'secret_access_key': SQS_SECRET_KEY,
            },
        },
    }