Kombu & celery with SQS #222

[shoaib-mohd]

• celery with sqs SQS broker url doesn't include queue_name_prefix #222

SQS broker url doesn't include queue_name_prefix #222
ANSWER:-
I have used the below code for queue_name_prefix...
It is in Flask and Django App running on production..

from celery import Celery
def make_celery(app):
    celery = Celery(
        app.import_name,
        broker="sqs://",
        broker_transport_options={
            "queue_name_prefix": "{SERVICE_ENV}-{SERVICE_NAME}-"
        },
    )
    task_base = celery.Task

    class ContextTask(task_base):
        abstract = True

        def __call__(self, *args, **kwargs):
            with app.app_context():
                return task_base.__call__(self, *args, **kwargs)

    celery.Task = ContextTask

    return celery

[auvipy]

or should we use the docs in celery instead?

[shoaib-mohd]

It would help if you used the docs in Kombu and Celery.

[shoaib-mohd]

Hello @auvipy
Should I also contribute the same in Celery?

[auvipy]

I think we can hold of for now, but in future we might try