run_recommend.py 1.0 KB

1234567891011121314151617181920212223242526272829303132
  1. # -*- coding: utf-8 -*-
  2. # @Author: wangkun
  3. # @Time: 2022/3/30
  4. import datetime
  5. import os
  6. import sys
  7. import time
  8. sys.path.append(os.getcwd())
  9. from main.common import Common
  10. from main.recommend import Recommend
  11. class Main:
  12. # 抓取及上传 job
  13. @classmethod
  14. def main(cls, env):
  15. while True:
  16. if 21 >= datetime.datetime.now().hour >= 8:
  17. # 抓取视频列表
  18. Common.logger('recommend').info('开始抓取微视视频\n')
  19. Recommend.get_feeds('recommend')
  20. # 下载/上传
  21. Common.logger('recommend').info('开始下载/上传视频\n')
  22. Recommend.run_download_publish('recommend', env)
  23. # 清除日志
  24. Common.del_logs('recommend')
  25. Common.logger('recommend').info('今日抓取任务结束,休眠{}小时', 24-datetime.datetime.now().hour)
  26. time.sleep(3600*(24-datetime.datetime.now().hour))
  27. if __name__ == "__main__":
  28. Main.main('prod')