actvalue.mongo-client 0.1.0

Singleton MongoDB client for AWS Lambda and serverless environments

actvalue.mongo-client

Singleton client for MongoDB connection

Install

pip install actvalue.mongo-client

Or with uv:

uv add actvalue.mongo-client

Client Usage

The client is used to create and share MongoDB connection pool.

import asyncio
from mongo_client import mongo

# Initialize your connection parameters and optionally set pool size
import os
os.environ['MONGO_URL'] = 'mongodb+srv://<your-connection>/database'
os.environ['MONGO_POOL_SIZE'] = '5'  # default value

async def main():
    # Create connection pool if not existing already
    db = await mongo.get_db()
    users = db["users"]
    await users.insert_one({"username": "test123", "password": "test123"})
    
    # Some other time, some other place in code
    # Connection pool is reused
    db = await mongo.get_db()
    user = await users.find_one({"username": "test123"})
    print(user)

asyncio.run(main())

AWS Lambda Usage

Perfect for serverless environments where connection reuse is critical:

import os
from mongo_client import mongo

# Set environment variables (typically from Lambda configuration)
os.environ['MONGO_URL'] = 'mongodb+srv://...'
os.environ['MONGO_POOL_SIZE'] = '5'

async def lambda_handler(event, context):
    # Connection is reused across Lambda invocations
    db = await mongo.get_db()
    collection = db["my_collection"]
    
    result = await collection.find_one({"_id": event["id"]})
    return {"statusCode": 200, "body": result}

Features

• 🚀 Async/await support with PyMongo 4.0+
• 🔄 Singleton pattern for connection reuse
• 🔒 Thread-safe connection initialization
• ⚙️ Environment-based configuration
• 📦 Connection pooling optimized for serverless
• ⏱️ Configurable timeouts and pool size
• 🎯 Designed for AWS Lambda and similar platforms

Environment Variables

• MONGO_URL: MongoDB connection string (required)
• MONGO_POOL_SIZE: Connection pool size (optional, default: "5")

License

MIT