ck 4 роки тому
батько
коміт
566c17be62
1 змінених файлів з 8 додано та 2 видалено
  1. 8 2
      app/etl/dw/dw_channel_daily.py

+ 8 - 2
app/etl/dw/dw_channel_daily.py

@@ -266,6 +266,11 @@ def dw_channel_amount_daily_reverse():
     db.dm.executeMany(isql, data)
 
 
+def del_channel():
+    sql = 'delete from dw_channel where channel in ("腾云文渊", "青渊文学", "玉竹文渊", "赤瞳伴读","扶摇阅文")'
+    db.dm.execute(sql)
+
+
 
 def dw_channel():
     print('run> dw_channel')
@@ -273,7 +278,7 @@ def dw_channel():
     dw_channel_user_daily()
     dw_channel_amount_daily()
     dw_channel_amount_daily_reverse()
-
+    del_channel()
 
 if __name__ == '__main__':
 
@@ -281,4 +286,5 @@ if __name__ == '__main__':
     # dw_channel()
     # dw_channel_amount_daily()
     # dw_channel_user_daily()
-    dw_channel_amount_daily_reverse()
+    # dw_channel_amount_daily_reverse()
+    del_channel()