observo-handler 1.0.1

Real-time logging handler for Observo platform

Observo Handler

Real-time Python logging handler for Observo centralized logging platform.

Features

• 🚀 Real-time logging - Logs sent instantly to Observo
• 🔍 Request tracing - Automatic request_id for all logs
• 👤 User tracking - Automatic user_id for authenticated users
• 📦 Batching - Efficient batch sending to reduce network overhead
• 🛡️ Fail-safe - Won't crash your app if Observo is unavailable
• 🧵 Thread-safe - Background workers handle async sending

Installation

pip install observo-handler

# Or install from source
pip install git+https://github.com/kennedy-ak/observo-handler.git

# Or install locally
pip install /path/to/observo-handler

Quick Start

1. Add to Django settings.py

LOGGING = {
    'version': 1,
    'disable_existing_loggers': False,
    'handlers': {
        'console': {
            'class': 'logging.StreamHandler',
        },
        'observo': {
            'class': 'observo_handler.ObservoHandler',
            'level': 'INFO',
            'project_id': 'your-project-id-here',
            'api_key': 'your-api-key-here',
            'observo_url': 'https://observo.yourdomain.com/api/v1/ingest/',
            'batch_size': 10,
            'flush_interval': 5,
        },
    },
    'root': {
        'handlers': ['console', 'observo'],
        'level': 'INFO',
    },
    'loggers': {
        'django': {
            'handlers': ['console', 'observo'],
            'level': 'INFO',
            'propagate': False,
        },
    },
}

2. Add Middleware (Optional - for request tracing)

MIDDLEWARE = [
    'django.middleware.security.SecurityMiddleware',
    'observo_handler.middleware.RequestIDMiddleware',  # Add this
    # ... rest of middleware
]

3. Use in Your Code

import logging

logger = logging.getLogger(__name__)

def my_view(request):
    logger.info('User accessed view')
    
    try:
        # Your code
        result = do_something()
        logger.debug('Operation successful', extra={'extra_data': {'result': result}})
    except Exception as e:
        logger.error('Operation failed', exc_info=True)

Configuration

Handler Parameters

• project_id (required): Your Observo project ID
• api_key (required): Your Observo API key
• observo_url (required): Observo API endpoint URL
• batch_size (optional): Number of logs to batch before sending (default: 10)
• flush_interval (optional): Seconds between automatic flushes (default: 5)
• level (optional): Minimum log level to capture (default: NOTSET)

Getting Credentials

1. Login to your Observo dashboard
2. Create or select a project
3. Copy the Project ID and API Key from project settings

Advanced Usage

Custom Metadata

Add custom metadata to logs:

logger.info(
    'User performed action',
    extra={
        'extra_data': {
            'action': 'purchase',
            'amount': 99.99,
            'currency': 'USD'
        }
    }
)

Manual Flushing

import logging

# Get the Observo handler
for handler in logging.getLogger().handlers:
    if isinstance(handler, ObservoHandler):
        handler.flush()  # Force send remaining logs

How It Works

Your Django App
    ↓
Logger.info("message")
    ↓
ObservoHandler.emit()
    ↓
Background Queue (thread-safe)
    ↓
Batch Worker (batches logs)
    ↓
HTTP POST to Observo API
    ↓
Observo Dashboard

Comparison: Handler vs File Shipper

File Shipper (existing)

App → Log File → Shipper reads → Observo
      (5 sec delay)

Handler (new)

App → ObservoHandler → Observo (instant)

Requirements

• Python >= 3.8
• Django >= 3.2
• requests >= 2.25.0

License

MIT License

Support

📧 Email: [e-mail]

📚 Documentation: https://github.com/kennedy-ak/observo-handler

🐛 Issues: https://github.com/kennedy-ak/observo-handler/issues

💬 Discussions: https://github.com/kennedy-ak/observo-handler/discussions