aj SSKJr SSKrSSKrSSKrSSKJr SSK J r J r 1Skr \ Vs1sHoR5iM sn\ -r1SkrSS\R S\S \S \S \R 4 S jjrS \S\S \4SjrSS \S\S\\S\S \R 4 SjjrSS \S\\\S\\S \\\R 44SjjrSS \S\S\\\S\\S \R 4 Sjjrgs snf))OptionalN)get_connection) TIMEFRAMES MOEX_TICKERS>ZCASHEURUSDBITCOINBITCOINC>D1H1W1df max_return level_low level_highreturncRUb[U5S:aU$UR5nUSRR[5n[U5n[ R "U5n[ R"USSUSS- S- 5USS&Xa:nXG)nUR5(aR[U5S:aC[ R"U5n XBU -:XCU -:-n U R5(a X)-n Xz-nUR5(dU$UR5n [ R"U5Sn S HnXRR[5nU HnUS- nUS:a!UU(aUS-nUS:a UU(aMUS-nUU:a!UU(aUS- nUU:a UU(aMUS:a0UU:a*UU:a$UU- nUUUUUU- UU- -U- -UU'MUS:a UUUU'MUU:aUUOUUUU'M XU'M US RR[5nU HBnUS:aUUS- OSnUS-U:aUUS-OSnUS:dUS:aUU-S - OUUUU'MD UR[5US 'U$) uОбнаруживает и интерполирует аномальные свечи. Два прохода: Pass 1 — смежные возвраты > max_return (catch spike candles: DROP 35→2 + JUMP 2→35) Pass 2 — абсолютный уровень цены < level_low × median или > level_high × median (catch persistent corrupted candles: 6 свечей по ~2р между DROP и JUMP) SNGSP/PLZL: ошибочные данные — падение с ~35р → ~2р (94%) с возвратом через 6 свечей. Все O/H/L/C/V аномалий заменяются линейной интерполяцией между чистыми соседями. NCloseg? r)OpenHighLowrVolume) lencopyvaluesastypefloatnpzerosabsanymediansumwhereint)rrrrclosenreturnsmask clean_close median_close level_mask new_flags total_spikes spike_idxcolvalsidxprev_idxnext_idxspanvolprev_vnext_vs data/loader.py clean_spikesr?s zSWq[ B wK   % %e ,E E AhhqkG&&qrU3BZ/#56GABK  D,K xxzzc+&+yy- ,665P\C\;\] >>  "e,I$D 88:: 88:Lq!I0w~~$$U+CQwHa-DNA a-DNNQwHQ,4>A Q,4>>1}A(X2E(* Nd8ntH~.MRUX`R`-adh-hhS Q NS .6lDNS S #&3-02 X,   $ $U +C!$qS1Wa!$q1S1W!-3aZ6A:FVOq(CPSHC::c?BxL Iticker timeframecUR5nUR5nU[;a[SU35eU[;a[SU35eUSU3$)uaВалидирует тикер и таймфрейм перед подстановкой в SQL.u%Недопустимый тикер: u-Недопустимый таймфрейм: _)upper VALID_TICKERS ValueError VALID_TFS)rArBtfs r>_validate_table_namerJ[s` \\^F  B ]"@IJJ HMNNXQrd r@limitcleanc[X5nU(a1[U5nUS::a[SU35eSRU5nOSRU5n[ 5nU(a[ R "XgW4S9nO[ R "Xg5nSSS5 U(aWb[U5S:a [U5nW$!,(df  N4=f)uwЗагружает свечные данные. Если clean=True — удаляет ценовые аномалии.ru8LIMIT должен быть положительным: a SELECT * FROM ( SELECT timestamp, `Date`, `Time`, Open, High, Low, Close, Volume FROM {} ORDER BY timestamp DESC LIMIT %s ) sub ORDER BY timestamp ASC z SELECT timestamp, `Date`, `Time`, Open, High, Low, Close, Volume FROM {} ORDER BY timestamp )paramsNr) rJr*rGformatrpdread_sqlrr?) rArBrKrLtable limit_intqueryconnrs r>load_dataframerVfs ! 3E J >WXaWbcd d  F5M   F5M   T U)>BU)B  CGqL "  I  s 5C C timeframesc Uc[[R"55nUVs0sHnU[XU5_M sn$s snf)N)listrkeysrV)rArWrKrIs r>load_multiple_timeframesr[sL*//+,  B N6u --  sAmain_tf higher_tfscSSKJnJn UcSS/nU/UVs/sH ofU:wdM UPM sn-n[XU5nU"X5n UHnXa:XaM U"XSS9n UV s0sH oUSU 3_M n n U S/U-R U S 9n S S S .n U R US 5nU SU-U S'[ R"U RS5U RS5SS S9n M U $s snfs sn f)Nr)engineer_features FEATURE_COLSr r T) skip_temporalrD timestamp)columnsiQi: )r r backward)on direction) features.technicalr_r`r[renamegetrP merge_asof sort_values)rAr\r]rKr_r`rIall_tfsdfsmain_dfdf_hr5rh tf_secondsshift_ss r>load_multitimeframe_featuresrrs  CD\ i D "Gm2 DDG "6E :C -G =  =0<= "Qse}$ =[ML01888H"0 ..U+ -7[--    ,   [ )  ( N3E>s C#C#C()g?g333333?g@)NT)NN)r NN)typingrrenumpyr#pandasrP db.connectionrconfigrr EXTRA_TICKERSrErFrH DataFramer"r?strrJr*boolrVrYdictr[rr)ts0r>rs (+; %11LqL1MA  8<>AHR\\HuH!H6;HFHllHVHL!%"3"3"x}""*,,,"JShtCy6IYabeYfrvwz|~}I}IxIsJ&* $ $ $c#$ C= $ \\ $Q2sC-