Read machine metrics and console logs

export ORNN_API_URL='https://api.ornn.com'
export NODE_ID='<node-id>'
END="$(date -u +%Y-%m-%dT%H:%M:%SZ)"
START="$(date -u -d '1 hour ago' +%Y-%m-%dT%H:%M:%SZ)"  # GNU date

curl --fail-with-body \
  "$ORNN_API_URL/v1/observability/nodes/$NODE_ID/telemetry/latest" \
  -H "Authorization: Bearer $ORNN_API_KEY"

curl --fail-with-body -G \
  "$ORNN_API_URL/v1/observability/nodes/$NODE_ID/telemetry/query" \
  -H "Authorization: Bearer $ORNN_API_KEY" \
  --data-urlencode "start=$START" --data-urlencode "end=$END" \
  --data-urlencode 'metrics=gpu_utilization,gpu_temperature' \
  --data-urlencode 'max_points=60'

curl --fail-with-body -G \
  "$ORNN_API_URL/v1/observability/nodes/$NODE_ID/logs/kernel/query" \
  -H "Authorization: Bearer $ORNN_API_KEY" \
  --data-urlencode "start=$START" --data-urlencode "end=$END" \
  --data-urlencode 'limit=200'

import json
import os
from datetime import datetime, timedelta, timezone

import requests

API = "https://api.ornn.com"
session = requests.Session()
session.headers["Authorization"] = f"Bearer {os.environ['ORNN_API_KEY']}"
node_id = os.environ["NODE_ID"]

latest = session.get(f"{API}/v1/observability/nodes/{node_id}/telemetry/latest", timeout=30)
latest.raise_for_status()
points = latest.json()
if not points:
    print("No telemetry in your reservation window yet.")
else:
    values = points[0]["values"]
    print(points[0]["observed_at"], values.get("gpu_utilization"))
    for gpu in json.loads(values.get("gpus", "[]")):
        print(gpu.get("index"), gpu.get("utilization_percent"), gpu.get("temperature_celsius"))

end = datetime.now(timezone.utc)
window = {"start": (end - timedelta(hours=1)).isoformat(), "end": end.isoformat()}
cursor = None
while True:
    params = {**window, "limit": 200, **({"cursor": cursor} if cursor else {})}
    page = session.get(
        f"{API}/v1/observability/nodes/{node_id}/logs/kernel/query", params=params, timeout=30
    )
    page.raise_for_status()
    body = page.json()
    for line in body["lines"]:
        if line["severity"] == "error":
            print(line["date"], line["message"])
    cursor = body["next_cursor"]
    if not cursor:
        break