This is a prototype to schedule jobs in the backend based on some priority using Rabbitmq and Celery.

In this sample project, the powers of Celery and RabbitMQ in prioritized tasking can be seen. The simulation for transcoding a video to

• 360p resolution takes 5 seconds
• 480p resolution takes 10 seconds
• 720p resolution takes 15 seconds
• 1080p resolution takes 20 seconds

Of course this isn't even close to the real scencario, but it's good enough to observe the prioritized tasking.

These are the things to keep in mind to enable priority tasking without getting into trouble or unnecessary errors.

• 'x-max-priority': 10 This argument must be provided to the queue so that RabbitMQ knows that tasks should be prioritized.
• There is a possibility that the queue has no chance to prioritize the messages (because they get downloaded before the sorting happens). Prefetch multiplier is 4 by default.

CELERY_ACKS_LATE = True
CELERYD_PREFETCH_MULTIPLIER = 1

• First, run pip install -r requirements.txt and go into the directory cd celery-priority-tasking/celery_sample_project.
• Run python main.py for starting up Flask.
• Then, in another terminal, run celery worker -c [number of workers] -A tasks -Q tasks --loglevel=info &.
• Open up a browser and start simulating!

There is a small preview video here with only 1 Celery worker so that it's easy to observe the tasks getting sorted.

To install dependencies on Debian machines, use the script provided or otherwise modify it accordingly for other operating systems.

• Executing tasks (Official Celery doc)
• Celery (full stack python)
• Task Queues (full stack python)
• How to integrate RabbitMQ with Celery?