zhangyong 5 miesięcy temu
rodzic
commit
5c295712b9
2 zmienionych plików z 31 dodań i 2 usunięć
  1. 7 2
      spider/crawler_offline/xng_zhanghao.py
  2. 24 0
      xng_zh_job.py

+ 7 - 2
spider/crawler_offline/xng_zhanghao.py

@@ -16,8 +16,9 @@ from selenium.webdriver.common.by import By
 
 from application.common.redis.xng_redis import xng_get_video_data
 
+import schedule
 
-class XiaoNianGaoZH(object):
+class XNGZH(object):
 
     def save_pq_uid(self, content):
         current_time = datetime.now()
@@ -164,6 +165,10 @@ class XiaoNianGaoZH(object):
                         content = file.read()
                 time.sleep(1)
             self.save_pq_uid(content)
+            print("成功")
+
+
 
 if __name__ == '__main__':
-    XiaoNianGaoZH.get_video_info_2()
+    x = XNGZH()
+    x.get_video_info_2()  # 调用任务调度函数

+ 24 - 0
xng_zh_job.py

@@ -0,0 +1,24 @@
+import schedule
+import time
+
+from spider.crawler_offline.xng_zhanghao import XNGZH
+
+
+def bot_xng_count_recommend():
+    try:
+        xng = XNGZH()
+        xng.get_video_info_2()
+    except Exception as e:
+        print(f"新推荐异常了{e}")
+
+def schedule_tasks():
+    schedule.every().day.at("00:50").do(bot_xng_count_recommend)
+
+
+
+
+if __name__ == '__main__':
+    schedule_tasks()  # 调用任务调度函数
+    while True:
+        schedule.run_pending()
+        time.sleep(1)  # 每秒钟检查一次