{"id":13024,"date":"2026-09-13T18:25:00","date_gmt":"2026-09-13T16:25:00","guid":{"rendered":"https:\/\/www.lukaswojcik.com\/blog\/?p=13024"},"modified":"2026-10-26T12:44:08","modified_gmt":"2026-10-26T11:44:08","slug":"tutorial-pomiar-zuzycia-tokenow-na-zadanie-i-egzekwowanie-budzetu-miesiecznego","status":"publish","type":"post","link":"https:\/\/www.lukaswojcik.com\/blog\/pl\/cloud-ai-pl\/tutorials-pl-cloud-ai-pl\/tutorial-pomiar-zuzycia-tokenow-na-zadanie-i-egzekwowanie-budzetu-miesiecznego\/","title":{"rendered":"Tutorial: Pomiar zu\u017cycia token\u00f3w na \u017c\u0105danie i egzekwowanie bud\u017cetu miesi\u0119cznego"},"content":{"rendered":"

U\u017cyteczny bud\u017cet API \u0142\u0105czy trzy zapisy: rezerwacj\u0119 przed \u017c\u0105daniem, zmierzone zu\u017cycie po odpowiedzi i p\u00f3\u017aniejsze uzgodnienie z op\u0142atami dostawcy. Sama suma token\u00f3w nie wystarcza. Dostawca, model, wariant us\u0142ugi, klasa pami\u0119ci podr\u0119cznej i dodatkowe narz\u0119dzia mog\u0105 zmienia\u0107 cen\u0119.<\/p>\n

1. Znaczenie schematu zu\u017cycia<\/h2>\n

W Anthropic Messages input_tokens<\/code> oznacza wej\u015bcie nieobj\u0119te pami\u0119ci\u0105 podr\u0119czn\u0105. Utworzenie cache i odczyt cache s\u0105 osobnymi klasami wej\u015bcia; zapis mo\u017ce dodatkowo rozr\u00f3\u017cnia\u0107 czas wa\u017cno\u015bci. W OpenAI Responses input_tokens<\/code> oznacza ca\u0142e wej\u015bcie, obejmuj\u0105ce odczyty cache i obs\u0142ugiwane klasy zapisu. Dodanie tych podklas do sumy policzy\u0142oby wej\u015bcie dwukrotnie. To r\u00f3\u017cne struktury rozliczeniowe, a nie tylko inne nazwy.<\/p>\n

Poni\u017cszy fikcyjny, ujednolicony rekord u\u017cywa czterech roz\u0142\u0105cznych klas. Stawki w USD za milion token\u00f3w s\u0142u\u017c\u0105 obliczeniu i nie s\u0105 aktualn\u0105 ofert\u0105 konkretnego modelu. Rzeczywisty adapter musi obs\u0142ugiwa\u0107 wybrany endpoint oraz wszystkie w\u0142a\u015bciwe czasy wa\u017cno\u015bci cache.<\/p>\n

from decimal import Decimal, ROUND_CEILING\n\n# Fictional normalized classes and example USD rates per million.\ncounts = {"input": 12400, "write_5m": 8200, "read": 96000, "output": 1850}\nrates = {k: Decimal(v) for k, v in {\n    "input": "3.00", "write_5m": "3.75", "read": "0.30", "output": "15.00"\n}.items()}\ncost_usd = sum(Decimal(counts[k]) * rates[k] for k in counts) \/ Decimal(1_000_000)\nactual_u = int((cost_usd * 1_000_000).to_integral_value(rounding=ROUND_CEILING))\nprint(cost_usd, actual_u)  # 0.1245, 124500\n<\/code><\/pre>\n
Dok\u0142adne sk\u0142adniki wynosz\u0105 0,0372, 0,03075, 0,0288 i 0,02775 USD, razem 0,1245 USD. Wcze\u015bniejsze zaokr\u0105glenie ka\u017cdej wy\u015bwietlanej cz\u0119\u015bci mo\u017ce zmieni\u0107 widoczn\u0105 sum\u0119. Arytmetyka dziesi\u0119tna zachowuje obliczenie; rejestr rezerwacji poni\u017cej u\u017cywa ca\u0142kowitych mikro-USD, czyli 1 000 000 jednostek na USD. Zaokr\u0105glenie w g\u00f3r\u0119 do tej jednostki jest lokaln\u0105 regu\u0142\u0105 bud\u017cetow\u0105, nie zasad\u0105 fakturowania dostawcy.<\/p>\n
\"Cztery
Cztery etapy kontroli bud\u017cetu API<\/figcaption><\/figure>\n
2. Zliczanie przed wys\u0142aniem i zapis po zako\u0144czeniu<\/h2>\n
Endpoint zliczania Anthropic jest bezp\u0142atny w ramach limit\u00f3w cz\u0119stotliwo\u015bci i daje oszacowanie bez logiki cache. Nie przyjmuje wszystkich wej\u015b\u0107 obs\u0142ugiwanych przez Messages: aktualna dokumentacja wyklucza wi\u0119kszo\u015b\u0107 narz\u0119dzi serwerowych, konektor MCP oraz bloki obraz\u00f3w i dokument\u00f3w ze \u017ar\u00f3d\u0142ami URL lub plikowymi. Znaczenie maj\u0105 model i pe\u0142na obs\u0142ugiwana struktura \u017c\u0105dania. Tokenizer samego tekstu nie jest uniwersalnym licznikiem narz\u0119dzi, obraz\u00f3w i oprawy komunikat\u00f3w.<\/p>\n
Zu\u017cycie w strumieniu nie pojawia si\u0119 zawsze dopiero w ostatnim zdarzeniu. Anthropic przekazuje pocz\u0105tkowe dane w message_start<\/code> i skumulowane aktualizacje w message_delta<\/code>. Dodawanie wszystkich skumulowanych warto\u015bci zawy\u017cy\u0142oby wynik. Kolejne sumy 10 i 20 oznaczaj\u0105 na przyk\u0142ad \u0142\u0105cznie 20 token\u00f3w do tej chwili, a nie 30. Obs\u0142ugiwana funkcja SDK zbieraj\u0105ca zako\u0144czon\u0105 wiadomo\u015b\u0107 upraszcza zapis. Przerwany strumie\u0144 lub b\u0142\u0105d po\u0142\u0105czenia mo\u017ce pozostawi\u0107 niepe\u0142ne dane. Brak informacji pozostaje niewiadom\u0105, a nie zerem.<\/p>\n
Trwa\u0142y rejestr audytowy powinien \u0142\u0105czy\u0107 operacj\u0119 logiczn\u0105, unikalne ID pr\u00f3by, dost\u0119pne identyfikatory dostawcy, czasy, funkcj\u0119, dostawc\u0119 i model, wersj\u0119 cennika, rezerwacj\u0119 i surowe zu\u017cycie. Prompty i klucze API nie s\u0105 do tego potrzebne. Ponowienie jest osobn\u0105 pr\u00f3b\u0105 z w\u0142asn\u0105 rezerwacj\u0105 mo\u017cliwych koszt\u00f3w. Timeout nie dowodzi ani naliczenia op\u0142aty, ani zatrzymania przetwarzania; nag\u0142\u00f3wki odpowiedzi mog\u0142y w og\u00f3le nie dotrze\u0107.<\/p>\n
3. Atomowa rezerwacja pe\u0142nej g\u00f3rnej granicy<\/h2>\n
G\u00f3rna granica musi obejmowa\u0107 wej\u015bcie, maksymalne w\u0142a\u015bciwe wyj\u015bcie, mo\u017cliwe koszty zapisu cache oraz ograniczone koszty narz\u0119dzi i p\u0119tli. Sam limit wyj\u015bcia nie wystarcza. Nieznane ceny, nieograniczone p\u0119tle narz\u0119dziowe lub nieudany zapis rejestru musz\u0105 blokowa\u0107 wysy\u0142k\u0119. Obliczenie granicy nie powinno zak\u0142ada\u0107 trafienia w cache.<\/p>\n
Wykonywalny ledger.py<\/code> pokazuje kontrol\u0119 dopuszczania \u017c\u0105da\u0144 dla jednej aplikacji, jednej waluty i miesi\u0119cy kalendarzowych UTC. Wszystkie procesy musz\u0105 korzysta\u0107 z tej samej lokalnej bazy SQLite. To nie baza dla wielu host\u00f3w ani kompletna integracja rozliczeniowa. Walidator ogranicza ka\u017cd\u0105 kwot\u0119 do miliona USD wyra\u017conych w mikrojednostkach.<\/p>\n
Przed pierwsz\u0105 rezerwacj\u0105 initialise(database_path)<\/code> tworzy tabele. Zu\u017cycie wyj\u015bcia mo\u017ce obejmowa\u0107 niewidoczne tokeny rozumowania lub formatowania; d\u0142ugo\u015b\u0107 widocznej odpowiedzi nie jest licznikiem wyj\u015bcia.<\/p>\n
import sqlite3\nfrom datetime import datetime, timezone\n\nclass BudgetExceeded(Exception):\n    pass\n\ndef units(value):\n    if type(value) is not int or not 0 <= value <= 10**12:\n        raise ValueError("Expected non-negative integer micro-USD, at most 10^12")\n    return value\n\ndef connect(path):\n    db = sqlite3.connect(path, timeout=10, isolation_level=None)\n    db.execute("PRAGMA foreign_keys=ON")\n    return db\n\ndef initialise(path):\n    db = connect(path)\n    try:\n        db.executescript("""\n        CREATE TABLE IF NOT EXISTS budgets(\n          month TEXT PRIMARY KEY, limit_u INTEGER NOT NULL,\n          breached INTEGER NOT NULL DEFAULT 0);\n        CREATE TABLE IF NOT EXISTS calls(\n          attempt_id TEXT PRIMARY KEY,\n          month TEXT NOT NULL REFERENCES budgets(month),\n          reserved_u INTEGER NOT NULL, actual_u INTEGER,\n          state TEXT NOT NULL CHECK(state IN ('pending','settled')));\n        """)\n    finally:\n        db.close()\n\ndef reserve(path, attempt_id, upper_u, limit_u, now=None):\n    upper_u, limit_u = units(upper_u), units(limit_u)\n    if not isinstance(attempt_id, str) or not attempt_id:\n        raise ValueError("Stable, nonempty attempt ID required")\n    now = datetime.now(timezone.utc) if now is None else now\n    if now.tzinfo is None or now.utcoffset() is None:\n        raise ValueError("Timezone-aware timestamp required")\n    month = now.astimezone(timezone.utc).strftime("%Y-%m")\n    db = connect(path)\n    try:\n        db.execute("BEGIN IMMEDIATE")\n        if db.execute("SELECT 1 FROM calls WHERE attempt_id=?",\n                      (attempt_id,)).fetchone():\n            db.commit()\n            return False  # No second permission to send.\n        db.execute("INSERT OR IGNORE INTO budgets(month,limit_u) VALUES (?,?)",\n                   (month, limit_u))\n        stored_limit, breached = db.execute(\n            "SELECT limit_u,breached FROM budgets WHERE month=?", (month,)\n        ).fetchone()\n        if stored_limit != limit_u:\n            raise ValueError("Conflicting limit for this month")\n        used = db.execute(\n            "SELECT COALESCE(SUM(COALESCE(actual_u,reserved_u)),0) "\n            "FROM calls WHERE month=?", (month,)\n        ).fetchone()[0]\n        if breached or used + upper_u > limit_u:\n            raise BudgetExceeded(month)\n        db.execute("INSERT INTO calls VALUES (?,?,?,?,?)",\n                   (attempt_id, month, upper_u, None, "pending"))\n        db.commit()\n        return True\n    except BaseException:\n        db.rollback()\n        raise\n    finally:\n        db.close()\n\ndef settle(path, attempt_id, actual_u):\n    actual_u = units(actual_u)\n    db = connect(path)\n    try:\n        db.execute("BEGIN IMMEDIATE")\n        row = db.execute(\n            "SELECT month,reserved_u,actual_u,state FROM calls WHERE attempt_id=?",\n            (attempt_id,)\n        ).fetchone()\n        if row is None:\n            raise ValueError("Unknown attempt")\n        month, reserved, old_actual, state = row\n        if state == "settled":\n            if old_actual != actual_u:\n                raise ValueError("Conflicting settlement")\n            db.commit()\n            return\n        db.execute("UPDATE calls SET actual_u=?,state='settled' WHERE attempt_id=?",\n                   (actual_u, attempt_id))\n        if actual_u > reserved:\n            db.execute("UPDATE budgets SET breached=1 WHERE month=?", (month,))\n        db.commit()\n    except BaseException:\n        db.rollback()\n        raise\n    finally:\n        db.close()\n<\/code><\/pre>\n
BEGIN IMMEDIATE<\/code> rozpoczyna transakcj\u0119 zapisu przed odczytem sumy. Dzi\u0119ki temu dwa r\u00f3wnoleg\u0142e wywo\u0142ania nie mog\u0105 zarezerwowa\u0107 tej samej pozosta\u0142ej cz\u0119\u015bci bud\u017cetu. Rezerwacja jest zatwierdzana przed wywo\u0142aniem sieciowym; transakcja nie pozostaje otwarta podczas oczekiwania na API. Tylko prawdziwy wynik reserve()<\/code> dopuszcza wysy\u0142k\u0119. False oznacza istniej\u0105c\u0105 pr\u00f3b\u0119, a nie ponown\u0105 zgod\u0119 na wys\u0142anie. B\u0142\u0105d blokady lub bazy musi zatrzyma\u0107 wywo\u0142anie.<\/p>\n
PSEUDOCODE\nvalidate provider, model, pricing snapshot and complete cost bound\npersist a unique attempt ID and audit context\nif reserve(database, attempt_id, upper_bound_u, monthly_limit_u) is True:\n    send exactly one provider attempt outside the database transaction\n    on complete usage:\n        persist the original usage and provider identifiers\n        calculate cost with the recorded pricing snapshot\n        settle(database, attempt_id, actual_cost_u)\n    on unknown outcome or unknown cost:\n        keep the reservation pending and investigate\n<\/code><\/pre>\n
Zapisany limit pozostaje sta\u0142y w danym miesi\u0105cu. P\u00f3\u017aniejsze oznaczenie przekroczenia nie anuluje ju\u017c dopuszczonych \u017c\u0105da\u0144.<\/p>\n
Schemat jest pseudokodem adaptera dostawcy: wymaga sprawdzonej wersji cennika i pe\u0142nej g\u00f3rnej granicy. Wykonywalny kod powy\u017cej nie wywo\u0142uje API. Rozliczenie zapisuje si\u0119 raz; identyczne ponowienie jest akceptowane, sprzeczne kwoty s\u0105 odrzucane. Gdy koszt przekracza rezerwacj\u0119, nadwy\u017cka zostaje zapisana, a dalsze dopuszczenia w tym miesi\u0105cu zablokowane. Nie cofa to ju\u017c poniesionych koszt\u00f3w.<\/p>\n
4. Widoczne pr\u00f3by z nieznanym wynikiem<\/h2>\n
Awaria po rezerwacji, ale przed wys\u0142aniem mo\u017ce blokowa\u0107 niewykorzystany bud\u017cet. Timeout po wys\u0142aniu mo\u017ce pozostawi\u0107 nieustalony realny koszt. Automatyczne wygaszanie obu przypadk\u00f3w otworzy\u0142oby bud\u017cet bez dowodu. Odzyskanie wymaga rejestru i informacji dostawcy; tylko pr\u00f3by potwierdzone jako bezp\u0142atne powinny by\u0107 rozliczane zerem.<\/p>\n
Miesi\u0105c jest przypisywany przy rezerwacji wed\u0142ug UTC. P\u00f3\u017aniejsze rozliczenie pozostaje w tym miesi\u0105cu. To regu\u0142a wewn\u0119trzna, nie twierdzenie o dacie faktury. Zg\u0142oszenie, wykonanie, lokalne rozliczenie i okres dostawcy powinny pozosta\u0107 odr\u0119bne przy zadaniach asynchronicznych i granicach miesi\u0119cy.<\/p>\n
\n
Pytania i odpowiedzi<\/h2>\n
Czy faktura dostawcy na pewno pozostanie poni\u017cej bud\u017cetu?<\/h3>\n
Nie. G\u00f3rna granica, adapter cen i obj\u0119cie wszystkich p\u0142atnych operacji musz\u0105 by\u0107 poprawne. Inne klucze API, pomini\u0119te op\u0142aty narz\u0119dziowe, umowy, podatki i p\u00f3\u017aniejsze korekty mog\u0105 pozostawa\u0107 poza lokalnym rejestrem. Limity dostawcy mog\u0105 dodatkowo chroni\u0107, je\u015bli s\u0105 dost\u0119pne, lecz znaczenie ma ich udokumentowany zakres.<\/p>\n
Czy uzgodnienie zawsze dopasuje pojedyncze \u017c\u0105dania?<\/h3>\n
Nie. API Usage i Cost Anthropic udost\u0119pniaj\u0105 zagregowane przedzia\u0142y czasu i wymiary grupowania. Nie mo\u017cna zak\u0142ada\u0107 eksportu ka\u017cdego \u017c\u0105dania osobno. Raport koszt\u00f3w r\u00f3wnie\u017c ma udokumentowane ograniczenia zakresu. Okres, waluta i zakres musz\u0105 si\u0119 zgadza\u0107 przed interpretacj\u0105 r\u00f3\u017cnicy.<\/p>\n
Co wykaza\u0142y testy przyk\u0142adu?<\/h3>\n
Osiem r\u00f3wnoleg\u0142ych pr\u00f3b rezerwacji dopu\u015bci\u0142o dok\u0142adnie dwie kwoty po 40 przy limicie 100. Dalsze testy izolowane sprawdza\u0142y powt\u00f3rne rozliczenia, nierozstrzygni\u0119te pr\u00f3by, sprzeczne limity, b\u0142\u0119dne kwoty i granice miesi\u0119cy UTC. Nie testowano p\u0142atnych wywo\u0142a\u0144 API ani prawdziwej faktury.<\/p>\n<\/div>\n
\u0179r\u00f3d\u0142a<\/h2>\n