Django Queue Health

Simple django app for checking queue health. Targeted to be used for Kubernetes deployments to periodically schedule update_queue_timestamp and set timestamp and verified by test_queue_health as a probe to verify if worker works and is not stucked.

For an up to date and maintained version of this library, please checkout gitlab.com

Installation

Using pip:

pip install django-queue-health

From git:

pip install git+https://gitlab.com/adaptiware/django-queue-health.git

Usage

1. Add "queuehealth" to your INSTALLED_APPS setting like this:

INSTALLED_APPS = [
...,
'queuechecker',
]

2. Add variable "DQH_TRESHOLD" to your settings like this:

# Minutes treshold to check if there is queue log and if queue is running
DQH_TRESHOLD = 10

3. Configure default django cache.
4. Queue Health use django rq or celery.
5. Use commands:

# Push job to queue that updates the timestamp 

python manage.py update_queue_timestamp 

# Check if timestamp in cache less than trashold

python manage.py test_queue_health