pynenc-rabbitmq 0.1.6

RabbitMQ plugin for pynenc, a distributed task queue for Python.

Pynenc RabbitMq Plugin

RabbitMq state backend plugin for Pynenc, providing distributed task state management using RabbitMq as the storage backend.

Features

• 🚀 High Performance: Optimized RabbitMq operations with connection pooling
• 🔒 Distributed Locking: RabbitMq-based distributed locks for task coordination
• 🎯 Type Safe: Full type hints and mypy compatibility
• 🧪 Well Tested: Comprehensive test suite with multiple RabbitMq versions
• 📊 Production Ready: Battle-tested configuration options and monitoring

Quick Start

Installation

pip install pynenc-rabbitmq

Basic Usage

from pynenc import Pynenc
from pynenc_rabbitmq import RabbitMqStateBackend

# Create Pynenc app with RabbitMq backend
app = Pynenc().with_state_backend(
    RabbitMqStateBackend.from_uri("rabbitmq://localhost:27017/pynenc")
)

@app.task
def my_task(x: int, y: int) -> int:
    return x + y

# Use your tasks as normal
result = my_task(1, 2)

Configuration

Connection Configuration

from pynenc_rabbitmq import RabbitMqStateBackend, ConfigRabbitMq

config = ConfigRabbitMq(
    uri="rabbitmq://localhost:27017",
    database_name="my_pynenc_db",
    max_pool_size=100,
    write_concern_w="majority",
    read_preference="primaryPreferred"
)

backend = RabbitMqStateBackend(config)

Environment Variables

You can also configure via environment variables:

export PYNENC_RABBITMQ_URI="rabbitmq://localhost:27017"
export PYNENC_RABBITMQ_DATABASE="pynenc"
export PYNENC_RABBITMQ_MAX_POOL_SIZE="100"

Documentation

• Configuration Guide
• Usage Examples
• Migration Guide

Development

Setup

1. Clone the repository
2. Install dependencies: poetry install --with dev
3. Start RABBITMQ: docker-compose -f docker/docker-compose.yml up -d
4. Run tests: poetry run pytest

Contributing

We welcome contributions! Please see CONTRIBUTING.md for guidelines.

License

This project is licensed under the MIT License - see the LICENSE file for details.