pynenc-mongo 0.1.0

MongoDB plugin for Pynenc distributed task management system

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.