pynenc-rabbitmq 0.1.0

RabbitMq plugin for Pynenc distributed task management system

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.