skip to navigation
skip to content

dj-pq 1.4.2

``pq`` wrapper for django

pq wrapper for django.

Installation

pip install dj-pq

Configuration

Add dj_pq to your INSTALLED_APPS:

INSTALLED_APPS += [
    'dj_pq',
]

Apply migrations:

./manage.py migrate

Usage

dj-pq exposes the pq tasks API.

from dj_pq import get_queue

queue = get_queue('notifications')

@queue.task()
def notify(user_id):
    User.objects.get(id=user_id).notify()

notify(42)

Optionally a Queue can be bound to a specific database connection:

queue = get_queue('notifications', 'another_connection')

A worker command allows to start a worker for a given queue:

./manage.py worker notifications
 
File Type Py Version Uploaded on Size
dj-pq-1.4.2.tar.gz (md5) Source 2016-03-30 3KB