diff --git a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py index c9d9bf5..5070ee0 100644 --- a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py +++ b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py @@ -319,13 +319,21 @@ 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 -dw_account as id , +account_id as id , prov_name || '-' || city_name as city, -address_detail as address -from p99_temp.address_city_1 -where dw_account not in (select account_id from p70_ai_intelligence.agent_address_complete) +address as address +from p99_temp.address_city_1 """ try: