Update app.py

app.py

@@ -163,13 +163,18 @@ async def create_thread_and_send_replies(message, video_id, comments, replies):
         # 웹훅 데이터 준비 (comment id 포함)
         webhook_data["replies"].append({"comment": comment, "reply": reply, "comment_id": comment_id})
 
-    # 웹훅으로 데이터 전송
-    async with aiohttp.ClientSession() as session:
-        async with session.post(WEBHOOK_URL, json=webhook_data) as resp:
-            if resp.status == 200:
-                logging.info("웹훅으로 데이터 전송 성공")
-            else:
-                logging.error(f"웹훅으로 데이터 전송 실패: {resp.status}")
+    # 데이터를 여러 번 나누어 전송
+    chunk_size = 5  # 전송할 데이터의 개수
+    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}
+
+        async with aiohttp.ClientSession() as session:
+            async with session.post(WEBHOOK_URL, json=chunk_data) as resp:
+                if resp.status == 200:
+                    logging.info(f"웹훅으로 데이터 전송 성공: {i // chunk_size + 1} 번째")
+                else:
+                    logging.error(f"웹훅으로 데이터 전송 실패: {resp.status}, {i // chunk_size + 1} 번째")
 
 if __name__ == "__main__":
     discord_client = MyClient(intents=intents)