How to Ship Logs to an Aggregator Endpoint in Python

import json
import requests
from datetime import datetime, timezone

LOG_ENTRIES = [
    {"timestamp": "2024-01-15T10:00:00Z", "level": "INFO", "message": "Server started"},
    {"timestamp": "2024-01-15T10:00:05Z", "level": "WARN", "message": "High memory usage"},
    {"timestamp": "2024-01-15T10:00:10Z", "level": "ERROR", "message": "Database connection lost"},
]

def ship_logs(entries: list[dict]) -> int:
    """Send log entries to an aggregator endpoint and return HTTP status."""
    try:
        response = requests.post(
            "https://httpbin.org/post",
            json={"source": "web-app", "logs": entries},
            timeout=5
        )
        response.raise_for_status()
        return response.status_code
    except requests.RequestException as exc:
        print(f"Shipping failed: {exc}")
        return -1

if __name__ == "__main__":
    # Simulate shipping at a given timestamp
    batch = {
        "received_at": datetime.now(timezone.utc).isoformat(),
        "logs": LOG_ENTRIES
    }
    
    status = ship_logs([batch])
    print(f"HTTP {status} - Shipped {len(LOG_ENTRIES)} log entries")