update
This commit is contained in:
parent
39bd87e868
commit
6f51eaa298
|
|
@ -117,7 +117,7 @@ def migrateSiteHotLogs(site_name, query_date):
|
|||
copy_start = time.time()
|
||||
# import shutil
|
||||
# shutil.copy(hot_db, hot_db_tmp)
|
||||
mw.fastCopy(hot_db, hot_db_tmp, 512 * 1024 * 1024)
|
||||
mw.fastCopy(hot_db, hot_db_tmp, 256 * 1024)
|
||||
print(f"[{site_name}] 备份完成,耗时 {time.time() - copy_start:.2f}s")
|
||||
if not os.path.exists(hot_db_tmp):
|
||||
return mw.returnMsg(False, f"{site_name} migrating fail, copy tmp file!")
|
||||
|
|
|
|||
|
|
@ -319,7 +319,7 @@ def toSize(size, middle='') -> str:
|
|||
s = u
|
||||
return str(round(size, 2)) + middle + u
|
||||
|
||||
def fastCopy(src, dst, buffer_size=128 * 1024 * 1024): # 128MB 缓冲区
|
||||
def fastCopy(src, dst, buffer_size=256 * 1024): # 128MB 缓冲区
|
||||
with open(src, 'rb') as fsrc:
|
||||
with open(dst, 'wb') as fdst:
|
||||
shutil.copyfileobj(fsrc, fdst, length=buffer_size)
|
||||
|
|
|
|||
Loading…
Reference in New Issue