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

add workflow 客户地址信息提取,dev

This commit is contained in:
root 2025-12-08 10:21:32 +08:00
parent 326b78ef3a
commit 3e0792e49d
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py
View File

@ -257,7 +257,8 @@ def process_single_item(api_client, item, type, item_index, total_count):
# item 是字典，包含 id 和 address # item 是字典，包含 id 和 address
inputs_data = { inputs_data = {
'id': f"{item.get('id', '')}", 'id': f"{item.get('id', '')}",
'address': f"{item.get('address', '')}" 'address': f"{item.get('address', '')}",
'city':f"{item.get('city', '')}"
} }
result = api_client.call_api_with_inputs(inputs_data) result = api_client.call_api_with_inputs(inputs_data)
@ -319,9 +320,12 @@ def main():
# 初始化 # 初始化
db_manager = DatabaseManager(db_config) db_manager = DatabaseManager(db_config)
custom_query = """ custom_query = """
select dw_account as id ,address_detail as address from p99_temp.address_city select
dw_account as id ,
prov_name || '-' || city_name as city,
address_detail as address
from p99_temp.address_city
where dw_account not in (select account_id from p70_ai_intelligence.agent_address_complete) where dw_account not in (select account_id from p70_ai_intelligence.agent_address_complete)
""" """
try: try: