Search code examples
pythondjangorabbitmqcelerydjango-celery

I need a django-celery daemon to listen to specific rabbitmq channel


In fact I have few django applications with celery tasks. I need each task to be executed within particular channel so that I can control the load. For example I may have 3 servers listen to channel_for_app_1 and two to channel_for_app_2. My question is how can I run celery daemon and specify the channel? Any other ways to do that?


Solution

  • Please review this page: http://docs.celeryproject.org/en/latest/userguide/routing.html.

    Your celery just should start with -Q, --queue settings, which define which queue will be used for fetching tasks