pynenc-mongo 0.1.4

MongoDB plugging for pynenc, a distributed task queue for Python.

Pynenc MongoDB Plugin

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

Features

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

Quick Start

Installation

pip install pynenc-mongodb

Basic Usage

from pynenc import Pynenc
from pynenc_mongodb import MongoStateBackend

# Create Pynenc app with MongoDB backend
app = Pynenc().with_state_backend(
    MongoStateBackend.from_uri("mongodb://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_mongodb import MongoStateBackend, ConfigMongoDB

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

backend = MongoStateBackend(config)

Environment Variables

You can also configure via environment variables:

export PYNENC_MONGODB_URI="mongodb://localhost:27017"
export PYNENC_MONGODB_DATABASE="pynenc"
export PYNENC_MONGODB_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 MongoDB: 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.