U
|
ìh8e¸ ã @ sz d dl Z d dlmZmZ d dlmZ d dlmZ d dlmZ d dl m
|
Z
|
dd Z d d
|
Z ed d d Z eedddZdS )é N)ÚdatetimeÚ timedelta)ÚLogUtils)Ú DateUtils)ÚEnumSiteStatus)ÚConfigc s d fdd }|S )u 失败éè¯é»è¾Nc s d}d}||k r|dkr|d kr* | }n
|
| |}|dkr|d }t | d¡ ||k rt d| d|| ¡ t |¡ qt | d¡ qq|S )NFr é u 失败u ç¨åºä¼å¨u& ç§åå次å°è¯, å©ä½å°è¯æ¬¡æ°u æå)r ÚerrorÚtimeÚsleepÚinfo)ÚselfZ retry_timesÚ wait_timeÚtagÚobjZsucessÚcount©Úfunc© úBE:\PycharmProject\fugitive_dust_new/src\task\request_task_proxy.pyÚinner s
|
|
zretry.<locals>.inner)Nr ©r r r r r Úretry s r c s dt t ttd fdd }|S )u åæ¶æ®µå¾ªç¯æ§è¡é»è¾N)Ú
|
start_timeÚend_timeÚranger c sÄ t |||¡}t tjddd t d| d| d| d| dt|
|
¡ |D ]^}t |¡ | ||d |d
|
d }|d krtjddd d S |d krRtjddd d S qRtjddd dS )u
|
Args:
|
start_time: å¼å§æ¶é´
|
end_time: ç»ææ¶é´
|
range: æ¶é´å段é´éï¼åä½å°æ¶
|
wait_time: æ¯æ®µå¾ªç¯æ§è¡é´éï¼åä½ç§
|
obj: èªå®ä¹ä»»æç±»åé带åæ°
|
z}-----------------------------------------------------------------------------------------------------------------------------é )Úprefixu åæ¶æ®µä»»å¡å¼å§ | èµ·å§: u | ç»æ: u | å¨æ: u å°æ¶ | çå¾
: u ç§ | 次æ°: r r )ÚsTimeÚeTimeÚbreakFN)r Ú
|
time_sliceÚprintr r Úlenr
|
r ) r r r r r r Z time_listÚitemÚrr r r r ( s
|
,
|
z$time_phased_execution.<locals>.inner)N)r Úintr r r r Útime_phased_execution% s r' )Úreturnc C sJ t | dkr,t jj}t ¡ }|t|d S t| dd d}|d jS dS )u9 è·åç«ç¹æ°æ®ææ°æ¶å»å表ä¸çæ¶é´æå°å¼r ©Údaysc S s | j S )N)Ú latest_time)Úxr r r Ú<lambda>M ó z get_min_time.<locals>.<lambda>)ÚkeyN) r# r Úrequest_configÚfirst_request_offset_daysr Ú today_0amr Úsortedr+ )Zsite_time_listZ offset_daysÚtÚlr r r Ú get_min_timeD s
|
r6 )r Ú site_statusc C sV t ¡ }|tjkr| |fS |tjkrR| }t | |¡}|dkrJ|tdd }||fS dS )uD æ ¹æ®èµ·å§æ¶é´å设å¤ç¶æ, 计ç®æ°æ®ç¬åçæ¶æ®µèå´é r) N)r r2 r ÚOnlineÚStopÚ time_distancer )r r7 ÚnowÚstÚ diff_daysr r r Úget_request_durationQ s
|
|
r? )r
|
r r Úutils.log_utilsr Úutils.date_utilsr Ú enumeration.enum_site_statusr Ú config.configr r r' r6 r? r r r r Ú<module> s
|
