1

app/etl/dm/dm_pitcher_daily_overview.py

@@ -9,6 +9,7 @@ db= MysqlUtils()
 ck = CkUtils()
 
 def dm_pitcher_daily_overview():
+    print("run> dm_pitcher_daily_overview")
     sql=f"""
 select 
         q.pitcher,

app/etl/dw/dw_channel_daily.py

@@ -11,6 +11,7 @@ ck = CkUtils()
 
 
 def dw_daily_channel():
+    print("run> dw_daily_channel")
 
     sql="""insert into dw_daily_channel
 select
@@ -248,6 +249,7 @@ def dw_channel_amount_daily():
 
 
 def dw_channel():
+    print('run> dw_channel')
     dw_channel_daily()
     dw_channel_user_daily()
     dw_channel_amount_daily()
@@ -256,6 +258,6 @@ def dw_channel():
 if __name__ == '__main__':
 
     # dw_daily_channel()
-    # dw_channel()
+    dw_channel()
     # dw_channel_amount_daily()
-    dw_channel_user_daily()
+    # dw_channel_user_daily()

app/etl/dw/dw_pitcher_daily.py

@@ -11,6 +11,7 @@ ck = CkUtils()
 
 
 def dw_pitcher_trend():
+    print('run> dw_pitcher_trend')
     sql="""insert into dw_pitcher_trend 
     select a.dt,pitcher,
        sum(cost),

app/etl/src/src_book_info.py

@@ -7,6 +7,7 @@ db= MysqlUtils()
 ck = CkUtils()
 
 def src_book_info():
+    print("run> src_book_info")
     sql="""SELECT  date_format(a.effect_day,'%Y-%m-%d'),
             case a.type when 'mp' then 'vx' when 'gdt' then 'qq' end type,
             b.book_name,c.platform_name,a.node_price from t_platform_book_ratio a