优乐搞笑小视频——随机入账户

youlegaoxiaoxiaoshipin/youlegaoxiaoxiaoshipin_main/run_ylgxxsp_recommend.py

@@ -80,7 +80,6 @@ def main(my_platform, mode, topic_name, group_id, env):
                 our_uid_list = []
                 for user in user_list:
                     our_uid_list.append(user["uid"])
-                our_uid = random.choice(our_uid_list)
                 AliyunLogger.logging(
                     code="1003",
                     platform=my_platform,
@@ -93,7 +92,7 @@ def main(my_platform, mode, topic_name, group_id, env):
                     mode=mode,
                     env=env,
                     rule_dict=rule_dict,
-                    our_uid=our_uid,
+                    our_uid=our_uid_list,
                 )
                 for i in range(50):
                     try:

youlegaoxiaoxiaoshipin/youlegaoxiaoxiaoshipin_recommend/youlegaoxiaoxiaoshipin_scheduling.py

@@ -18,12 +18,12 @@ from common.public import clean_title
 
 
 class YLGXXSPScheduling:
-    def __init__(self, platform, mode, rule_dict, env, our_uid):
+    def __init__(self, platform, mode, rule_dict, env, our_uid_list):
         self.platform = platform
         self.mode = mode
         self.rule_dict = rule_dict
         self.env = env
-        self.our_uid = our_uid
+        self.our_uid_list = our_uid_list
         self.mq = MQ(topic_name="topic_crawler_etl_" + self.env)
         self.download_count = 0
 
@@ -176,7 +176,7 @@ class YLGXXSPScheduling:
             video_dict["width"] = video_dict["video_width"]
             video_dict["height"] = video_dict["video_height"]
             video_dict["crawler_rule"] = json.dumps(self.rule_dict)
-            video_dict["user_id"] = self.our_uid
+            video_dict["user_id"] = random.choice(self.our_uid_list)
             video_dict["publish_time"] = video_dict["publish_time_str"]
             video_dict["video_url"] = video_obj["data"]["url"]
             video_dict["avatar_url"] = "http:" + video_obj["data"]["avatar"]