ó
|
%õeiC# ã ó, S SK rS SKJr " S S5 rg)é N)Ú lru_cachec óF \ rS rSrS rS rS S jrS S jrS rS r S r
|
S r g
|
) ÚDataProcessingServiceé c óv Ub UR ( a U$ UR 5 nUR S5 nUS R [ 5 US' US R [ 5 US' US R [ 5 US' SUR
|
; ax [ R " US 5 US' US R R c! US R R S5 US' US R R S5 US' U$ ! [ a n[ S U 35 Us SnA$ SnAff = f)
|
uH
|
æ¸
æ´æ°æ®
|
:param df: åå§æ°æ®æ¡
|
:return: æ¸
æ´åçæ°æ®æ¡
|
Nr Ú count_underÚcount_in_rangeÚ
|
count_overÚtimeÚUTCz Asia/Shanghaiu æ°æ®æ¸
æ´å¤±è´¥: )ÚemptyÚcopyÚfillnaÚastypeÚintÚcolumnsÚpdÚ to_datetimeÚdtÚtzÚ tz_localizeÚ
|
tz_convertÚ ExceptionÚprint)ÚselfÚdfÚ
|
cleaned_dfÚes ÚZC:\Users\admin\Documents\trae_projects\trt_analyse\app\services\data_processing_service.pyÚ
|
clean_dataÚ DataProcessingService.clean_data s6 ð :ØIð àJð $×*Ñ*¨1Ó-Jð )3°=Ñ(A×(HÑ(HÌÓ(MJ}Ñ %Ø+5Ð6FÑ+G×+NÑ+NÌsÓ+SJÐ'Ñ (Ø'1°,Ñ'?×'FÑ'FÄsÓ'KJ|Ñ $ð ×+Ñ+Ó+ä%'§^¢^°J¸vÑ4FÓ%G
|
6Ñ"ð fÑ%×(Ñ(×+Ñ+Ñ3à)3°FÑ);×)>Ñ)>×)JÑ)JÈ5Ó)QJvÑ&ð &0°Ñ%7×%:Ñ%:×%EÑ%EÀoÓ%V
|
6Ñ"à Ð øÜó Ü Ð(¨¨Ð,Ô -ØIûð ús C;D Ä
|
D8Ä D3Ä-D8Ä3D8c óX Ub UR ( a 0 $ [ U5 US R 5 US R 5 US R 5 US R 5 S.US R 5 US R 5 US R 5 US R 5 S.US R 5 US R 5 US R 5 US R 5 S.S.nU$ ! [ a n[ SU 35 0 s SnA$ SnAff = f)uK
|
计ç®åºæ¬ç»è®¡ä¿¡æ¯
|
:param df: æ°æ®æ¡
|
:return: ç»è®¡ä¿¡æ¯åå
¸
|
Nr )ÚmeanÚsumÚmaxÚminr r
|
)Ú total_recordsr r r
|
u 计ç®ç»è®¡ä¿¡æ¯å¤±è´¥: )r Úlenr# r$ r% r& r r )r r Ústatsr s r Úcalculate_statisticsÚ*DataProcessingService.calculate_statistics- s6 ð :ØIð ä!$ R£à }Ñ -× 2Ñ 2Ó 4Ø mÑ,×0Ñ0Ó2Ø mÑ,×0Ñ0Ó2Ø mÑ,×0Ñ0Ó2ñ ð Ð /Ñ 0× 5Ñ 5Ó 7Ø Ð .Ñ/×3Ñ3Ó5Ø Ð .Ñ/×3Ñ3Ó5Ø Ð .Ñ/×3Ñ3Ó5ñ #ð |Ñ ,× 1Ñ 1Ó 3Ø lÑ+×/Ñ/Ó1Ø lÑ+×/Ñ/Ó1Ø lÑ+×/Ñ/Ó1ñ ñ Eð* LøÜó Ü Ð.¨q¨cÐ2Ô 3ØIûð ús C,D Ä
|
D)ÄD$Ä D)Ä$D)c ó` Ub UR ( a [ R " 5 $ UR 5 n/ nX2 R n[ [ U5 5 H nUS:X a XV XVS- :¬ nO>U[ U5 S-
|
:X a XV XVS-
|
:¬ nO XV XVS-
|
:¬ =( a XV XVS- :¬ nU( a! U[ U5 S-
|
: a XV XVS- :X a SnUR U5 M X4 nU$ ! [ a- n[ SU 35 [ R " 5 s SnA$ SnAff = f)u
|
è¯å«æå®åçå±é¨æ大å¼ç¹
|
:param df: æ°æ®æ¡
|
:param column: è¦åæçåå
|
:return: å
å«å±é¨æ大å¼ç¹çæ°æ°æ®æ¡
|
Nr é Fu è¯å«å±é¨æ大å¼å¤±è´¥: )
|
r r Ú DataFramer ÚvaluesÚranger( Úappendr r ) r r ÚcolumnÚ maxima_dfÚmaskr/ ÚiÚis_maxr s r Úidentify_local_maximaÚ+DataProcessingService.identify_local_maximaQ s$ ð :Ü<<>Ð !ð" "à Ið
|
DØ Ñ&×-Ñ-Fä3v;Ö'à6à #Y¨&°1±©+Ñ 5FØ#f+¨/Ó)à #Y¨&°1±©+Ñ 5Fð $Y¨&°1±©+Ñ 5× R¸&¹)ÀvÐPQÉcÁ{Ñ:RFö a¤# f£+°¡/Ó 1°f±iÀ6ÈAÉ#Á;Ó6NØ "Fà FÖ#ñ! (ð& "Ià Ð øÜó "Ü Ð1°!°Ð5Ô 6Ü<<>Õ !ûð "ús «C
|
C6 Ã6
|
D-Ä "D(Ä"D-Ä(D-c ó Ub UR ( a [ R " 5 $ UR 5 nX2 R n/ n/ n[ U5 HQ u pxU( d UR U5 M XUS :X a UR U5 M= UR U5 U/nMS U( a UR U5 / n U H n
|
U R U
|
S 5 M UR U n X² R 5 n X»U U :H n U $ ! [ a- n[ SU 35 [ R " 5 s SnA$ SnAff = f)u
|
è¯å«"æåä¸ä¸ªé¶æ®µæ大å¼"
|
:param df: æ°æ®æ¡
|
:param column: è¦åæçåå
|
:return: å
å«é¶æ®µæ大å¼ç¹çæ°æ°æ®æ¡
|
Nr éÿÿÿÿu è¯å«é¶æ®µæ大å¼å¤±è´¥: ) r r r. r r/ Ú enumerater1 Úilocr% r r )r r r2 Úphase_maxima_dfr/ ÚphasesÚ current_phaser5 ÚvalÚ phase_indicesÚphaseÚ phase_pointsÚ max_valueÚ final_maximar s r Úidentify_phase_maximaÚ+DataProcessingService.identify_phase_maxima s3 ð :Ü<<>Ð !ð$ "à ggiOð %Ñ,×3Ñ3FØFØ Mä# FÖ+Þ$Ø!×(Ñ(¨Ö+à ]°1Ñ%5Ñ 6Ó6Ø%×,Ñ,¨QÖ/à mÔ4Ø)*¨ ñ ,ö Ø mÔ,ð MÛ Ø ×$Ñ$ U¨2¡YÖ/ñ ð +×/Ñ/° Ñ>LØ$Ñ,×0Ñ0Ó2IØ'°VÑ(<À Ñ(IÑJLà Ð øÜó "Ü Ð1°!°Ð5Ô 6Ü<<>Õ !ûð "ús «C%D Ä
|
EÄ"EÄ=EÅEc ó¬ US US - US - nUS:X a gUS U- S- n[ US5 $ ! [ a n[ SU 35 S nAgS nAff = f)
|
u[
|
计ç®å个æ°æ®ç¹çåæ ¼ç
|
:param row: æ°æ®è¡
|
:return: åæ ¼çï¼ç¾åæ¯ï¼
|
r r r
|
r ç éd é u 计ç®åæ ¼ç失败: N)Úroundr r )r ÚrowÚtotalÚ pass_rater s r Úcalculate_pass_rateÚ)DataProcessingService.calculate_pass_rate¯ su ð Ø Ñ&¨Ð-=Ñ)>Ñ>ÀÀ\ÑARÑREØzØØ Ð -Ñ.°Ñ6¸#Ñ=IÜ AÓ&Ð &øÜó Ü Ð+¨A¨3Ð/Ô 0Üûð ús 1 1 ±
|
A»AÁAc ó, Ub UR ( a g US R 5 nUS R 5 nUS R 5 nX#- U- nUS:X a gX5- S- n[ US5 $ ! [ a n[ S U 35 SnAgSnAff = f)
|
uT
|
计ç®æ´ä½åæ ¼ç
|
:param df: æ°æ®æ¡
|
:return: æ´ä½åæ ¼çï¼ç¾åæ¯ï¼
|
NrI r r r
|
r rJ rK u 计ç®æ´ä½åæ ¼ç失败: )r r$ rL r r )r r Ú total_underÚtotal_in_rangeÚ
|
total_overrN Úoverall_pass_rater s r Úcalculate_overall_pass_rateÚ1DataProcessingService.calculate_overall_pass_rate¿ s§ ð :Øð Ø ]Ñ+×/Ñ/Ó1KØ Ð 0Ñ 1× 5Ñ 5Ó 7NØLÑ)×-Ñ-Ó/JØ Ñ0°:Ñ=EàzØà!/Ñ!7¸3Ñ >Ð ÜÐ*¨AÓ.Ð .øÜó Ü Ð1°!°Ð5Ô 6Üûð ús AA1 Á A1 Á1
|
BÁ;BÂBc óô Ub UR ( a, [ R " 5 [ R " 5 SS.$ U R U5 nU R U5 nUR ( d UR U R SS9US' U R U5 nUUUS.$ ! [ aD n[ SU 35 [ R " 5 [ R " 5 SS.s SnA$ SnAff = f)ui
|
åææå¼ç¹å¹¶è®¡ç®ç¸å
³ç»è®¡
|
:param df: æ°æ®æ¡
|
:return: å
å«æå¼ç¹åæç»æçåå
¸
|
NrI )Úextreme_pointsÚ phase_maximarV r- )ÚaxisrO u åææå¼ç¹å¤±è´¥: )
|
r r r. r7 rF ÚapplyrP rW r r )r r rZ r[ rV r s r Úanalyze_extreme_pointsÚ,DataProcessingService.analyze_extreme_points× sê ð :ä"$§,¢,£.Ü "§ ¢ £Ø%(ñð ð à !× 7Ñ 7¸Ó ;Nð ×5Ñ5°bÓ9Lð "×'×'Ø.<×.BÑ.BÀ4×C[ÑC[ÐbcÐ.BÐ.d{Ñ+ð !%× @Ñ @ÀÓ DÐ ð #1Ø ,Ø%6ñð øô
|
ó Ü Ð+¨A¨3Ð/Ô 0ä"$§,¢,£.Ü "§ ¢ £Ø%(ñõ ûð ús ÁA&B) Â)
|
C7Â39C2Ã,C7Ã2C7© N)r ) Ú__name__Ú
|
__module__Ú __qualname__Ú__firstlineno__r r* r7 rF rP rW r^ Ú__static_attributes__r` ó r r r s) ò&òP"ôH,"ô\."ò`ò õ0&rf r )Úpandasr Ú functoolsr r r` rf r Ú<module>ri s ðÛ Ý ÷yò yrf
|
