Tutorial: Log and monitor API errors

import json, logging, time, os, requests

logger = logging.getLogger("paradise")
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter("%(message)s"))
logger.addHandler(handler)
logger.setLevel(logging.INFO)

API_KEY = os.environ["PARADISE_API_KEY"]
BASE = os.environ.get("PARADISE_BASE_URL", "https://api.dev.paradisegateway.net")

def logged_request(method: str, path: str, payload: dict | None = None) -> dict:
    url = f"{BASE}{path}"
    headers = {"Content-Type": "application/json", "APIKEY": API_KEY}

    start = time.monotonic()
    try:
        resp = requests.request(method, url, headers=headers, json=payload, timeout=30)
        body = resp.json()
        elapsed = int((time.monotonic() - start) * 1000)

        log_entry = {
            "timestamp": time.strftime("%Y-%m-%dT%H:%M:%S.000Z", time.gmtime()),
            "level": "error" if resp.status_code >= 400 else "info",
            "http_method": method,
            "endpoint": path,
            "http_status": resp.status_code,
            "response_status": body.get("response_status"),
            "response_code": body.get("response_code"),
            "correlation_id": body.get("correlation_id"),
            "transaction_id": body.get("id"),
            "elapsed_ms": elapsed,
        }

        if resp.status_code >= 400 or body.get("response_status") in ("declined", "error"):
            log_entry["response_message"] = body.get("response_message")
            logger.error(json.dumps(log_entry))
        else:
            logger.info(json.dumps(log_entry))

        return body
    except Exception as e:
        elapsed = int((time.monotonic() - start) * 1000)
        logger.error(json.dumps({
            "timestamp": time.strftime("%Y-%m-%dT%H:%M:%S.000Z", time.gmtime()),
            "level": "error",
            "http_method": method,
            "endpoint": path,
            "error": str(e),
            "elapsed_ms": elapsed,
        }))
        raise