1

app/etl/sync_to_ck_daily.py

@@ -11,28 +11,29 @@ ck = CkUtils()
 dt = DateUtils()
 
 from sync_to_ck_task import *
-
+yestoday=dt.get_n_days(-1)
+today=dt.get_n_days()
 
 def run(ymd):
     # 全量
-    pitcher_change()
-    book_change()
-    account_change()
-    platform_change()
+    # pitcher_change()
+    # book_change()
+    # account_change()
+    # platform_change()
 
     # 天
-    daily_vx_campaign(ymd)
-    adcreative()
+    # daily_vx_campaign(ymd)
+    # adcreative()
 
     # 小时
-    order(ymd)
-    daily_vx(ymd)
-    daily_qq(ymd)
+    # order(ymd)
+    # daily_vx(ymd)
+    # daily_qq(ymd)
+    pass
 
 
 
 
 
 if __name__ == '__main__':
-    ymd=dt.get_n_days(-1)
-    run(ymd)
+    order(yestoday)

app/etl/sync_to_ck_hourly.py

@@ -10,28 +10,25 @@ db = MysqlUtils()
 ck = CkUtils()
 dt = DateUtils()
 
-
-def run():
-    advertiser_vx_qq()
-
-
-
-    try:
-        order(ymd)
-    except:
-        DingTalkUtils.send("[order]同步到ck出错:",'18860455786')
-    try:
-        daily_qq(ymd)
-    except:
-        DingTalkUtils.send("[daily_qq]到ck出错:", '18860455786,')
-    try:
-        daily_vx(ymd)
-    except:
-        DingTalkUtils.send("[daily_vx]同步到ck出错", '18860455786,')
-
+today=dt.get_n_days()
+# def run():
+    # advertiser_vx_qq()
+    #
+    #
+    #
+    # try:
+    #     order(ymd)
+    # except:
+    #     DingTalkUtils.send("[order]同步到ck出错:",'18860455786')
+    # try:
+    #     daily_qq(ymd)
+    # except:
+    #     DingTalkUtils.send("[daily_qq]到ck出错:", '18860455786,')
+    # try:
+    #     daily_vx(ymd)
+    # except:
+    #     DingTalkUtils.send("[daily_vx]同步到ck出错", '18860455786,')
 
 
 if __name__ == '__main__':
-    ymd = dt.get_n_days()
-    log.debug("run  " + ymd)
-    run()
+    order(today)