from openai import OpenAI

client = OpenAI(
    api_key="tg-prod-你的密钥",
    base_url="http://127.0.0.1:8080/v1",
    default_headers={"X-TG-Feature": "chat"},   # 整个客户端共用的功能名
)

r = client.chat.completions.with_raw_response.create(
    model="你的逻辑模型名",
    messages=[{"role": "user", "content": "hi"}],
    user="u_10231",                              # 网关自动当成 X-TG-End-User
    extra_headers={"X-TG-Session": "s_88fa1"},   # 单次请求的会话 id
)
print(r.headers.get("X-TG-Request-Id"))          # 对账用，出问题报这个
print(r.headers.get("X-TG-Cost-USD"))            # 非流式才有
print(r.parse().choices[0].message.content)

import OpenAI from "openai";

const client = new OpenAI({
  apiKey: "tg-prod-你的密钥",
  baseURL: "http://127.0.0.1:8080/v1",
  defaultHeaders: { "X-TG-Feature": "chat" },
});

const r = await client.chat.completions
  .create(
    {
      model: "你的逻辑模型名",
      messages: [{ role: "user", content: "hi" }],
      user: "u_10231",
    },
    { headers: { "X-TG-Session": "s_88fa1" } },
  )
  .withResponse();

console.log(r.response.headers.get("x-tg-request-id"));
console.log(r.data.choices[0].message.content);

from anthropic import Anthropic

client = Anthropic(
    api_key="tg-prod-你的密钥",   # 走 X-Api-Key，网关也收
    base_url="http://127.0.0.1:8080",  # 注意：不带 /v1
    default_headers={"X-TG-Feature": "chat"},
)

r = client.messages.with_raw_response.create(
    model="你的逻辑模型名",
    max_tokens=1024,
    messages=[{"role": "user", "content": "hi"}],
    metadata={"user_id": "u_10231"},   # 网关自动当成 X-TG-End-User
)
print(r.headers.get("X-TG-Request-Id"))
print(r.parse().content[0].text)

import time, httpx
from openai import OpenAI

BASE = "http://127.0.0.1:8080"
KEY  = "tg-prod-你的密钥"
client = OpenAI(api_key=KEY, base_url=BASE + "/v1")

r = client.chat.completions.with_raw_response.create(
    model="你的逻辑模型名",
    messages=[{"role": "user", "content": "写首五言绝句"}],
    stream=True,            # include_usage 由网关自动补，不用自己带
    user="u_10231",
)
rid = r.headers["X-TG-Request-Id"]
for chunk in r.parse():
    if chunk.choices and chunk.choices[0].delta.content:
        print(chunk.choices[0].delta.content, end="", flush=True)

time.sleep(2.5)             # 等账本落盘
u = httpx.get(f"{BASE}/v1/usage/{rid}", headers={"Authorization": f"Bearer {KEY}"}).json()
print("\n", u["cost_usd"], u["input_tokens"], u["output_tokens"], u["ttfb_ms"])