Cloudflare AI Gateway

from anthropic import Anthropic
from lago_agent_sdk import LagoSDK

sdk = LagoSDK(api_key="<YOUR_LAGO_API_KEY>", default_subscription_id="sub_acme")

client = sdk.wrap(Anthropic(
    api_key="<YOUR_ANTHROPIC_API_KEY>",
    base_url=f"https://gateway.ai.cloudflare.com/v1/{account_id}/{gateway_id}/anthropic",
    default_headers={"cf-aig-authorization": f"Bearer {gateway_auth}"},
))

client.messages.create(
    model="claude-sonnet-4-6",
    max_tokens=200,
    messages=[{"role": "user", "content": "Hello"}],
)
sdk.flush()

import Anthropic from "@anthropic-ai/sdk";
import { LagoSDK } from "lago-agent-sdk";

const sdk = new LagoSDK({
  apiKey: process.env.LAGO_API_KEY!,
  defaultSubscriptionId: "sub_acme",
});

const client = sdk.wrap(new Anthropic({
  apiKey: process.env.ANTHROPIC_API_KEY!,
  baseURL: `https://gateway.ai.cloudflare.com/v1/${accountId}/${gatewayId}/anthropic`,
  defaultHeaders: { "cf-aig-authorization": `Bearer ${gatewayAuth}` },
}));

await client.messages.create({
  model: "claude-sonnet-4-6",
  max_tokens: 200,
  messages: [{ role: "user", content: "Hello" }],
});
await sdk.flush();

from openai import OpenAI

client = sdk.wrap(OpenAI(
    api_key=gateway_auth,
    base_url=f"https://gateway.ai.cloudflare.com/v1/{account_id}/{gateway_id}/compat",
))

resp = client.chat.completions.create(
    model="workers-ai/@cf/meta/llama-3.3-70b-instruct-fp8-fast",
    messages=[{"role": "user", "content": "Hello"}],
)

import OpenAI from "openai";

const client = sdk.wrap(new OpenAI({
  apiKey: gatewayAuth,
  baseURL: `https://gateway.ai.cloudflare.com/v1/${accountId}/${gatewayId}/compat`,
}));

await client.chat.completions.create({
  model: "workers-ai/@cf/meta/llama-3.3-70b-instruct-fp8-fast",
  messages: [{ role: "user", content: "Hello" }],
});

from lago_agent_sdk.gateway.adapters import extract_cloudflare_log, resolve_subscription

for entry in fetch_gateway_logs():   # GET .../ai-gateway/gateways/{id}/logs
    usage = extract_cloudflare_log(entry)
    sub = resolve_subscription(entry) or "sub_default"
    sdk.emit(
        usage,
        subscription=sub,
        mode="price",
        usd_cost=entry.get("cost") or 0,      # Cloudflare's own metered price
        event_id=f"cf_{sub}_{entry['id']}",   # idempotency key
    )

sdk.flush()

import { extractCloudflareLog, resolveSubscription } from "lago-agent-sdk/gateway/adapters";

for (const entry of await fetchGatewayLogs()) {
  const usage = extractCloudflareLog(entry);
  const sub = resolveSubscription(entry) ?? "sub_default";
  sdk.emit(usage, {
    subscription: sub,
    mode: "price",
    usdCost: entry.cost ?? 0,              // Cloudflare's own metered price
    eventId: `cf_${sub}_${entry.id}`,      // idempotency key
  });
}

await sdk.flush();