hourlyRun.py 670 B

123456789101112131415161718192021222324252627282930313233
  1. from app.api_data import get_order
  2. from app.etl import data_stat_run
  3. from model.DateUtils import DateUtils
  4. from app.api_data import get_cost
  5. from app.etl.dw import dw_image_cost_day
  6. from app import task
  7. du = DateUtils()
  8. import time
  9. from model.DingTalkUtils import DingTalkUtils
  10. if __name__ == '__main__':
  11. st = time.time()
  12. # 订单数据和消耗数据拉取
  13. task.hourly()
  14. # 数据处理
  15. data_stat_run.hourly()
  16. # 广告数据
  17. get_cost.hourly() # 广告相关消耗数据
  18. dw_image_cost_day.hourly()
  19. if int(time.time()-st)>1500:
  20. DingTalkUtils.send(f"小时任务耗时{int(time.time()-st)}秒",phone="18860455786")