|
@@ -1,9 +1,6 @@
|
|
|
"""
|
|
|
@author: luojunhui
|
|
|
"""
|
|
|
-"""
|
|
|
-@author: luojunhui
|
|
|
-"""
|
|
|
import time
|
|
|
from concurrent.futures.thread import ThreadPoolExecutor
|
|
|
|
|
@@ -29,6 +26,6 @@ def migrate_daily(dt):
|
|
|
print("{} successfully insert {} rows, totally cost {} seconds".format(dt, len(data), b - a))
|
|
|
|
|
|
|
|
|
-dt_list = generate_daily_strings("20240613", "20240617")
|
|
|
+dt_list = generate_daily_strings("20240613", "20240616")
|
|
|
for dt in dt_list:
|
|
|
migrate_daily(dt)
|