aioq 0.4.0

Async job queue with multiple backend support and built-in dashboard

aioq

Async job queue for Python with Redis, PostgreSQL, and MySQL backends, priority queues, job dependencies, dead letter queues, and a built-in real-time dashboard.

Documentation · PyPI

Install

pip install aioq                # Redis only
pip install "aioq[postgres]"    # + PostgreSQL
pip install "aioq[mysql]"       # + MySQL
pip install "aioq[all]"         # everything

Quick start

# tasks.py
from aioq import Aarq
from aioq.backends import RedisBroker

app = Aarq(broker=RedisBroker(url="redis://localhost:6379"))

@app.task(queue="default", retries=3)
async def my_task(ctx, value: int):
    ...

aioq worker tasks:app       # run a worker
aioq dashboard tasks:app    # dashboard at :8080

See the docs for full usage.

License

MIT