Update app.py

app.py

@@ -192,26 +192,44 @@ async def send_webhook_data(session, chunk_data, chunk_number):
 
     return False  # 재시도 횟수 초과 시 실패로 간주
 
+
 async def create_thread_and_send_replies(message, video_id, comments, replies, session):
     thread = await message.channel.create_thread(name=f"{message.author.name}의 댓글 답글", message=message)
-    webhook_data = {"video_id": video_id, "replies": []}
-
+    
     for (comment, comment_id), reply in zip(comments, replies):
         embed = discord.Embed(description=f"**댓글**: {comment}\n**답글**: {reply}")
         await thread.send(embed=embed)
 
-        # 웹훅 데이터 준비 (comment id 포함)
-        webhook_data["replies"].append({"comment": comment, "reply": reply, "comment_id": comment_id})
+        # 웹훅 데이터를 개별적으로 전송
+        webhook_data = {
+            "video_id": video_id,
+            "replies": [{"comment": comment, "reply": reply, "comment_id": comment_id}]
+        }
+        
+        # 웹훅 데이터 전송
+        success = await send_webhook_data(session, webhook_data, 1)  # 청크 번호는 여기서는 사용하지 않고, 1을 고정값으로 사용
+        if not success:
+            logging.error("웹훅을 통한 데이터 전송 실패")
 
-    # 데이터를 여러 번 나누어 전송
-    chunk_size = 1  # 전송할 데이터의 개수를 1로 설정하여 각 데이터를 별도로 전송
-    for i in range(0, len(webhook_data["replies"]), chunk_size):
-        chunk = webhook_data["replies"][i:i+chunk_size]
-        chunk_data = {"video_id": video_id, "replies": chunk}
+        await asyncio.sleep(1)  # 다음 답글 전송 전에 잠시 대기 (필요한 경우 대기 시간 조절)
 
-        success = await send_webhook_data(session, chunk_data, i // chunk_size + 1)
-        if not success:
-            logging.error(f"데이터 전송 실패: {i // chunk_size + 1} 번째 청크")
+
+#async def create_thread_and_send_replies(message, video_id, comments, replies, session):
+#    thread = await message.channel.create_thread(name=f"{message.author.name}의 댓글 답글", message=message)
+#    webhook_data = {"video_id": video_id, "replies": []}
+#    for (comment, comment_id), reply in zip(comments, replies):
+#        embed = discord.Embed(description=f"**댓글**: {comment}\n**답글**: {reply}")
+#        await thread.send(embed=embed)
+        # 웹훅 데이터 준비 (comment id 포함)
+#        webhook_data["replies"].append({"comment": comment, "reply": reply, "comment_id": comment_id})
+    # 데이터를 여러 번 나누어 전송
+#    chunk_size = 1  # 전송할 데이터의 개수를 1로 설정하여 각 데이터를 별도로 전송
+#    for i in range(0, len(webhook_data["replies"]), chunk_size):
+#        chunk = webhook_data["replies"][i:i+chunk_size]
+#        chunk_data = {"video_id": video_id, "replies": chunk}
+#        success = await send_webhook_data(session, chunk_data, i // chunk_size + 1)
+#        if not success:
+#            logging.error(f"데이터 전송 실패: {i // chunk_size + 1} 번째 청크")
 
 if __name__ == "__main__":
     discord_client = MyClient(intents=intents)