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-25 11:39:32 +08:00
parent 24f1804268
commit a9500ec642
7 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/tk_api/custom_events_activity_submit/S98_S_custom_events_activity_submit.sql
View File

@ -37,9 +37,9 @@ insert into p10_sa.S98_S_custom_events_activity_submit
, target_id , target_id
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_custom_events_activity_submit from p00_tal.S98_S_custom_events_activity_submit
; ;
delete from p12_sfull.S98_S_custom_events_activity_submit delete from p12_sfull.S98_S_custom_events_activity_submit
; where (id) in (select id from p10_sa.S98_S_custom_events_activity_submit) ;
; ;
insert into p12_sfull.S98_S_custom_events_activity_submit insert into p12_sfull.S98_S_custom_events_activity_submit
( id ( id

4
dev/workflow/TK_Cust/tk_api/customer_events_c_minipro_page_view/S98_S_customer_events_c_minipro_page_view.sql
View File

@ -55,9 +55,9 @@ insert into p10_sa.S98_S_customer_events_c_minipro_page_view
, url , url
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_customer_events_c_minipro_page_view from p00_tal.S98_S_customer_events_c_minipro_page_view
; ;
delete from p12_sfull.S98_S_customer_events_c_minipro_page_view delete from p12_sfull.S98_S_customer_events_c_minipro_page_view
; where (id) in (select id from p10_sa.S98_S_customer_events_c_minipro_page_view) ;
; ;
insert into p12_sfull.S98_S_customer_events_c_minipro_page_view insert into p12_sfull.S98_S_customer_events_c_minipro_page_view
( id ( id

4
dev/workflow/TK_Cust/tk_api/customer_events_click_link_in_page/S98_S_customer_events_click_link_in_page.sql
View File

@ -61,9 +61,9 @@ insert into p10_sa.S98_S_customer_events_click_link_in_page
, url , url
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_customer_events_click_link_in_page from p00_tal.S98_S_customer_events_click_link_in_page
; ;
delete from p12_sfull.S98_S_customer_events_click_link_in_page delete from p12_sfull.S98_S_customer_events_click_link_in_page
; where (id) in (select id from p10_sa.S98_S_customer_events_click_link_in_page) ;
; ;
insert into p12_sfull.S98_S_customer_events_click_link_in_page insert into p12_sfull.S98_S_customer_events_click_link_in_page
( id ( id

4
dev/workflow/TK_Cust/tk_api/customer_events_open_app/S98_S_customer_events_open_app.sql
View File

@ -59,9 +59,9 @@ insert into p10_sa.S98_S_customer_events_open_app
, url , url
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_customer_events_open_app from p00_tal.S98_S_customer_events_open_app
; ;
delete from p12_sfull.S98_S_customer_events_open_app delete from p12_sfull.S98_S_customer_events_open_app
; where (id) in (select id from p10_sa.S98_S_customer_events_open_app) ;
; ;
insert into p12_sfull.S98_S_customer_events_open_app insert into p12_sfull.S98_S_customer_events_open_app
( id ( id

4
dev/workflow/TK_Cust/tk_api/customer_events_subscribe/S98_S_customer_events_subscribe.sql
View File

@ -33,9 +33,9 @@ insert into p10_sa.S98_S_customer_events_subscribe
, target_id , target_id
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_customer_events_subscribe from p00_tal.S98_S_customer_events_subscribe
; ;
delete from p12_sfull.S98_S_customer_events_subscribe delete from p12_sfull.S98_S_customer_events_subscribe
; where (id) in (select id from p10_sa.S98_S_customer_events_subscribe) ;
; ;
insert into p12_sfull.S98_S_customer_events_subscribe insert into p12_sfull.S98_S_customer_events_subscribe
( id ( id

4
dev/workflow/TK_Cust/tk_api/customer_events_wechat_scan/S98_S_customer_events_wechat_scan.sql
View File

@ -33,9 +33,9 @@ insert into p10_sa.S98_S_customer_events_wechat_scan
, target_name , target_name
, etl_tx_dt , etl_tx_dt
from p00_tal.S98_S_customer_events_wechat_scan from p00_tal.S98_S_customer_events_wechat_scan
; ;
delete from p12_sfull.S98_S_customer_events_wechat_scan delete from p12_sfull.S98_S_customer_events_wechat_scan
; where (id) in (select id from p10_sa.S98_S_customer_events_wechat_scan) ;
; ;
insert into p12_sfull.S98_S_customer_events_wechat_scan insert into p12_sfull.S98_S_customer_events_wechat_scan
( channel_account ( channel_account

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

@ -23,7 +23,7 @@ default_args = {
} }
dag = DAG('wf_dag_tk_api', default_args=default_args, dag = DAG('wf_dag_tk_api', default_args=default_args,
schedule_interval="0 0 * * *", schedule_interval="1 0 * * *",
catchup=False, catchup=False,
dagrun_timeout=timedelta(minutes=160), dagrun_timeout=timedelta(minutes=160),
max_active_runs=3) max_active_runs=3)