|
|
@@ -237,8 +237,9 @@ def main():
|
|
|
"""主函数"""
|
|
|
# 创建配置
|
|
|
config = AppConfig(
|
|
|
- base_path=r"F:\BaiduNetdiskDownload\标准化数据\stander_parquet",
|
|
|
- max_workers=2,
|
|
|
+ # base_path=r"F:\BaiduNetdiskDownload\标准化数据\stander_parquet",
|
|
|
+ base_path=f"./data/标准化数据/stander_parquet",
|
|
|
+ max_workers=10,
|
|
|
batch_size=10000,
|
|
|
upsert_enabled=True, # 启用UPSERT
|
|
|
db_config=DatabaseConfig(
|