祝万物复苏，增加了等待时间

resend_msg.py

@@ -45,16 +45,6 @@ if __name__ == "__main__":
         video_dict['strategy'] = strategy
         video_dict['platform'] = platform
         video_dict['crawler_rule'] = json.dumps({})
-        print(json.dumps(video_dict, ensure_ascii=False, indent=4))
+        # print(json.dumps(video_dict, ensure_ascii=False, indent=4))
         mq = MQ(topic_name="topic_crawler_etl_" + "prod")
         mq.send_msg(video_dict)
-
-    # video_dict = {'video_title': '吴尊友因病去世！吴老师，您真的不容易，千言万语，汇成一句话您走好❗️', 'video_id': '5262651713', 'duration': 49, 'play_cnt': 71, 'like_cnt': 0, 'comment_cnt': 0, 'share_cnt': 1, 'user_name': '夏日❤️莲莲', 'publish_time_stamp': 1698398572, 'publish_time_str': '2023-10-27 17:22:52', 'video_width': 537, 'video_height': 954, 'avatar_url': 'https://cdn-xphoto2.xiaoniangao.cn/4987933869?Expires=1704038400&OSSAccessKeyId=LTAI4G2W1FsgwzAWYpPoB3v6&Signature=wopOmtlcp9tGyWHYW9uy7DIXO%2Bg%3D&x-oss-process=image%2Fresize%2Cw_200%2Ch_200%2Climit_0%2Finterlace%2C1%2Fquality%2Cq_50%2Fcrop%2Cw_200%2Ch_200%2Cg_center%2Fformat%2Cjpg%2Fauto-orient%2C0', 'profile_id': 55888345, 'profile_mid': 185546, 'cover_url': 'https://cdn-xphoto2.xiaoniangao.cn/5262652619?Expires=1704038400&OSSAccessKeyId=LTAI4G2W1FsgwzAWYpPoB3v6&Signature=qIIRzRICgyv40n3uMFeMwHCY8JY%3D&x-oss-process=image%2Fresize%2Cw_690%2Ch_385%2Climit_0%2Finterlace%2C1%2Fformat%2Cjpg%2Fauto-orient%2C0', 'video_url': 'https://cdn-xalbum2.xiaoniangao.cn/5262651713?Expires=1704038400&OSSAccessKeyId=LTAI5tB7cRkYiqHcTdkVprwb&Signature=hFGFAB49mmgUYwYcF4679bE%2BgLg%3D', 'session': 'xiaoniangao-author-1698402882'}
-    # video_dict['strategy'] = "author"
-    # video_dict['platform'] = "xiaoniangao"
-    # video_dict['user_id'] = 58528269
-    # video_dict['out_video_id'] = video_dict['video_id']
-    # print(json.dumps(video_dict, ensure_ascii=False, indent=4))
-    # mq = MQ(topic_name="topic_crawler_etl_" + "prod")
-    # mq.send_msg(video_dict)
-    #

zhuwanwufusu/zhuwanwufusu_recommend/zwwfs_recommend.py

@@ -161,6 +161,7 @@ class ZhuWanWuFuSuRecommend(object):
                         )
 
     def process_video_obj(self, video_obj):
+        time.sleep(random.randint(3, 8))
         trace_id = self.platform + str(uuid.uuid1())
         if video_obj.get("playnum"):
             play_cnt = int(video_obj['playnum'].replace("万+", "0000")) if "万+" in video_obj['playnum'] else int(