Update app.py

app.py

@@ -5,17 +5,24 @@ import asyncio
 import datetime
 import sys
 import traceback
-from aiohttp import web
+from aiohttp import web, ClientTimeout, TCPConnector
 from urllib.parse import parse_qs
 from cachetools import TTLCache
-from functools import partial
 
 # 创建一个TTL缓存，最多存储1000个项目，每个项目的有效期为1小时
-cache = TTLCache(maxsize=1000, ttl=3600)
-
-async def fetch_url(url, session):
-    async with session.get(url) as response:
-        return await response.text()
+cache = TTLCache(maxsize=1000, ttl=1800)
+
+async def fetch_url(url, session, max_retries=3):
+    for attempt in range(max_retries):
+        try:
+            async with session.get(url, timeout=ClientTimeout(total=60)) as response:
+                response.raise_for_status()
+                return await response.text()
+        except aiohttp.ClientError as e:
+            print(f"Attempt {attempt + 1} failed: {str(e)}", flush=True)
+            if attempt == max_retries - 1:
+                raise
+            await asyncio.sleep(1)  # 在重试之前等待1秒
 
 async def extract_and_transform_proxies(input_text):
     try:
@@ -120,7 +127,7 @@ async def handle_request(request):
             
             try:
                 print(f"Fetching URL: {url}", flush=True)
-                async with aiohttp.ClientSession() as session:
+                async with aiohttp.ClientSession(connector=TCPConnector(ssl=False)) as session:
                     input_text = await fetch_url(url, session)
                 print(f"URL content length: {len(input_text)}", flush=True)
                 result = await extract_and_transform_proxies(input_text)