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

add workflow 天润Smart-ccc客户数据,dev

This commit is contained in:
root 2024-08-03 06:36:31 +08:00
parent 655f8b545f
commit 9a8743df6e
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py
View File

@ -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)

2
dev/workflow/TK_Cust/smart_ccc_custom/获取客户资料列表/customer_list_feign.py
View File

@ -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)