仕事に使えるか、確かめる。

export TASK_ID="$(python3 -c 'import uuid; print(uuid.uuid4())')"
curl --fail-with-body --max-time 120 \
  -D auto-headers.txt -o auto-response.json \
  https://teai.io/v1/chat/completions \
  -H "Authorization: Bearer $TEAI_API_KEY" \
  -H "Content-Type: application/json" \
  -H "x-teai-task-id: $TASK_ID" \
  -H "x-teai-task-type: json_extract" \
  --data-binary @- <<'JSON'
{
  "model": "teai/auto",
  "messages": [{"role": "user", "content": "Extract this fictional event registration. Return only JSON with id, date, people; copy values without inference. Registration: R42; date: 2026-10-03; people: 3. No extra fields. Do not use Markdown code fences."}],
  "temperature": 0,
  "max_tokens": 256,
  "stream": false
}
JSON
python3 -m json.tool auto-response.json
python3 -c 'from pathlib import Path; print(Path("auto-headers.txt").read_text())'
export RECEIPT="$(python3 -c 'from pathlib import Path; h=Path("auto-headers.txt").read_text().splitlines(); print(next(v.split(":",1)[1].strip() for v in h if v.lower().startswith("x-teai-task-receipt:")))')"
curl --fail-with-body --max-time 30 \
  -H "Authorization: Bearer $TEAI_API_KEY" \
  "https://teai.io/api/v1/task-outcomes/$TASK_ID"

# Only after inspecting the source, output and GET summary above.
printf 'Decision (accepted/rejected/needs_revision; blank skips): '
read -r DECISION
export DECISION
case "$DECISION" in
  accepted|rejected|needs_revision)
    python3 -c 'import json,os; print(json.dumps({k:os.environ[v] for k,v in [("task_id","TASK_ID"),("receipt","RECEIPT"),("decision","DECISION")]}))' |
      curl --fail-with-body --max-time 30 \
        https://teai.io/api/v1/task-outcomes \
        -H "Authorization: Bearer $TEAI_API_KEY" \
        -H "Content-Type: application/json" --data-binary @-
    ;;
  *) printf 'No decision sent.\n' ;;
esac

python3 -m pip install openai

モデルがMarkdownコードフェンスを返す場合があります。以下は回答全体を囲む単一のフェンス（json指定または指定なし）だけを除去し、重複キー・NaNなどを拒否してJSONを解析します。文章中の波括弧からは抽出しません。プロンプトはモデル共通の出力形式を保証しません。

import json
import os
import re
import uuid
from urllib.request import Request, urlopen
from openai import OpenAI

def parse_json_answer(text):
    text = text.strip()
    fence = re.fullmatch(r'```(?:json)?\s*\n(.*?)\n```', text, re.S)
    if fence:
        text = fence.group(1)

    def reject_duplicates(pairs):
        result = {}
        for key, value in pairs:
            if key in result:
                raise ValueError(f"Duplicate key: {key}")
            result[key] = value
        return result

    def reject_constant(value):
        raise ValueError(f"Invalid JSON constant: {value}")

    return json.loads(text, object_pairs_hook=reject_duplicates,
                      parse_constant=reject_constant)

key = os.environ["TEAI_API_KEY"]
task_id = str(uuid.uuid4())  # Keep this ID for revisions of the same task.
client = OpenAI(api_key=key, base_url="https://teai.io/v1",
                max_retries=0, timeout=120.0)
prompt = (
    "Extract this fictional event registration. Return only JSON with "
    "id, date, people; copy values without inference. "
    "Registration: R42; date: 2026-10-03; people: 3. No extra fields. "
    "Do not use Markdown code fences."
)
print("Task ID:", task_id, flush=True)
raw = client.chat.completions.with_raw_response.create(
    model="teai/auto", messages=[{"role": "user", "content": prompt}],
    temperature=0, max_tokens=256, stream=False,
    extra_headers={"x-teai-task-id": task_id,
                   "x-teai-task-type": "json_extract"},
)
response = raw.parse()
receipt = raw.headers["x-teai-task-receipt"]
assert raw.headers["x-teai-task-id"] == task_id
print("Receipt:", receipt)
print("Model:", response.model, "Usage:", response.usage)
print("Reason:", raw.headers.get("x-teai-auto-reason", "unavailable"))
print("Source:", prompt)
choice = response.choices[0]
print("Output:", choice.message.content)
if choice.finish_reason != "stop":
    raise RuntimeError(f"Incomplete answer: {choice.finish_reason}")
data = parse_json_answer(choice.message.content or "")
if not isinstance(data, dict) or set(data) != {"id", "date", "people"}:
    raise ValueError("Unexpected fields; inspect before retrying")
if (type(data["people"]) is not int or data["people"] < 1
        or not all(isinstance(data[k], str) for k in ("id", "date"))):
    raise ValueError("Invalid field types")

def outcomes(path, body=None):
    payload = None if body is None else json.dumps(body).encode()
    req = Request("https://teai.io/api/v1/task-outcomes" + path,
                  data=payload, headers={"Authorization": f"Bearer {key}",
                                        "Content-Type": "application/json"})
    with urlopen(req, timeout=30) as result:
        return json.load(result)

summary = outcomes("/" + task_id)
print(json.dumps(summary, ensure_ascii=False, indent=2))
if summary["current_receipt"] != receipt:
    raise RuntimeError("A newer attempt exists; inspect it first")
# A schema check or sample match is NOT acceptance. Review the source yourself.
decision = input("After review: accepted/rejected/needs_revision (blank skips): ").strip()
if decision in {"accepted", "rejected", "needs_revision"}:
    result = outcomes("", {"task_id": task_id, "receipt": receipt,
                           "decision": decision})
    print(json.dumps(result, ensure_ascii=False, indent=2))
else:
    print("No decision sent.")

• attempt_countは総試行数、correction_countは追加試行数。accepted_first_timeは初回受入ならtrue、再試行後ならfalse、未受入ならnullです。
• total_attempt_elapsed_msは各試行時間の合計。elapsed_overall_msは修正間隔も含む最初の開始から最後の終了まで。未観測・未完了はnullのままです。
• elapsed_until_decision_msは最初の開始から最新試行の自己申告判定まで（確認時間を含む）。未判定時や再試行後の判定前はnullです。
• unknown_cost_attemptsは費用不明の試行数。feedback_source=self_reported、cost_basis=estimate_not_billed、verified_corpus=false、production_evidence_eligible=falseです。
• 400はヘッダー・入力条件、401は認証、402は残高を確認。404は所有者・UUID・レシートを確認。409は古いレシート、未完了、判定済み、accepted後の再試行など。429/5xxや応答不明時はGETで台帳を確認してから判断します。