diff --git a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py index 5070ee0..0d9c85f 100644 --- a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py +++ b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py @@ -319,22 +319,22 @@ def main(): if flag: # 初始化 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 = """ select -account_id as id , +dw_account as id , prov_name || '-' || city_name as city, -address as address -from p99_temp.address_city_1 +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 = """ +# select +# account_id as id , +# prov_name || '-' || city_name as city, +# address as address +# from p99_temp.address_city_1 +# """ try: # 从数据库获取URL列表