update

crawler_sys/scheduler/xiaohongshu_to_rpc.py

@@ -143,18 +143,28 @@ for pid in pid_list:
     video_dic["content"] = desc_fix
     video_dic["user_id"] = random.choice(user_id_list_copy)
     rpc_res = post_single_data(copy.deepcopy(video_dic), "cims/answer/batch_create")
-    if res_json["NoteView"].get("data"):
-        print(res_json["NoteView"].get("data"))
     try:
-        for comment in res_json["NoteView"]["commentInfo"]["comments"]:
-            video_dic["content"] = comment['content']
-            comment_id_list_copy = copy.deepcopy(majiayonghu_list)
-            comment_id = random.choice(comment_id_list_copy)
-            video_dic["user_id"] = comment_id
-            comment_id_list_copy.remove(comment_id)
-            video_dic["create_time"] = (create_time + datetime.timedelta(hours=random.randint(0,24),minutes=random.randint(0,60))).timestamp()
-            rpc_res = post_single_data(copy.deepcopy(video_dic), "cims/reply/batch_create")
+        if res_json["NoteView"].get("data"):
+            print(res_json["NoteView"].get("data"))
+            for comment in res_json["NoteView"]["data"]["comments"]:
+                video_dic["content"] = comment['content']
+                comment_id_list_copy = copy.deepcopy(majiayonghu_list)
+                comment_id = random.choice(comment_id_list_copy)
+                video_dic["user_id"] = comment_id
+                comment_id_list_copy.remove(comment_id)
+                video_dic["create_time"] = (create_time + datetime.timedelta(hours=random.randint(0, 24),
+                                minutes=random.randint(0, 60))).timestamp()
+                rpc_res = post_single_data(copy.deepcopy(video_dic), "cims/reply/batch_create")
+        elif res_json["NoteView"].get("commentInfo"):
+            for comment in res_json["NoteView"]["commentInfo"]["comments"]:
+                video_dic["content"] = comment['content']
+                comment_id_list_copy = copy.deepcopy(majiayonghu_list)
+                comment_id = random.choice(comment_id_list_copy)
+                video_dic["user_id"] = comment_id
+                comment_id_list_copy.remove(comment_id)
+                video_dic["create_time"] = (create_time + datetime.timedelta(hours=random.randint(0,24),minutes=random.randint(0,60))).timestamp()
+                rpc_res = post_single_data(copy.deepcopy(video_dic), "cims/reply/batch_create")
     except:
         print("comment error")
-        # print(res)
+        print(res)
     # break
\ No newline at end of file