mujB@ BSrSSKrSSKrSSKrSSKrSSKJrJrJr SSK r SSK r \RRS\RR\RR\RR!\5555 SSKJr SSKJr S\S\4Sjr\RR7\RR\RR\RR!\555S 5r\RR7\S 5r/S Qr\4S \S\\4S jjrSS\\S\S\ 4Sjjr!Sr"\"4S\ S\ 4Sjjr#S\\SS4Sjr$S\SS4Sjr%/SQr&SS\\\S\ 4Sjjr'Sr(\)S:Xa\("5 gg!\a SrGNf=f)u sync_signals — синхронизация сигналов MoE v12 из summary_report в MySQL (current_signals). Вызывается из monitor.py после завершения анализа, либо вручную: python -m utils.sync_signals Записывает для каждого тикера: signal_type, confidence, p_long, p_short, tp_price, sl_price, close_price, updated_at. N)ListDictOptional)get_connection)is_moex_only_longtickerreturncJ[cg[U5$![a gf=f)uYTrue если тикер относится к MOEX в режиме only-LONG (no short).F)_is_moex_only_long Exception)rs 3/home/ai/projects/AI_Strategy/utils/sync_signals.pysignal_is_moex_long_onlyrs-!!&)) s  "" monitoringzsummary_report.md)ASTRGAZPLKOHMOEXMTSSNSVZNVTKPHORPLZLROSNSBERSNGSPVTBRX5BITCOINBITCOINCZCASHEURUSDfilepathc [RRU5(d[SU35 /$[ USSS9nUR 5nSSS5 /n[ R"S[ R5nURW5HnURS5nURS5nURS 5n[URS 55S - n [URS 55S - n [URS 55S - n US:XdMURUUS;aUOSU U U SSSS.5 M [S[U5SU35 U$!,(df  GN=f)uiПарсит summary_report.md и возвращает список сигналов по тикерам.u+[sync_signals] Файл не найден: rutf-8encodingNzv^\|\s*(\w+)\s*\|\s*(ok|stale|error|no_candle|no_model)\s*\|\s*(\w+)\s*\|\s*([\d.]+)%\s*\|\s*([\d.]+)%\s*\|\s*([\d.]+)%gY@okBUYSELLNEUTRAL)r signal_type confidencep_longp_shorttp_pricesl_price close_priceu$[sync_signals] Распарсено u сигналов из )ospathexistsprintopenreadrecompile MULTILINEfinditergroupfloatappendlen) r"fcontentsignals table_patternmatchrstatussignalconfr6r7s r parse_summary_reportrQ/sS 77>>( # # ;H:FG hg .!&&( /GJJ B M ''0QQQU[[^$u,u{{1~&. A'%/ T> NN )/?)Bv " ""  1( 0W>UV^U_ `a N? / .s E(( E7rK model_typecU(dg[[R"55nSn[5nUR5nUHmn[ US5(aSUS'UR S5S:XaSUS'UR SUSUSUS US USUS US US X4 5 US- nMo SSS5 [SUS35 U$!,(df  N=f)u:Upsert сигналов в таблицу current_signals.rrr3r7r4r1r2a INSERT INTO current_signals (ticker, signal_type, confidence, p_long, p_short, tp_price, sl_price, close_price, model_type, updated_at) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE signal_type = VALUES(signal_type), confidence = VALUES(confidence), p_long = VALUES(p_long), p_short = VALUES(p_short), tp_price = VALUES(tp_price), sl_price = VALUES(sl_price), close_price = VALUES(close_price), model_type = VALUES(model_type), updated_at = VALUES(updated_at) r5r6r8r9r:r(Nu [sync_signals] Записано u$ сигналов в current_signals)inttimercursorrgetexecuter>)rKrRnow_tsupdatedconncurss r sync_to_dbr^Ws   FG  TkkmA(( 44") 55'61'0Am$ KK ( Q}-q( Qy\* q}a .>  * qLG9 B ,WI5Y Z[ NE  s BC Ci`T threshold_secc ,[[R"55nX- nSn[5nURSS9nUR SU45 UR 5nU(dUR 5 SSS5 gUHnU[URS5=(d S5- nUS- n URSS 5n [S US S U S U SS35 Sn SSK n U RS5RSUS SU SU SS35 M UR SX45 URnUR5 UR 5 SSS5 US:a[SU35 U$![a Mf=f!,(df  N5=f)uLСбрасывает устаревшие сигналы в current_signals в NEUTRAL. Если updated_at < (now - threshold_sec) для тикера — обнуляет signal_type, confidence, tp_price, sl_price, выставляет updated_at=now. Возвращает количество обнулённых строк. rT) dictionaryznSELECT ticker, signal_type, updated_at FROM current_signals WHERE updated_at < %s AND signal_type != 'NEUTRAL'N updated_atir4?z[sync_signals] STALE r: z updated z.1fuh ago → NEUTRAL AI_Strategyzcurrent_signals STALE:  z (uh ago) → NEUTRALzUPDATE current_signals SET signal_type='NEUTRAL', confidence=0, p_long=0, p_short=0, tp_price=0, sl_price=0, close_price=0, updated_at=%s WHERE updated_at < %s AND signal_type != 'NEUTRAL'uG[sync_signals] Сброшено устаревших сигналов: )rTrUrrVrXfetchallcloserWr>logging getLoggerinfor rowcountcommit) r_rYcutoffresetr[r\ stale_rowsrow stale_secstale_hold_sigloggerris r cleanup_stale_signalsrvs F  #F E  TkkTk*  A I \\^  IIK  CSWW\%:%?a!@@I$&GggmS1G )#h-7)D$SM):< =F !!-055-c(m_AgYG}$68  A      Q T qy WX]W^_` L!  9  s8A FAF!2E4AF4 F>FFF FcPUGH^nUSn[RR[UR 5S35n[RR U5(dMd[ USSS9nUR5nSSS5 WR5RS5nUVs/sH3owRS5(dMURS 5S :dM1UPM5 nnU(adUS n U RS 5V s/sHoR5PM n n [U 5S :a"[U S RSS55US'[%U5 GMa g!,(df  N=fs snfs sn f![[ 4a N>f=f!["a NNf=f)ubДополняет сигналы ценами close, tp, sl из individual monitor-файлов.rz _monitor.mdr$r%r&N z| |r,r),r:)r;r<join MONITOR_DIRlowerr=r?r@stripsplit startswithcountrHrFreplace ValueError IndexErrorr _compute_tp_sl) rKr]r monitor_filerIrJlinesl data_lines last_lineppartss r sync_ticker_pricesrs^ 8ww||KFLLN3C;1OP ww~~l++  lC':a&&(;MMO))$/E%*WUll4.@!QWWS\UVEV!UJW&rN ,5OOC,@A,@q,@Au:?+0q1A1A#r1J+K-( q9;: XB ' 3   sl( F3E'+F/E8 E8#E8)!F E=#F5!F' E5 1FFFFF F%$F%r]cURSS5nUS;a SUS'SUS'gSS KJn U"US 5up4nSS KJn SS KJn U"US S SSS9nUb[U5S:agU"U5n[USRS5n [USRS5n U S:aU S::agX:agXS-:agUS:Xa/[U SXI---S5US'[U SX9-- -S5US'O.[U SXI-- -S5US'[U SX9---S5US'[U S5US'g![a gf=f)uВычисляет TP/SL для сигнала BUY/SELL из последней H1-свечи + ATR. BUG-FIX (2026-07-31): множители берутся per-market из get_risk_params (MARKET_TARGET_CONFIGS). Ранее захардкожено 3/6 — это противоречило тренировочным целям для crypto (4/8) и forex (2/4). Также порог ATR валидации был global 5%/10%, что некорректно для crypto. Для NEUTRAL TP/SL = 0. r4r2r/r3r8r9Nr)get_risk_paramsrload_dataframeengineer_featuresH1dTlimitcleanatr_pctrzCloser*r0r(r:) rWconfigr data.loaderrfeatures.technicalrrHrFilocroundr ) r]sigrsl_multtp_mult max_atr_ratiorrdfrrhs r rrsz %% y )C /!* * ! **9!H+*F'-.8 AhKS E :R2  r "9 **2./bk&&r*+!    "  Q& &  %<!%1w/@+@"A1EAjM!%1w/@+@"A1EAjM!%1w/@+@"A1EAjM!%1w/@+@"A1EAjM ?-    s+>D1$A D1/D15D1>A2D11 D>=D>) rsi_signal bb_signal macd_signal trend_signalmomentum_signal volume_signaldirectional_biassignal_strengthtickerscUc[nSSKJn SSKJn SSKJn [[R"55nSnUGHYnU"USSSS 9nUb[U5S :aM"U"U5nU"U5nURS n0n [Hdn [URU S 55n [R"U 5(d[ R""U 5(aS n [%U S 5X'Mf [URSS 55n [URSS 55n ['5nUR)5nUR+SUU SU SU SU SU SU SU SU S[%U S 5[%U S5U4 5 US- nSSS5 GM\ [/SU35 U$!,(df  GM~=f![,an[/SUSU35 SnAGMSnAff=f)u0Вычисляет directional сигналы для всех тикеров и сохраняет в regression_signal_data. Args: tickers: список тикеров. Если None — использует FALLBACK_TICKERS. Returns: количество записанных тикеров. Nrrr)add_directional_signalsrTr2rzr3r-rra[ INSERT INTO regression_signal_data (ticker, rsi_signal, bb_signal, macd_signal, trend_signal, momentum_signal, volume_signal, directional_bias, signal_strength, atr_pct, close_price, updated_at) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE rsi_signal = VALUES(rsi_signal), bb_signal = VALUES(bb_signal), macd_signal = VALUES(macd_signal), trend_signal = VALUES(trend_signal), momentum_signal = VALUES(momentum_signal), volume_signal = VALUES(volume_signal), directional_bias = VALUES(directional_bias), signal_strength = VALUES(signal_strength), atr_pct = VALUES(atr_pct), close_price = VALUES(close_price), updated_at = VALUES(updated_at) rrrrrrrrrr(u[sync_signals] ✗ rduM[sync_signals] Записано регрессионных сигналов: )FALLBACK_TICKERSrrrrfeatures.directionalrrTrUrHrDIRECTIONAL_SIGNAL_COLSrFrWpdisnanpisnanrrrVrXr r>)rrrrrYrZrrlast signals_datacolvalrrhr[r\es r sync_regression_signalsr&s"*4<  FG= CtDBzSWr\#2&B(,B772;DL.DHHS#./773<<288C==C$)#qM ! / DHHY45G$((7C01E!Tkkm ( . - / 0 !23 1 !34 !23'1%%O ' B1 G"!/@ YZaYb cd NU"!J  (1#6 7  s>F? CF?/A F,F?, F< 6F?<F?? G& G!!G&c SSKnURSS9nURSSSS9 URS SS S9 UR5nUR(a [ 5 gUR (a [ 5 [5nU(d [S 5 g[U5 [U5 [S U55n[S U55n[SUSUS[U5U- U- S35 g)uОсновной Entry Point.rNu4Синхронизация сигналов в MySQL) descriptionz --regression store_trueueСинхронизировать только регрессионные (directional) сигналы)actionhelpz--allubСинхронизировать и основные, и регрессионные сигналыuI[sync_signals] Нет сигналов для синхронизации.c3:# UHoSS:XdM Sv M g7f)r4r0r(N.0r]s r main..s?'Q}%5%>qq'  c3:# UHoSS:XdM Sv M g7f)r4r1r(Nrrs r rrsA7a &6&&@7ru [sync_signals] Итого: 🟢 u BUY | 🔴 u SELL | ⚪ z NEUTRAL) argparseArgumentParser add_argument parse_args regressionrallrQr>rr^sumrH)rparserargsrKbuyssellss r mainr}s  $ $1g $ hF |EF  BC    D ! xx!"$G  YZww ?'? ?D A7A AE ,TF,ug\RUV]R^aeRehmRmQnnv wx__main__)moe_v12)N)*__doc__sysr;rArUtypingrrrnumpyrpandasrr<insertdirnameabspath__file__ db.connectionrrrr ImportErrorstrboolrr~r SUMMARY_FILErrQrTr^STALE_SIGNAL_THRESHOLD_SECrvrrrrr__name__rrr rs''277??277??277??83L#MNO(> STggll277??277??277??8;T+UVXde ww||K)<= > *6%3%$t*%P*T **C*`&0J88c8vT tB1 d1 t1 rTXd3i%8TCTny> zFI sFFF