快手调试

kuaishou_main.py

@@ -14,7 +14,7 @@ def job_kuaishou_data():
     kuaishouAuthor.get_kuaishou_videoList()
 
 # 每10个小时执行一次
-schedule.every(4).hours.do(job_kuaishou_data)
+schedule.every(2).hours.do(job_kuaishou_data)
 
 
 

video_capture/kuaishou/kuaishou_author/kuaishou_author.py

@@ -39,7 +39,7 @@ class kuaishouAuthor():
     """
     @classmethod
     def get_kuaishou_videoUserId(cls):
-        select_user_sql = f"""select user_id from video_user_id where channel LIKE '%快手%' ORDER BY id DESC;"""
+        select_user_sql = f"""select user_id, channel from video_user_id where channel LIKE '%快手%' ORDER BY id DESC;"""
         user_list = MysqlHelper.get_values(select_user_sql, "prod")
         return user_list
 
@@ -68,6 +68,8 @@ class kuaishouAuthor():
                 return
             for i in user_list:
                 account_id = i[0].replace('(', '').replace(')', '').replace(',', '')
+                channel = i[1].replace('(', '').replace(')', '').replace(',', '')
+
                 Common.logger("kuaishou").info(f"用户主页ID：{account_id}")
                 pcursor = ""
                 while True:
@@ -134,7 +136,11 @@ class kuaishouAuthor():
                                         f"重复视频不在抓取该用户，用户主页id：{account_id}")
                                     break
                                 continue
-                            oss_object_key = Oss.video_sync_upload_oss(video_url, video_id, account_id, "kuaishou")
+                            if channel == "快手-春节":
+                                channel_name = 'kschunjie'
+                            else:
+                                channel_name = 'kuaishou'
+                            oss_object_key = Oss.video_sync_upload_oss(video_url, video_id, account_id, channel_name)
                             status = oss_object_key.get("status")
                             # 发送 oss
                             oss_object_key = oss_object_key.get("oss_object_key")