django-q

A multiprocessing distributed task queue for Django

Features

Multiprocessing worker pool
Asynchronous tasks
Scheduled, cron and repeated tasks
Signed and compressed packages
Failure and success database or cache
Result hooks, groups and chains
Django Admin integration
PaaS compatible with multiple instances
Multi cluster monitor
Redis, Disque, IronMQ, SQS, MongoDB or ORM
Rollbar and Sentry support

Requirements

Tested with: Python 3.7, 3.8, 3.9 Django 2.2.X and 3.2.X

Brokers

Installation

Install the latest version with pip:
```
$ pip install django-q
```
Add django_q to your INSTALLED_APPS in your projects settings.py:
```
INSTALLED_APPS = (
    # other apps
    'django_q',
)
```
Run Django migrations to create the database tables:
```
$ python manage.py migrate
```
Choose a message broker , configure and install the appropriate client library.

Read the full documentation at https://django-q.readthedocs.org

Configuration

All configuration settings are optional. e.g:

# settings.py example
Q_CLUSTER = {
    'name': 'myproject',
    'workers': 8,
    'recycle': 500,
    'timeout': 60,
    'compress': True,
    'cpu_affinity': 1,
    'save_limit': 250,
    'queue_limit': 500,
    'label': 'Django Q',
    'redis': {
        'host': '127.0.0.1',
        'port': 6379,
        'db': 0, }
}

For full configuration options, see the configuration documentation.

Management Commands

Start a cluster with:

$ python manage.py qcluster

Monitor your clusters with:

$ python manage.py qmonitor

Monitor your clusters’ memory usage with:

$ python manage.py qmemory

Check overall statistics with:

$ python manage.py qinfo

Creating Tasks

Use async_task from your code to quickly offload tasks:

from django_q.tasks import async_task, result

# create the task
async_task('math.copysign', 2, -2)

# or with a reference
import math.copysign

task_id = async_task(copysign, 2, -2)

# get the result
task_result = result(task_id)

# result returns None if the task has not been executed yet
# you can wait for it
task_result = result(task_id, 200)

# but in most cases you will want to use a hook:

async_task('math.modf', 2.5, hook='hooks.print_result')

# hooks.py
def print_result(task):
    print(task.result)

For more info see Tasks

Schedule

Schedules are regular Django models. You can manage them through the Admin page or directly from your code:

# Use the schedule function
from django_q.tasks import schedule

schedule('math.copysign',
         2, -2,
         hook='hooks.print_result',
         schedule_type=Schedule.DAILY)

# Or create the object directly
from django_q.models import Schedule

Schedule.objects.create(func='math.copysign',
                        hook='hooks.print_result',
                        args='2,-2',
                        schedule_type=Schedule.DAILY
                        )

# Run a task every 5 minutes, starting at 6 today
# for 2 hours
import arrow

schedule('math.hypot',
         3, 4,
         schedule_type=Schedule.MINUTES,
         minutes=5,
         repeats=24,
         next_run=arrow.utcnow().replace(hour=18, minute=0))

# Use a cron expression
schedule('math.hypot',
         3, 4,
         schedule_type=Schedule.CRON,
         cron = '0 22 * * 1-5')

For more info check the Schedules documentation.

Testing

To run the tests you will need the following in addition to install requirements:

py.test
pytest-django
Disque from https://github.com/antirez/disque.git
Redis
MongoDB

Or you can use the included Docker Compose file.

The following commands can be used to run the tests:

# Create virtual environment
python -m venv venv

# Install requirements
venv/bin/pip install -r requirements.txt

# Install test dependencies
venv/bin/pip install pytest pytest-django

# Install django-q
venv/bin/python setup.py develop

# Run required services (you need to have docker-compose installed)
docker-compose -f test-services-docker-compose.yaml up -d

# Run tests
venv/bin/pytest

# Stop the services required by tests (when you no longer plan to run tests)
docker-compose -f test-services-docker-compose.yaml down

Locale

Currently available in English, German and French. Translation pull requests are always welcome.

Todo

Better tests and coverage
Less dependencies?

Acknowledgements

Django Q was inspired by working with Django-RQ and RQ
Human readable hashes by HumanHash
Redditors feedback at r/django
JetBrains for their Open Source Support Program

Metadata

Release files for django-q 1.3.9

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for django-q 1.3.9
File	Size	Uploaded
django-q-1.3.9.tar.gz	72.1 kB	Jun 27, 2021	Details

Built distribution (wheel)

Table of built distributions (wheels) for django-q 1.3.9
File	Interpreter	ABI	Platform	Reset
django_q-1.3.9-py3-none-any.whl 90.0 kB Jun 27, 2021	Python 3	none	any	Details

Total release size: 162.1 kB

Release files / django-q-1.3.9.tar.gz

Download URL	django-q-1.3.9.tar.gz
Size	72.1 kB
Tags	Source
SHA-256 checksum How to use checksums	`5c6b4d530aa3aabf9c6aa57376da1ca2abf89a1562b77038b7a04e52a4a0a91b`
BLAKE2b-256 checksum How to use checksums	`3f49d54c6631bce6fea588ad31cd4f1b7538a4f5e6e7b85a5187c5de72c9fa75`
Upload date	Jun 27, 2021
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`poetry/1.1.6 CPython/3.8.5 Linux/5.4.72-microsoft-standard-WSL2`

Release files / django_q-1.3.9-py3-none-any.whl

Download URL	django_q-1.3.9-py3-none-any.whl
Size	90.0 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`1b74ce3a8931990b136903e3a7bc9b07243282a2b5355117246f05ed5d076e68`
BLAKE2b-256 checksum How to use checksums	`bf4c150dcb7bb9e5e0c67da2b1773823f44378f1160973cef3fe2923b840aa72`
Upload date	Jun 27, 2021
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`poetry/1.1.6 CPython/3.8.5 Linux/5.4.72-microsoft-standard-WSL2`