Skip to main content

A distributer that helps to publish to a queue and process tasks from a queue

Project description


A queue manager based on rq and made for impulsare. It helps to : - add items to a queue - listen for a queue via a cli listener

See tests/static/ for examples of configuration.

Installation / Usage

To install use pip:

$ pip install --upgrade impulsare-distributer


You need to create/add to your configuration file:

    # Required, redis address

    # Optional
    port: 6379

# If a component needs to send data to a queue,
# define here where what is the queue's name (next one)
# used by impulsare-ruler to send to writer for example (ruler: {queue: writer})
    queue: my_test_queue


This is a simple implementation of rq's worker. If you need to listen for a queue, no need to have a config file, run in cli:

$ queue-listener --host redis --queue my_test_queue

To be able to see the next example working, keep that opened in a separate window.

Queue Usage

To use the queue manager, and send jobs to be processed:

from impulsare_distributer import QueueManager
from mymodule import my_method

queue = QueueManager(config_file='tests/static/config_valid.yml', listener='testqueue')
queue.add(method=my_method, item='Hello World', job='test')

Development & Tests

$ pip install -r requirements.txt
$ pip install -r requirements-dev.txt
$ py.test

If you run your tests with a different redis server than localhost:

$ REDIS=redis py.test

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for impulsare-distributer, version 1.0b4
Filename, size File type Python version Upload date Hashes
Filename, size impulsare-distributer-1.0b4.tar.gz (4.0 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page