bj dZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z ejeZdZdZd d Zdd  d d Zy)uAAnthropic kullanım istatistiklerini structured JSON-lines log'a yazan modül. Mimari: Her `messages.create` / `messages.stream` çağrısından sonra `record_usage` çağrılır. JSONL formatında /var/log/patentyazar-llm-usage.log (production) veya /tmp/llm-usage.log (development) dosyasına atomic append yapar. Laravel tarafında `php artisan llm:ingest-usage` cron komutu bu dosyayı okur, `llm_usage_records` tablosuna ekler ve dosyayı truncate eder. Bu yüzden file-based loglama tercih ettik (Redis pub-sub veya başka bir kanal yerine): - Python ve Laravel ayrı süreçlerde, file ortak alan - Apache + systemd standart, bir yere bağımlılık eklemek istemiyoruz - Append atomic (POSIX < PIPE_BUF, log satırları küçük) - Cron-based ingest 5 dakikada bir → admin paneli için zaten yeterli ) annotationsN)Path)Any) get_settingsz"/var/log/patentyazar-llm-usage.logz/tmp/llm-usage.logcJt}t|dd}|r|Stt}|j r0t j |t jrtStSt j |jt jrtStS)zIConfigured log path; production'da /var/log/ user yazabiliyor mu kontrol.llm_usage_log_pathN) rgetattrr_DEFAULT_LOG_PATHexistsosaccessW_OKparent _DEV_LOG_PATH)settings candidatelog_files 9/var/www/ai.patentyazar.com/app/services/llm/usage_log.py _log_pathr&s|~H"6=I%&H 99Xrww '$ $  8??BGG ,  )extrac  ydfd }ttjdz|||d|d|d|dd}|r||d <tj|d d d z}t t dd5}|j |dddy#1swYyxYw#t$rtjdYywxYw)u Anthropic response'undaki `usage` objesini log'a yazar. `usage` Anthropic SDK'nın `Usage` modeli olabilir veya stream end_event'inden gelmiş bir dict olabilir. İki tipten de aşağıdaki alanları çeker: input_tokens — non-cached input output_tokens — completion cache_creation_input_tokens — yeni cache write (5min veya 1h) cache_read_input_tokens — cache hit (en ucuz) Bu alanların hepsi int. Eksik olan 0 sayılır. `endpoint` log'lama için string identifier — örn. "drafting.stream", "intake.suggest", "prior_art.analyze". Admin paneli endpoint bazında grupluyor. Hatalar yutulur — logging code uygulama akışını hiçbir zaman bozmamalı. Nct|rtt|xsdSttrtj |dxsdSy)Nr)hasattrintr isinstancedictget)keyusages r_getzrecord_usage.._get\sLuc"75#.3!44%&599S!,122ri input_tokens output_tokenscache_creation_input_tokenscache_read_input_tokens)tsmodelendpointr"r#r$r%rF),:) ensure_ascii separators azutf-8)encodingz!LLM usage log failed (suppressed))rstrreturnr) rtimejsondumpsopenrwrite Exception_logger exception)r'r r(rr!recordlinefs ` r record_usager=?s2!? =  diikD()  0!/2+/0M+N'+,E'F"  #F7Ozz&uLtS)+sW 5  GGDM    ? =>?s5B+A>B+BB+B($B+(B++C  C )r1r0) r'r0r rr(r0rzdict[str, Any] | Noner1None)__doc__ __future__rr3loggingr r2pathlibrtypingr app.configr getLogger__name__r8r rrr=rrrHs$#  # '  H %9$ <$( :? :? :? :? ! :?  :?r