workerlib 0.5.0

Async RabbitMQ worker utilities

WorkerLib

Асинхронные утилиты для работы с RabbitMQ: пул воркеров, очереди, retry, DLQ, вебхуки. Основа — aio-pika.

Установка

pip install workerlib

Python 3.10+.

Минимальный пример

import asyncio
from workerlib import WorkerPool

async def task_handler(data: dict) -> bool:
    print(data)
    return True

async def main():
    async with WorkerPool() as pool:
        pool.add_worker("tasks", task_handler)
        await pool.send("tasks", {"id": 1})

asyncio.run(main())

Документация

Полное описание, конфигурация, обработка ошибок, метрики, вебхуки и интеграция с FastAPI — в каталоге docs/:

• Обзор и навигация
• Быстрый старт
• Руководство (конфигурация, ошибки, метрики, вебхуки, FastAPI)
• Справочник API