From 9a8743df6ec3679f56444b8045b2b3f4004e53a7 Mon Sep 17 00:00:00 2001 From: root Date: Sat, 3 Aug 2024 06:36:31 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E6=95=B0=E6=8D=AE,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py | 4 ++-- .../smart_ccc_custom/获取客户资料列表/customer_list_feign.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py index 3c37e9a..c4f2265 100644 --- a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py +++ b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py @@ -24,8 +24,8 @@ default_args = { } dag = DAG('wf_dag_smart_ccc_custom', default_args=default_args, -# schedule_interval="0 0-23/1 * * *", -schedule_interval="0 8 * * *", +schedule_interval="0 0-23/1 * * *", +# schedule_interval="0 8 * * *", catchup=False, dagrun_timeout=timedelta(minutes=160), max_active_runs=3) diff --git a/dev/workflow/TK_Cust/smart_ccc_custom/获取客户资料列表/customer_list_feign.py b/dev/workflow/TK_Cust/smart_ccc_custom/获取客户资料列表/customer_list_feign.py index 2e206ee..4b33ad6 100644 --- a/dev/workflow/TK_Cust/smart_ccc_custom/获取客户资料列表/customer_list_feign.py +++ b/dev/workflow/TK_Cust/smart_ccc_custom/获取客户资料列表/customer_list_feign.py @@ -78,7 +78,7 @@ def build_query_string(params): def request_list_signature_get(offset,pageSize): print('开始请求数据...') url='https://api-bj.clink.cn/crm/list_customers' - param={'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','Timestamp':current_time_utc,'Expires':86400,'updateStartTime':previous_hour_timestamp(1),'updateEndTime':previous_hour_timestamp(0),'offset':offset,'limit':pageSize} + param={'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','Timestamp':current_time_utc,'Expires':86400,'updateStartTime':previous_hour_timestamp(9),'updateEndTime':previous_hour_timestamp(0),'offset':offset,'limit':pageSize} # param={'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','Timestamp':current_time_utc,'Expires':86400,'updateStartTime':1704038400,'updateEndTime':previous_hour_timestamp(0)} print(f'param: {param}') url_path = build_query_string(param)