|
|
@@ -45,7 +45,7 @@ def douyin_task():
|
|
|
# 创建一个线程池
|
|
|
valid_data = [user_data for user_data in data if user_data['sheet'] is not None]
|
|
|
with concurrent.futures.ThreadPoolExecutor() as executor:
|
|
|
- futures = [executor.submit(kuaishou_start, user_data) for user_data in valid_data]
|
|
|
+ futures = [executor.submit(douyin_start, user_data) for user_data in valid_data]
|
|
|
# 等待所有任务执行完成
|
|
|
for future in concurrent.futures.as_completed(futures):
|
|
|
# 获取每个任务的执行结果
|
|
|
@@ -67,9 +67,8 @@ def kuanshou_task():
|
|
|
print("处理结果:", result)
|
|
|
print("快手数据抓取定时任务执行完成.")
|
|
|
|
|
|
-
|
|
|
schedule.every().day.at("19:20").do(kuanshou_task)
|
|
|
-schedule.every().day.at("19:20").do(douyin_task)
|
|
|
+schedule.every().day.at("19:30").do(douyin_task)
|
|
|
schedule.every().day.at("18:00").do(zhannei_task)
|
|
|
|
|
|
|
