skip to navigation
skip to content

aiodisque 0.1

Asyncio Disque client

Python3.5 & Asyncio client for Disque message broker.

Installation

aiodisque requires a running disque server.

python -m pip install -e .

Getting started

Usage:

from aiodisque import Disque
client = Disque()
job_id = await client.sendjob('queue', 'body')

client accepts a tcp or unix address:

client = Disque(address='127.0.0.1:7711')
client = Disque(address=('127.0.0.1', 7711))
client = Disque(address='/path/to/socket')

API Reference

The official Disque command documentation does a great job of explaining each command in detail. There are a few exceptions:

  • each method are lowered
  • async keywords are replaced by asynchronous

In addition to the changes above, it implements some async sugar:

  • Fancy async iterators:

    async for jobs in client.client.getjob_iter('q', nohang=True):
        print(jobs)
    
    async for queue in client.qscan_iter(count=128):
        print(queue)
    
    async for job in client.jscan_iter(count=128):
        print(job)
    
  • There is also an experimentaton that try to mimic an asyncio.Queue:

    from aiodisque.queue import Queue
    queue = JobsQueue('queue', client)
    job_id = await queue.put('job')
    job = await queue.get()
    assert job.id == job_id
    
  • client can reconnect automatically when a connection lost:

    from aiodisque import Disque
    client = Disque(auto_reconnect=True)
    await client.hello()
    # ... connection has been lost here...
    await client.hello()  # this not fails
    
 
File Type Py Version Uploaded on Size
aiodisque-0.1-py2.py3-none-any.whl (md5) Python Wheel py2.py3 2016-01-08 14KB
aiodisque-0.1.tar.gz (md5) Source 2016-01-08 26KB