Merge branch 'canbula:master' into master

Author: Apexq

Week06/sync_vs_async.py

@@ -0,0 +1,86 @@
+import requests
+import logging
+import time
+import asyncio
+import aiohttp
+
+logging.basicConfig(
+    format="%(levelname)s @ %(asctime)s : %(message)s",
+    datefmt="%d.%m.%Y %H:%M:%S",
+    level=logging.INFO,
+    handlers=[logging.FileHandler("requests.log", mode="w"), logging.StreamHandler()],
+)
+HEADERS = {
+    "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 12_6) "
+    "AppleWebKit/537.36 (KHTML, like Gecko) "
+    "Chrome/106.0.0.0 Safari/537.36"
+}
+BASE_URL = "https://www.canbula.com/prime"
+MAX_RETRIES = 3
+TIMEOUT = 10
+
+
+def sync_request(session: requests.Session, n: int) -> dict:
+    """Synchronous request with error handling, logging, and retry logic"""
+    for attempt in range(MAX_RETRIES):
+        try:
+            response = session.get(f"{BASE_URL}/{n}", headers=HEADERS, timeout=TIMEOUT)
+            response.raise_for_status()
+            logging.info(
+                f"Request returned for {n} with status code {response.status_code}"
+            )
+            return response.json()
+        except requests.exceptions.RequestException as e:
+            logging.error(f"Request for {n} failed: {e} (attempt {attempt + 1})")
+            time.sleep(2**attempt)  # Exponential backoff
+    logging.error(f"Request for {n} failed after {MAX_RETRIES} attempts")
+    return {}
+
+
+async def async_request(session: aiohttp.ClientSession, n: int) -> dict:
+    """Asynchronous request with error handling, logging, and retry logic"""
+    for attempt in range(MAX_RETRIES):
+        try:
+            response = await session.get(
+                f"{BASE_URL}/{n}", headers=HEADERS, timeout=TIMEOUT
+            )
+            response.raise_for_status()
+            logging.info(f"Request returned for {n} with status code {response.status}")
+            return await response.json()
+        except (aiohttp.ClientError, asyncio.TimeoutError) as e:
+            logging.error(f"Request for {n} failed: {e} (attempt {attempt + 1})")
+            await asyncio.sleep(2**attempt)
+    logging.error(f"Request for {n} failed after {MAX_RETRIES} attempts")
+    return {}
+
+
+def sync_main(n: int) -> dict:
+    with requests.Session() as session:
+        start_time = time.time()
+        results = [sync_request(session, i) for i in range(1, n + 1)]
+        total_time = time.time() - start_time
+        logging.info(f"Time taken for {n} requests: {total_time:.2f} seconds with sync")
+        for result in results:
+            logging.info(result)
+
+
+async def async_main(n: int) -> dict:
+    async with aiohttp.ClientSession() as session:
+        start_time = time.time()
+        tasks = [async_request(session, i) for i in range(1, n + 1)]
+        results = await asyncio.gather(*tasks)
+        total_time = time.time() - start_time
+        logging.info(
+            f"Time taken for {n} requests: {total_time:.2f} seconds with async"
+        )
+        for result in results:
+            logging.info(result)
+
+
+if __name__ == "__main__":
+    n = 25
+    logging.info(f"Starting synchronous requests for {n} numbers")
+    sync_main(n)
+
+    logging.info(f"Starting asynchronous requests for {n} numbers")
+    asyncio.run(async_main(n))