Dynamic queues in Celery

celeryconfig.py

CELERY_IMPORTS = ('tasks')
CELERY_IGNORE_RESULT = True
CELERY_RESULT_BACKEND = 'amqp'
CELERYD_PREFETCH_MULTIPLIER = 1

start.py

import tasks


def send_requests(count, snd=0, queue='def'):
    for i in range(count):
        tasks.add.apply_async(args=(i, snd), queue=queue)


tasks.app.control.add_consumer('foo', reply=True)
tasks.app.control.add_consumer('bar', reply=True)

send_requests(30, 0, 'foo')
send_requests(10, 100, 'bar')

tasks.py

from __future__ import absolute_import

from celery import Celery
import celeryconfig
import time

app = Celery()
app.config_from_object(celeryconfig)


@app.task()
def add(x, y):
    time.sleep(0.3)
    return x + y

if __name__ == '__main__':
    app.start()