소스 검색

update filter videos count: 2000->200

liqian 2 년 전
부모
커밋
c14a25478c
1개의 변경된 파일7개의 추가작업 그리고 6개의 파일을 삭제
  1. 7 6
      utils.py

+ 7 - 6
utils.py

@@ -200,7 +200,7 @@ def filter_video_status(video_ids):
 
             else:
                 data = []
-                for i in range(len(video_ids) // 2000 + 1):
+                for i in range(len(video_ids) // 200 + 1):
                     sql = "SELECT video_id " \
                           "FROM ({}) " \
                           "WHERE audit_status = 5 " \
@@ -209,7 +209,7 @@ def filter_video_status(video_ids):
                           "AND payment_status = 0 " \
                           "AND encryption_status != 5 " \
                           "AND transcoding_status = 3 " \
-                          "AND video_id IN {};".format(video_status_sql, tuple(video_ids[i*2000:(i+1)*2000]))
+                          "AND video_id IN {};".format(video_status_sql, tuple(video_ids[i*200:(i+1)*200]))
                     select_res = mysql_helper.get_data(sql=sql)
                     if select_res is not None:
                         data += select_res
@@ -268,7 +268,7 @@ def filter_video_status_with_applet_rec(video_ids, applet_rec_status):
 
             else:
                 data = []
-                for i in range(len(video_ids) // 2000 + 1):
+                for i in range(len(video_ids) // 200 + 1):
                     sql = "SELECT video_id " \
                           "FROM ({}) " \
                           "WHERE audit_status = 5 " \
@@ -277,7 +277,8 @@ def filter_video_status_with_applet_rec(video_ids, applet_rec_status):
                           "AND payment_status = 0 " \
                           "AND encryption_status != 5 " \
                           "AND transcoding_status = 3 " \
-                          "AND video_id IN {};".format(video_status_sql, applet_rec_status, tuple(video_ids[i*2000:(i+1)*2000]))
+                          "AND video_id IN {};".format(video_status_sql, applet_rec_status,
+                                                       tuple(video_ids[i*200:(i+1)*200]))
                     select_res = mysql_helper.get_data(sql=sql)
                     if select_res is not None:
                         data += select_res
@@ -336,7 +337,7 @@ def filter_video_status_app(video_ids):
 
             else:
                 data = []
-                for i in range(len(video_ids) // 2000 + 1):
+                for i in range(len(video_ids) // 200 + 1):
                     sql = "SELECT video_id " \
                           "FROM ({}) " \
                           "WHERE app_audit_status = 5 " \
@@ -345,7 +346,7 @@ def filter_video_status_app(video_ids):
                           "AND payment_status = 0 " \
                           "AND encryption_status != 5 " \
                           "AND transcoding_status = 3 " \
-                          "AND video_id IN {};".format(video_status_sql, tuple(video_ids[i*2000:(i+1)*2000]))
+                          "AND video_id IN {};".format(video_status_sql, tuple(video_ids[i*200:(i+1)*200]))
                     select_res = mysql_helper.get_data(sql=sql)
                     if select_res is not None:
                         data += select_res