检查更新逻辑,2、修正0 无法退出程序的问题。
This commit is contained in:
@@ -4,6 +4,7 @@ import time
|
||||
import logging
|
||||
import threading
|
||||
import socket
|
||||
import sys
|
||||
from datetime import timedelta
|
||||
from concurrent.futures import ThreadPoolExecutor, as_completed
|
||||
import pandas as pd
|
||||
@@ -499,7 +500,13 @@ class DataDownloader:
|
||||
log_error(f"释放批量更新的SQLAlchemy引擎失败: {e}")
|
||||
|
||||
def create_dirs(self):
|
||||
# 创建基础目录
|
||||
os.makedirs(Config.BASE_DIR, exist_ok=True)
|
||||
# 创建代码文件目录
|
||||
os.makedirs(os.path.dirname(Config.INPUT_FILE), exist_ok=True)
|
||||
# 创建输出目录
|
||||
os.makedirs(Config.OUTPUT_DIR, exist_ok=True)
|
||||
# 创建指数目录
|
||||
os.makedirs(Config.INDEX_DIR, exist_ok=True)
|
||||
|
||||
# 优化 fetch_data_with_retry 方法,改进请求频率控制
|
||||
@@ -800,7 +807,8 @@ class ConsoleDataDownloader:
|
||||
"""使用指定的选项运行"""
|
||||
try:
|
||||
if choice == '0':
|
||||
return
|
||||
print("程序正在退出...")
|
||||
sys.exit(0)
|
||||
if choice == '6': # 新增全部工作逻辑
|
||||
print("开始执行全部工作...")
|
||||
start_time = time.time()
|
||||
|
||||
Reference in New Issue
Block a user