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

add workflow 荟聚API,dev

This commit is contained in:
root 2024-04-07 10:09:12 +08:00
parent df9e00b46c
commit e60f353b9b
1 changed files with 58 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
dev/workflow/TK_Cust/tk_api/荟聚API/wf_dag_tk_api.py
View File

@ -37,7 +37,7 @@ task_failed = EmailOperator (
cc=[""],
subject="tk_api_failed",
html_content='<h3>您好，tk_api作业失败，请及时处理" </h3>')
scrm_contact_feign = SSHOperator(
ssh_hook=sshHook,
task_id='scrm_contact_feign',
@ -56,7 +56,7 @@ retries=3,
dag=dag)
scrm_contact_feign >> scrm_contact_load
scrm_contact_1129 = SSHOperator(
ssh_hook=sshHook,
task_id='scrm_contact_1129',
@ -65,7 +65,7 @@ params={'my_param':"S98_S_scrm_contact"},
depends_on_past=False,
retries=3,
dag=dag)
custom_events_update_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_update_feign',
@ -84,7 +84,7 @@ retries=3,
dag=dag)
custom_events_update_feign >> custom_events_update_load
update_scrm_contact_feign = SSHOperator(
ssh_hook=sshHook,
task_id='update_scrm_contact_feign',
@ -103,7 +103,7 @@ retries=3,
dag=dag)
update_scrm_contact_feign >> update_scrm_contact_load
customer_events_feign = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_feign',
@ -122,7 +122,7 @@ retries=3,
dag=dag)
customer_events_feign >> customer_events_load
customer_event_meta_feign = SSHOperator(
ssh_hook=sshHook,
task_id='customer_event_meta_feign',
@ -141,7 +141,7 @@ retries=3,
dag=dag)
customer_event_meta_feign >> customer_event_meta_load
scrm_contact_lastupdated_4112 = SSHOperator(
ssh_hook=sshHook,
task_id='scrm_contact_lastupdated_4112',
@ -150,7 +150,7 @@ params={'my_param':"S98_S_scrm_contact_lastupdated"},
depends_on_past=False,
retries=3,
dag=dag)
customer_event_meta_2268 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_event_meta_2268',
@ -159,7 +159,7 @@ params={'my_param':"S98_S_customer_event_meta"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_lastupdated_8895 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_lastupdated_8895',
@ -168,7 +168,7 @@ params={'my_param':"S98_S_customer_events_lastupdated"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_3292 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_3292',
@ -177,7 +177,7 @@ params={'my_param':"S98_S_customer_events"},
depends_on_past=False,
retries=3,
dag=dag)
custom_events_9_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_9_feign',
@ -196,7 +196,7 @@ retries=3,
dag=dag)
custom_events_9_feign >> custom_events_9_load
custom_events_6_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_6_feign',
@ -215,7 +215,7 @@ retries=3,
dag=dag)
custom_events_6_feign >> custom_events_6_load
custom_events_4_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_4_feign',
@ -234,7 +234,7 @@ retries=3,
dag=dag)
custom_events_4_feign >> custom_events_4_load
custom_events_8_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_8_feign',
@ -253,7 +253,7 @@ retries=3,
dag=dag)
custom_events_8_feign >> custom_events_8_load
custom_events_3_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_3_feign',
@ -272,7 +272,7 @@ retries=3,
dag=dag)
custom_events_3_feign >> custom_events_3_load
custom_events_1_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_1_feign',
@ -291,7 +291,7 @@ retries=3,
dag=dag)
custom_events_1_feign >> custom_events_1_load
custom_events_7_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_7_feign',
@ -310,7 +310,7 @@ retries=3,
dag=dag)
custom_events_7_feign >> custom_events_7_load
custom_events_2_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_2_feign',
@ -329,7 +329,7 @@ retries=3,
dag=dag)
custom_events_2_feign >> custom_events_2_load
custom_events_5_feign = SSHOperator(
ssh_hook=sshHook,
task_id='custom_events_5_feign',
@ -348,7 +348,7 @@ retries=3,
dag=dag)
custom_events_5_feign >> custom_events_5_load
customer_events_submit_form_4283 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_submit_form_4283',
@ -357,7 +357,7 @@ params={'my_param':"S98_S_customer_events_submit_form"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_wechat_scan_2105 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_wechat_scan_2105',
@ -366,7 +366,7 @@ params={'my_param':"S98_S_customer_events_wechat_scan"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_subscribe_5997 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_subscribe_5997',
@ -375,7 +375,7 @@ params={'my_param':"S98_S_customer_events_subscribe"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_click_link_in_page_2034 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_click_link_in_page_2034',
@ -384,7 +384,7 @@ params={'my_param':"S98_S_customer_events_click_link_in_page"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_open_content_page_9684 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_open_content_page_9684',
@ -393,7 +393,7 @@ params={'my_param':"S98_S_customer_events_open_content_page"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_open_app_5878 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_open_app_5878',
@ -402,7 +402,7 @@ params={'my_param':"S98_S_customer_events_open_app"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_open_page_7519 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_open_page_7519',
@ -411,7 +411,7 @@ params={'my_param':"S98_S_customer_events_open_page"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_c_minipro_page_view_9309 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_c_minipro_page_view_9309',
@ -420,7 +420,7 @@ params={'my_param':"S98_S_customer_events_c_minipro_page_view"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_add_user_9393 = SSHOperator(
ssh_hook=sshHook,
task_id='customer_events_add_user_9393',
@ -429,19 +429,33 @@ params={'my_param':"S98_S_customer_events_add_user"},
depends_on_past=False,
retries=3,
dag=dag)
scrm_contact_load >> scrm_contact_1129
update_scrm_contact_load >> scrm_contact_lastupdated_4112
customer_event_meta_load >> customer_event_meta_2268
custom_events_update_load >> customer_events_lastupdated_8895
customer_events_load >> customer_events_3292
custom_events_9_load >> customer_events_wechat_scan_2105
custom_events_6_load >> customer_events_submit_form_4283
custom_events_4_load >> customer_events_subscribe_5997
custom_events_8_load >> customer_events_click_link_in_page_2034
custom_events_1_load >> customer_events_open_app_5878
custom_events_2_load >> customer_events_open_content_page_9684
custom_events_3_load >> customer_events_open_page_7519
custom_events_5_load >> customer_events_c_minipro_page_view_9309
custom_events_7_load >> customer_events_add_user_9393
customer_events_add_user_9393 >> task_failed
scrm_contact_load >> scrm_contact_1129
update_scrm_contact_load >> scrm_contact_lastupdated_4112
customer_event_meta_load >> customer_event_meta_2268
custom_events_update_load >> customer_events_lastupdated_8895
customer_events_load >> customer_events_3292
custom_events_9_load >> customer_events_wechat_scan_2105
custom_events_6_load >> customer_events_submit_form_4283
custom_events_4_load >> customer_events_subscribe_5997
custom_events_8_load >> customer_events_click_link_in_page_2034
custom_events_1_load >> customer_events_open_app_5878
custom_events_2_load >> customer_events_open_content_page_9684
custom_events_3_load >> customer_events_open_page_7519
custom_events_5_load >> customer_events_c_minipro_page_view_9309
custom_events_7_load >> customer_events_add_user_9393
customer_events_add_user_9393 >> task_failed
scrm_contact_lastupdated_4112 >> task_failed
customer_event_meta_2268 >> task_failed
customer_events_lastupdated_8895 >> task_failed
customer_events_3292 >> task_failed
customer_events_wechat_scan_2105 >> task_failed
customer_events_submit_form_4283 >> task_failed
customer_events_subscribe_5997 >> task_failed
customer_events_click_link_in_page_2034 >> task_failed
customer_events_open_app_5878 >> task_failed
customer_events_open_content_page_9684 >> task_failed
customer_events_open_page_7519 >> task_failed
customer_events_c_minipro_page_view_9309 >> task_failed