diff --git a/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py b/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py index c90bef9..5566ab0 100644 --- a/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py +++ b/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py @@ -329,7 +329,7 @@ def process_single_item(api_client, item_text, type, item_index, total_count): def main(): """主函数""" # 配置并发数 - MAX_WORKERS = 10 # 可调整为5或10 + MAX_WORKERS = 3 # 可调整为5或10 # 数据库配置 db_config = { @@ -361,7 +361,7 @@ def main(): WITH numbered_names AS ( SELECT name, - (ROW_NUMBER() OVER (ORDER BY dw_account) - 1) /10 as batch_num + (ROW_NUMBER() OVER (ORDER BY dw_account) - 1) /5 as batch_num FROM p30_common.v_sql_cleaned_cn_d_account_info WHERE name NOT IN ( SELECT "search"