chasquimq 1.0.0

The fastest open-source message broker for Redis.

chasquimq (Python)

Python bindings for ChasquiMQ — the fastest open-source message broker for Redis. The Rust engine pulls jobs; Python asyncio handlers process them.

Status: Phase 4, slice A4 (high-level shim). Public API is pre-1.0 and may change.

Layout

• src-rs/ — PyO3 Rust bindings, compiled as the chasquimq._native extension module.
• src/chasquimq/ — Python shim (the src layout); re-exports the native classes (Producer / Consumer / Scheduler) and the high-level surface (Queue / Worker / Job / QueueEvents) from one flat namespace.
• tests/ — pytest harness.

Build

cd chasquimq-py
maturin develop          # editable install into the active venv
pytest tests/            # smoke + integration tests (needs Redis 8.6+)
maturin build --release  # wheels under target/wheels/

Quickstart

import asyncio

from chasquimq import Queue, Worker, Job, RepeatPattern


async def send_email(job: Job) -> None:
    print(f"sending {job.data}")


async def main() -> None:
    queue = Queue("emails")

    # Enqueue a one-shot job.
    await queue.add("send-email", {"to": "[e-mail]"})

    # Enqueue a recurring job (fires every 60s on this worker process).
    await queue.add(
        "daily-digest",
        {"who": "all"},
        repeat=RepeatPattern.every(60_000),
    )

    # `concurrency` defaults to 100; tune it to your handler's I/O profile.
    worker = Worker("emails", send_email)
    try:
        await worker.run()
    finally:
        await worker.close()
        await queue.close()


asyncio.run(main())

Power-user surface

Native engine handles are re-exported from the same top-level package — no private _native import needed:

from chasquimq import Producer, Consumer, Scheduler

The high-level Job dataclass wins the unqualified Job name; if you need the native value type, import it explicitly:

from chasquimq._native import Job as NativeJob

See also

• Main repo README
• Phase 4 design doc

License

MIT — see LICENSE at the workspace root.