pip install requests

export DM_API_KEY="dm_key_abc123def456"

import os
import requests
API_BASE = "https://api.datamammoth.com/v1"
API_KEY = os.environ.get("DM_API_KEY")
headers = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

response = requests.get(f"{API_BASE}/servers", headers=headers)
servers = response.json()["data"]
for server in servers:
    print(f"{server['name']} ({server['ip']}) - {server['status']}")

server_id = "srv_abc123"
response = requests.get(f"{API_BASE}/servers/{server_id}", headers=headers)
server = response.json()["data"]
print(f"Name: {server['name']}")
print(f"IP: {server['ip']}")
print(f"Status: {server['status']}")
print(f"Plan: {server['plan']}")
print(f"OS: {server['os']}")
print(f"CPU: {server['vcpus']} vCPUs")
print(f"RAM: {server['ram_mb']} MB")

new_server = {
    "name": "web-production",
    "plan": "vps-standard",
    "region": "us-east",
    "os": "ubuntu-24.04",
    "hostname": "web01.example.com",
    "tags": ["production", "web"]
}
response = requests.post(f"{API_BASE}/servers", headers=headers, json=new_server)
if response.status_code == 201:
    server = response.json()["data"]
    print(f"Server created: {server['id']} ({server['ip']})")
else:
    error = response.json()["error"]
    print(f"Error: {error['message']}")

server_id = "srv_abc123"
action = {"action": "restart"}
response = requests.post(
    f"{API_BASE}/servers/{server_id}/actions",
    headers=headers,
    json=action
)
if response.status_code == 200:
    print("Server restart initiated")
else:
    print(f"Error: {response.json()['error']['message']}")

response = requests.get(
    f"{API_BASE}/billing/invoices",
    headers=headers,
    params={"status": "unpaid"}
)
invoices = response.json()["data"]
for invoice in invoices:
    print(f"Invoice {invoice['number']}: ${invoice['total']:.2f} (due {invoice['due_date']})")

response = requests.get(f"{API_BASE}/billing/balance", headers=headers)
balance = response.json()["data"]
print(f"Account balance: ${balance['balance']:.2f} {balance['currency']}")

ticket = {
    "subject": "High CPU usage on web server",
    "department": "technical",
    "priority": "high",
    "server_id": "srv_abc123",
    "message": "CPU usage has been above 90% for the past 3 hours. "
               "Running htop shows MySQL as the top consumer."
}
response = requests.post(f"{API_BASE}/support/tickets", headers=headers, json=ticket)
if response.status_code == 201:
    ticket_data = response.json()["data"]
    print(f"Ticket created: {ticket_data['id']}")
else:
    print(f"Error: {response.json()['error']['message']}")

def fetch_all(endpoint, params=None):
    """Fetch all pages of a paginated endpoint."""
    all_items = []
    page = 1
    params = params or {}
    while True:
        params["page"] = page
        params["per_page"] = 50
        response = requests.get(
            f"{API_BASE}/{endpoint}",
            headers=headers,
            params=params
        )
        data = response.json()
        all_items.extend(data["data"])
        if not data["meta"]["has_next"]:
            break
        page += 1
    return all_items
Usage
all_servers = fetch_all("servers", {"status": "running"})
print(f"Total running servers: {len(all_servers)}")

import time
def api_request(method, endpoint, max_retries=3, **kwargs):
    """Make an API request with retry logic."""
    url = f"{API_BASE}/{endpoint}"
    for attempt in range(max_retries):
        response = requests.request(method, url, headers=headers, **kwargs)
        if response.status_code == 429:
            retry_after = int(response.headers.get("Retry-After", 2 ** attempt))
            print(f"Rate limited. Retrying in {retry_after}s...")
            time.sleep(retry_after)
            continue
        if response.status_code >= 500:
            wait = 2 ** attempt
            print(f"Server error {response.status_code}. Retrying in {wait}s...")
            time.sleep(wait)
            continue
        return response
    raise Exception(f"Max retries exceeded for {endpoint}")
Usage
response = api_request("GET", "servers")
servers = response.json()["data"]

from flask import Flask, request, jsonify
import hmac
import hashlib
app = Flask(__name__)
WEBHOOK_SECRET = "your_webhook_secret"
@app.route("/webhooks/datamammoth", methods=["POST"])
def handle_webhook():
    signature = request.headers.get("X-Webhook-Signature", "")
    payload = request.get_data(as_text=True)
    expected = hmac.new(
        WEBHOOK_SECRET.encode(),
        payload.encode(),
        hashlib.sha256
    ).hexdigest()
    if not hmac.compare_digest(f"sha256={expected}", signature):
        return jsonify({"error": "Invalid signature"}), 401
    event = request.json
    print(f"Received event: {event['event']}")
    if event["event"] == "server.status_changed":
        server = event["data"]
        print(f"Server {server['name']} changed to {server['new_status']}")
    return jsonify({"status": "ok"}), 200