调试

job_ks_feed.py

@@ -9,7 +9,7 @@ def video_task_start():
         try:
             count = sqlCollect.get_feed_count("快手推荐流")
             count = int(count[0][0])
-            if count >= 55:
+            if count >= 130:
                 print(f"到了限制数{count}")
                 time.sleep(3600)
                 continue

job_pl_dy.py

@@ -1,6 +1,7 @@
 
 import time
 from common import Material
+from common.sql_help import sqlCollect
 
 from video_rewriting.video_processor import VideoProcessor
 def video_task_start():
@@ -8,6 +9,12 @@ def video_task_start():
     data = Material.feishu_list()[10]
     while True:
         try:
+            count = sqlCollect.get_feed_count("抖音品类账号")
+            count = int(count[0][0])
+            if count >= 470:
+                print(f"到了限制数{count}")
+                time.sleep(3600)
+                continue
             print("开始执行任务")
             mark = VideoProcessor.main(data)
             print(f"返回用户名: {mark}")

job_pl_ks.py

@@ -1,6 +1,7 @@
 
 import time
 from common import Material
+from common.sql_help import sqlCollect
 
 from video_rewriting.video_processor import VideoProcessor
 def video_task_start():
@@ -8,6 +9,12 @@ def video_task_start():
     data = Material.feishu_list()[13]
     while True:
         try:
+            count = sqlCollect.get_feed_count("快手品类账号")
+            count = int(count[0][0])
+            if count >= 560:
+                print(f"到了限制数{count}")
+                time.sleep(3600)
+                continue
             print("开始执行任务")
             mark = VideoProcessor.main(data)
             print(f"返回用户名: {mark}")

job_sph_feed.py

@@ -11,7 +11,7 @@ def video_task_start():
         try:
             count = sqlCollect.get_feed_count("视频号推荐流")
             count = int(count[0][0])
-            if count >= 150:
+            if count >= 110:
                 print(f"到了限制数{count}")
                 time.sleep(3600)
                 continue