自动下架视频---线程池修改为单线程 for 循环模式

getOffVideosDaily.py

@@ -8,6 +8,7 @@ from concurrent.futures.thread import ThreadPoolExecutor
 
 import requests
 import schedule
+from tqdm import tqdm
 
 from applications import PQMySQL, Functions
 from applications.decoratorApi import retryOnTimeout
@@ -84,6 +85,7 @@ class AutoGetOffVideos(object):
             sql=select_sql,
             params=video_id
         )
+        print("更新成功")
 
     @classmethod
     def changeVideoIdStatus(cls, video_id):
@@ -115,7 +117,7 @@ class AutoGetOffVideos(object):
             headers=headers,
             data=payload
         )
-        if response.status_code == 2:
+        if response.status_code == 200:
             result = response.json()
             if result.get("code", None) == 0:
                 cls.updateVideoIdStatus(video_id=video_id)
@@ -130,8 +132,10 @@ class AutoGetOffVideos(object):
         three_days_before = now_stamp - 3 * 24 * 60 * 60
         video_set = cls.getLongArticlesVideos(time_stamp=three_days_before)
         vid_list = [i[0] for i in video_set]
-        with ThreadPoolExecutor(max_workers=8) as Pool1:
-            Pool1.map(cls.changeVideoIdStatus, vid_list)
+        for video_id in tqdm(vid_list):
+            cls.changeVideoIdStatus(video_id=video_id)
+        # with ThreadPoolExecutor(max_workers=8) as Pool1:
+        #     Pool1.map(cls.changeVideoIdStatus, vid_list)
 
     @classmethod
     def task2(cls):
@@ -148,9 +152,9 @@ class AutoGetOffVideos(object):
         vid_tuple = cls.pqMysql.select(sql)
         if vid_tuple:
             vid_list = [i[0] for i in vid_tuple]
-            with ThreadPoolExecutor(max_workers=8) as Pool1:
-                Pool1.map(cls.changeVideoIdStatus, vid_list)
-
+            for vid in vid_list:
+                cls.changeVideoIdStatus(video_id=vid)
+            time.sleep(10)
             vid_tuple2 = cls.pqMysql.select(sql)
             if vid_tuple2:
                 vid_list2 = [i[0] for i in vid_tuple2]