diff --git a/DB.py b/DB.py index be2a6ee..9f83c81 100644 --- a/DB.py +++ b/DB.py @@ -503,7 +503,7 @@ class DBVidcon: class DBSA: FLUSH_EVERY_ROWS = 100 # 行阈值 - FLUSH_INTERVAL = 30 # 秒阈值 + FLUSH_INTERVAL = 40 # 秒阈值 _buf_op: List[Dict] = [] _buf_vid: List[Dict] = [] diff --git a/main.py b/main.py index a91bb04..8a9eae2 100644 --- a/main.py +++ b/main.py @@ -165,7 +165,7 @@ def integrate_data_parallel(): futures = [] for payload, kitem in tasks: futures.append(executor.submit(search_worker, payload, kitem, flag)) - time.sleep(3) + time.sleep(1) rollback = {0: [], 1: [], 2: []}