KVMCloud 文档

# 国内（Gitee 分发）
curl -fsSL https://gitee.com/yuntianojo/kvmcloud/raw/main/install.sh -o /tmp/kc.sh \
  && sudo bash /tmp/kc.sh all-in-one

# 海外（德国 CDN 分发）
curl -fsSL https://cdn.kvm.mianyun.cloud/install-overseas.sh -o /tmp/kc.sh \
  && sudo bash /tmp/kc.sh all-in-one

# 主控
sudo bash /tmp/kc.sh control

# 每台计算节点（JOIN_TOKEN 从主控安装摘要或 control.env 获取）
sudo bash /tmp/kc.sh agent \
  --control-addr 10.0.0.10:9443 --token <JOIN_TOKEN> \
  --cpu-ratio 4 --mem-ratio 1.5 --disk-ratio 2 --bw-ratio 1

cat /var/lib/kvmcloud/control-ui-path     # 控制台路径
grep ADMIN_PASSWORD /etc/cloud/control.env # 初始管理员口令

Authorization: Bearer <TOKEN>

Idempotency-Key: 6f1c2a9e-4b3d-4f8a-9c21-7e5b0d3a8f14

{
  "error": {
    "code": "capacity_unavailable",
    "request_id": "9a3f…"
  }
}

HTTP/1.1 202 Accepted
Location: /api/v1/tasks/3f2a9c11-…

{ "task_id": "3f2a9c11-…", "state": "running" }

# 充值
POST /api/v1/billing/wallets/CNY/topups
{ "amount": 10000, "external_ref": "PAY-8891" }

BASE="https://your-control:27400"
TOKEN="$KVMCLOUD_TOKEN"
VM_URL="$BASE/api/v1/vms"

# 1) 创建（指定节点；省略 node_id 则自动调度）
RESP=$(curl -sS -X POST "$VM_URL" \
  -H "Authorization: Bearer $TOKEN" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $(uuidgen)" \
  -d '{
    "name": "web-fra-01",
    "image_source_name": "debian-12",
    "network_id": "00000000-0000-0000-0000-000000000003",
    "node_id": "b1f0c2d3-…",
    "vcpus": 4, "memory_mib": 8192, "root_disk_gib": 40,
    "bandwidth": { "min_kbps": 20000, "max_kbps": 100000, "priority": 10 }
  }')

TASK=$(echo "$RESP" | python3 -c 'import sys,json;print(json.load(sys.stdin)["task_id"])')

# 2) 轮询任务到终态
while :; do
  ST=$(curl -sS "$BASE/api/v1/tasks/$TASK" -H "Authorization: Bearer $TOKEN" \
        | python3 -c 'import sys,json;print(json.load(sys.stdin)["state"])')
  echo "state=$ST"
  case "$ST" in succeeded|failed|cancelled) break;; esac
  sleep 2
done

import json, urllib.request

BASE = "https://your-control:27400"
TOKEN = "kc_..."

def get(path):
    req = urllib.request.Request(BASE + path, headers={
        "Authorization": "Bearer " + TOKEN,
    })
    with urllib.request.urlopen(req, timeout=15) as r:
        return json.load(r)

# ids 精确批查（≤100），绕开 200 条列表窗口
ids = ["7d31…", "9f02…"]
data = get("/api/v1/vms?ids=" + ",".join(ids))
for vm in data["items"]:
    print(vm["id"], vm["state"])

import json, uuid, urllib.request

def post(path, body):
    req = urllib.request.Request(
        BASE + path, data=json.dumps(body).encode(), method="POST",
        headers={
            "Authorization": "Bearer " + TOKEN,
            "Content-Type": "application/json",
            "Idempotency-Key": str(uuid.uuid4()),
        })
    with urllib.request.urlopen(req, timeout=15) as r:
        return json.load(r)

res = post(f"/api/v1/tenants/{TENANT_ID}/traffic-packages", {
    "product_id": PRODUCT_ID,
    "quantity": 1,
    "node_id": NODE_ID,               # 省略 = 租户级
    "external_ref": "BILL-2026-1108-001",
})
print(res.get("grant_task_id"))  # 节点下发任务 ID

func do(ctx context.Context, method, url string, body []byte) ([]byte, error) {
    key := uuid.NewString() // 重试必须复用同一个键
    for attempt := 0; attempt < 5; attempt++ {
        req, _ := http.NewRequestWithContext(ctx, method, url, bytes.NewReader(body))
        req.Header.Set("Authorization", "Bearer "+token)
        req.Header.Set("Content-Type", "application/json")
        req.Header.Set("Idempotency-Key", key)
        resp, err := http.DefaultClient.Do(req)
        if err != nil || resp.StatusCode >= 500 {
            time.Sleep(time.Duration(1<<attempt) * time.Second)
            continue
        }
        defer resp.Body.Close()
        if resp.StatusCode >= 400 {
            return nil, fmt.Errorf("api %d", resp.StatusCode)
        }
        return io.ReadAll(resp.Body)
    }
    return nil, errors.New("retries exhausted")
}