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-09-22 19:21:52 +08:00
parent 6968179da8
commit cc38b7ed29
5 changed files with 5 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Account同步/Jdy_account_01_feign.py
View File

@ -189,7 +189,7 @@ def main():
APP_ID = params['app_id']
ENTRY_ID = params['entry_id']
start_dt = get_previous_date(1)
start_dt = get_previous_date(3)
end_dt = get_previous_date(0)
# 创建客户端

2
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Contact同步/Jdy_contact_01_feign.py
View File

@ -189,7 +189,7 @@ def main():
APP_ID = params['app_id']
ENTRY_ID = params['entry_id']
start_dt = get_previous_date(1)
start_dt = get_previous_date(3)
end_dt = get_previous_date(0)
# 创建客户端

2
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访AE排期同步/Jdy_ae_01_feign.py
View File

@ -189,7 +189,7 @@ def main():
APP_ID = params['app_id']
ENTRY_ID = params['entry_id']
start_dt = get_previous_date(1)
start_dt = get_previous_date(3)
end_dt = get_previous_date(0)
# 创建客户端

2
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访Visit同步/Jdy_daily_visit_feign.py
View File

@ -189,7 +189,7 @@ def main():
APP_ID = params['app_id']
ENTRY_ID = params['entry_id']
start_dt = get_previous_date(1)
start_dt = get_previous_date(3)
end_dt = get_previous_date(0)
# 创建客户端

31
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py
View File

@ -114,34 +114,6 @@ dag=dag)
Jdy_account_01_feign >> Jdy_account_01_load
Jdy_calendar_01_feign = SSHOperator(
ssh_hook=sshHook,
task_id='Jdy_calendar_01_feign',
command='python3 /data/airflow/etl/API/Jdy_calendar_01_feign.py',
depends_on_past=False,
retries=3,
dag=dag)
Jdy_calendar_01_load = SSHOperator(
ssh_hook=sshHook,
task_id='Jdy_calendar_01_load',
command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}',
params={'my_param':"Jdy_calendar_01_load"},
depends_on_past=False,
retries=3,
dag=dag)
Jdy_calendar_01_feign >> Jdy_calendar_01_load
jdy_calendar_8832 = SSHOperator(
ssh_hook=sshHook,
task_id='jdy_calendar_8832',
command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ',
params={'my_param':"S98_S_jdy_calendar"},
depends_on_past=False,
retries=3,
dag=dag)
jdy_account_4319 = SSHOperator(
ssh_hook=sshHook,
task_id='jdy_account_4319',
@ -182,5 +154,4 @@ Jdy_contact_01_load >> jdy_contact_6445
Jdy_ae_01_load >> jdy_ae_plan_2600
Jdy_daily_visit_load >> jdy_daily_visit_9783
Jdy_account_01_load >> jdy_account_4319
Jdy_calendar_01_load >> jdy_calendar_8832
jdy_calendar_8832 >> task_failed
jdy_account_4319 >> task_failed