Update app.py

app.py

@@ -37,6 +37,9 @@ SPECIFIC_CHANNEL_ID = int(os.getenv("DISCORD_CHANNEL_ID"))
 # 웹훅 URL 설정
 WEBHOOK_URL = "https://connect.pabbly.com/workflow/sendwebhookdata/IjU3NjUwNTY1MDYzMjA0MzA1MjY4NTUzMDUxMzUi_pc"
 
+# 전송 실패 시 재시도 횟수
+MAX_RETRIES = 3
+
 class MyClient(discord.Client):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
@@ -169,12 +172,17 @@ async def create_thread_and_send_replies(message, video_id, comments, replies):
         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} 번째")
+        for attempt in range(MAX_RETRIES):
+            async with aiohttp.ClientSession() as session:
+                try:
+                    async with session.post(WEBHOOK_URL, json=chunk_data) as resp:
+                        if resp.status == 200:
+                            logging.info(f"웹훅으로 데이터 전송 성공: {i // chunk_size + 1} 번째 시도")
+                            break  # 성공 시 루프 탈출
+                        else:
+                            logging.error(f"웹훅으로 데이터 전송 실패: {resp.status}, {i // chunk_size + 1} 번째 시도")
+                except aiohttp.ClientError as e:
+                    logging.error(f"웹훅 전송 중 오류 발생: {e}, {i // chunk_size + 1} 번째 시도")
 
 if __name__ == "__main__":
     discord_client = MyClient(intents=intents)