Fast RabbitMQ task management library for asynchronous message handling.
Features
Asynchronous RabbitMQ message handling
Task queue management with Pydantic validation
Robust retry mechanisms with Tenacity
Easy-to-use decorators for consumers and producers
Support for both sync and async handlers
Installation
pip install fast-mq-taskQuick Start
Producer Example:
from fast_mq_task import Producer
from fast_mq_task.models import TaskMessage
producer = Producer()
await producer.publish_task(task_message)Consumer Example:
from fast_mq_task import Consumer
from fast_mq_task.register import consumer
@consumer(queue_name="task_queue")
async def handle_task(message: TaskMessage):
# Process your task here
passRequirements
Python >= 3.7
aio-pika
pydantic
tenacity
License
BSD License
1 maintainer
Release files for fast-mq-task 4.0.4
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| fast_mq_task-4.0.4.tar.gz | 28.1 kB | Details |
Release files / fast_mq_task-4.0.4.tar.gz
| Download URL | fast_mq_task-4.0.4.tar.gz |
|---|---|
| Size | 28.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
b6a3f0d1b4ea23541c58b9f9d41c743ca09c751c8b22d68e9bc85e3749424f5a
|
|
BLAKE2b-256 checksum How to use checksums |
bdc0d7ae8c3c426b1f8e5128642b2900980118ba8f90f8c1ab859af378969720
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.11.9
|
