dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 客户信息补全【156,dev

This commit is contained in:
root 2025-12-06 16:06:56 +08:00
parent 9722349fd7
commit 326b78ef3a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py
View File

@ -329,7 +329,7 @@ def process_single_item(api_client, item_text, type, item_index, total_count):
def main(): def main():
"""主函数""" """主函数"""
# 配置并发数 # 配置并发数
MAX_WORKERS = 10 # 可调整为5或10 MAX_WORKERS = 3 # 可调整为5或10
# 数据库配置 # 数据库配置
db_config = { db_config = {
@ -361,7 +361,7 @@ def main():
WITH numbered_names AS ( WITH numbered_names AS (
SELECT SELECT
name, 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 FROM p30_common.v_sql_cleaned_cn_d_account_info
WHERE name NOT IN ( WHERE name NOT IN (
SELECT "search" SELECT "search"