ik LdZddlZddlZddlZddlmZmZej eZejjejje Z ejje dZdZdedzfdZdedefd Zd dedzd edefd Zdedzdefd Zy)u: signals_consumer.py — Lecture du cache signal_aggregator pour market_spy.py Import : from signals_consumer import get_signal_snapshot, signal_log_entry Usage dans market_spy.py (observation mode) : snap = get_signal_snapshot() if snap: logger.info(f" 📡 Signaux: {signal_log_entry(snap)}") N)datetimetimezonezsignal_cache.jsonreturnc tjjtsytjj t}t j tjj|z }|tkDr"tjd|ddtdytt5}tj|}dddhd}|j!j#stjdy|S#1swYDxYw#t$$r"}tjd|Yd}~yd}~wwxYw) u Lit le cache JSON écrit par signal_aggregator.py. Retourne None si le cache est absent, corrompu ou trop vieux. Ne lève jamais d'exception (FAIL_OPEN). NzCache signal trop vieux (z.0fzs > zs)>netflow funding_oi score_totalinterpretationzCache signal incompletu Lecture cache signal échouée: )ospathexists CACHE_FILEgetmtimernowrutc timestampCACHE_MAX_AGE_SEClogdebugopenjsonloadissubsetkeys Exception)mtimeagefdatarequiredes signals_consumer.pyget_signal_snapshotr$s ww~~j)  , X\\*446> " " II1#c$?P>QQST U *  99QBGhhy"%)).!rNs 'g!ggoobggooh78 ggll:':; TD[@4C,/TD[/5/5/ * * *r9