Estoy usando Django y Celery y estoy tratando de configurar el enrutamiento a varias colas. Cuando especifico una tarearouting_key yexchange (ya sea en el decorador de tareas o usandoapply_async()), la tarea no se agrega al agente (que es Kombu conectándose a mi base de datos MySQL).

Si especifico el nombre de la cola en el decorador de tareas (lo que significa que la clave de enrutamiento se ignora), la tarea funciona bien. Parece ser un problema con la configuración de enrutamiento / intercambio.

¿Alguna idea de cuál podría ser el problema?

Aquí está la configuración:

settings.py

INSTALLED_APPS = (
    ...
    'kombu.transport.django',
    'djcelery',
)
BROKER_BACKEND = 'django'
CELERY_DEFAULT_QUEUE = 'default'
CELERY_DEFAULT_EXCHANGE = "tasks"
CELERY_DEFAULT_EXCHANGE_TYPE = "topic"
CELERY_DEFAULT_ROUTING_KEY = "task.default"
CELERY_QUEUES = {
    'default': {
        'binding_key':'task.#',
    },
    'i_tasks': {
        'binding_key':'important_task.#',
    },
}

tareas.py

from celery.task import task

@task(routing_key='important_task.update')
def my_important_task():
    try:
        ...
    except Exception as exc:
        my_important_task.retry(exc=exc)

Iniciar la tarea:

from tasks import my_important_task
my_important_task.delay()