Изучаем сетевые библиотеки Python: от простых запросов до асинхронных решений

Расширенные примеры работы с сетевыми библиотеками

1. Сессии, повторные попытки и тайм-ауты в requests

from requests import Session, RequestException
from requests.adapters import HTTPAdapter
from urllib3.util.retry import Retry

session = Session()
retries = Retry(total=3, backoff_factor=1, status_forcelist=[500, 502, 503, 504])
adapter = HTTPAdapter(max_retries=retries)
session.mount('https://', adapter)
session.mount('http://', adapter)

try:
    resp = session.get('https://httpbin.org/status/500', timeout=10)
    resp.raise_for_status()
except RequestException as e:
    print(f"Ошибка: {e}")
finally:
    session.close()

# При выполнении будет выброшено исключение после всех попыток (если ошибка не исправилась). Вывод в консоль: 
# Ошибка: 500 Server Error: INTERNAL SERVER ERROR for url: https://httpbin.org/status/500

Пояснение: создаётся сессия с политикой повторных попыток (3 попытки, задержка по экспоненте). Адаптер монтируется к префиксам протоколов. Тайм-аут гарантирует, что запрос не зависнет.

2. Асинхронное скачивание нескольких файлов с aiohttp

import aiohttp
import asyncio
from pathlib import Path

async def download_file(session, url, filename):
    async with session.get(url) as resp:
        if resp.status == 200:
            content = await resp.read()
            Path(filename).write_bytes(content)
            return f"Скачан {filename}"
        return f"Ошибка {resp.status} для {filename}"

async def main():
    urls = [
        ("https://httpbin.org/image/png", "image1.png"),
        ("https://httpbin.org/image/jpeg", "image2.jpg")
    ]
    async with aiohttp.ClientSession() as session:
        tasks = [download_file(session, url, name) for url, name in urls]
        results = await asyncio.gather(*tasks)
        for res in results:
            print(res)

asyncio.run(main())

# Вывод:
# Скачан image1.png
# Скачан image2.jpg

Пояснение: asyncio.gather запускает несколько корутин параллельно. Каждая корутина скачивает файл и сохраняет его в локальную папку.

3. Работа с WebSocket через websockets и asyncio

import asyncio
import websockets

async def echo():
    uri = "wss://echo.websocket.org"
    async with websockets.connect(uri) as websocket:
        await websocket.send("Hello, World!")
        response = await websocket.recv()
        print(f"Получено: {response}")

asyncio.run(echo())

# Вывод:
# Получено: Hello, World!

Пояснение: библиотека websockets упрощает работу с WebSocket. После установки соединения отправляется сообщение и ожидается ответ (эхо-сервер возвращает то же самое).

4. Использование низкоуровневых сокетов для простого UDP-чата

import socket

# Сервер
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(('127.0.0.1', 8888))
print("Сервер слушает порт 8888...")
data, addr = server.recvfrom(1024)
print(f"Получено от {addr}: {data.decode()}")
server.sendto('Привет от сервера'.encode(), addr)
server.close()

# (при отправке клиентом сообщения "Привет")
# Сервер слушает порт 8888...
# Получено от ('127.0.0.1', 54321): Привет

Пояснение: UDP-сокет не требует установки соединения. Сервер принимает одно сообщение, отвечает и закрывается. Для полноценного чата потребуется цикл.

5. Потоковая передача данных с httpx (загрузка больших файлов)

import httpx

with httpx.stream('GET', 'https://speed.hetzner.de/100MB.bin') as response:
    with open('large_file.bin', 'wb') as f:
        for chunk in response.iter_bytes(chunk_size=8192):
            f.write(chunk)
print("Файл скачан")

Пояснение: httpx.stream позволяет получать ответ чанками, не загружая его целиком в память. Это необходимо для больших файлов или потокового аудио/видео.