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-09 12:17:02 +08:00
parent 7174f3c77f
commit 75be906ead
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -319,23 +319,23 @@ def main():
if flag: if flag:
# 初始化 # 初始化
db_manager = DatabaseManager(db_config) db_manager = DatabaseManager(db_config)
# custom_query = """
# 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)
# """
custom_query = """ custom_query = """
select select
account_id as id , dw_account as id ,
prov_name || '-' || city_name as city, prov_name || '-' || city_name as city,
address as address address_detail as address
from p99_temp.address_city_1 from p99_temp.address_city
where dw_account not in (select account_id from p70_ai_intelligence.agent_address_complete)
""" """
# custom_query = """
# select
# account_id as id ,
# prov_name || '-' || city_name as city,
# address as address
# from p99_temp.address_city_1
# """
try: try:
# 从数据库获取URL列表 # 从数据库获取URL列表
list = db_manager.get_urls_from_database(custom_query) list = db_manager.get_urls_from_database(custom_query)