| """ |
| Python HTTP library with thread-safe connection pooling, file post support, user friendly, and more |
| """ |
|
|
| from __future__ import annotations |
|
|
| |
| import logging |
| import typing |
| import warnings |
| from logging import NullHandler |
|
|
| from . import exceptions |
| from ._base_connection import _TYPE_BODY |
| from ._collections import HTTPHeaderDict |
| from ._version import __version__ |
| from .connectionpool import HTTPConnectionPool, HTTPSConnectionPool, connection_from_url |
| from .filepost import _TYPE_FIELDS, encode_multipart_formdata |
| from .poolmanager import PoolManager, ProxyManager, proxy_from_url |
| from .response import BaseHTTPResponse, HTTPResponse |
| from .util.request import make_headers |
| from .util.retry import Retry |
| from .util.timeout import Timeout |
|
|
| |
| |
| |
| try: |
| import ssl |
| except ImportError: |
| pass |
| else: |
| if not ssl.OPENSSL_VERSION.startswith("OpenSSL "): |
| warnings.warn( |
| "urllib3 v2 only supports OpenSSL 1.1.1+, currently " |
| f"the 'ssl' module is compiled with {ssl.OPENSSL_VERSION!r}. " |
| "See: https://github.com/urllib3/urllib3/issues/3020", |
| exceptions.NotOpenSSLWarning, |
| ) |
| elif ssl.OPENSSL_VERSION_INFO < (1, 1, 1): |
| raise ImportError( |
| "urllib3 v2 only supports OpenSSL 1.1.1+, currently " |
| f"the 'ssl' module is compiled with {ssl.OPENSSL_VERSION!r}. " |
| "See: https://github.com/urllib3/urllib3/issues/2168" |
| ) |
|
|
| __author__ = "Andrey Petrov (andrey.petrov@shazow.net)" |
| __license__ = "MIT" |
| __version__ = __version__ |
|
|
| __all__ = ( |
| "HTTPConnectionPool", |
| "HTTPHeaderDict", |
| "HTTPSConnectionPool", |
| "PoolManager", |
| "ProxyManager", |
| "HTTPResponse", |
| "Retry", |
| "Timeout", |
| "add_stderr_logger", |
| "connection_from_url", |
| "disable_warnings", |
| "encode_multipart_formdata", |
| "make_headers", |
| "proxy_from_url", |
| "request", |
| "BaseHTTPResponse", |
| ) |
|
|
| logging.getLogger(__name__).addHandler(NullHandler()) |
|
|
|
|
| def add_stderr_logger( |
| level: int = logging.DEBUG, |
| ) -> logging.StreamHandler[typing.TextIO]: |
| """ |
| Helper for quickly adding a StreamHandler to the logger. Useful for |
| debugging. |
| |
| Returns the handler after adding it. |
| """ |
| |
| |
| logger = logging.getLogger(__name__) |
| handler = logging.StreamHandler() |
| handler.setFormatter(logging.Formatter("%(asctime)s %(levelname)s %(message)s")) |
| logger.addHandler(handler) |
| logger.setLevel(level) |
| logger.debug("Added a stderr logging handler to logger: %s", __name__) |
| return handler |
|
|
|
|
| |
| del NullHandler |
|
|
|
|
| |
| |
| |
| |
| warnings.simplefilter("always", exceptions.SecurityWarning, append=True) |
| |
| warnings.simplefilter("default", exceptions.InsecurePlatformWarning, append=True) |
|
|
|
|
| def disable_warnings(category: type[Warning] = exceptions.HTTPWarning) -> None: |
| """ |
| Helper for quickly disabling all urllib3 warnings. |
| """ |
| warnings.simplefilter("ignore", category) |
|
|
|
|
| _DEFAULT_POOL = PoolManager() |
|
|
|
|
| def request( |
| method: str, |
| url: str, |
| *, |
| body: _TYPE_BODY | None = None, |
| fields: _TYPE_FIELDS | None = None, |
| headers: typing.Mapping[str, str] | None = None, |
| preload_content: bool | None = True, |
| decode_content: bool | None = True, |
| redirect: bool | None = True, |
| retries: Retry | bool | int | None = None, |
| timeout: Timeout | float | int | None = 3, |
| json: typing.Any | None = None, |
| ) -> BaseHTTPResponse: |
| """ |
| A convenience, top-level request method. It uses a module-global ``PoolManager`` instance. |
| Therefore, its side effects could be shared across dependencies relying on it. |
| To avoid side effects create a new ``PoolManager`` instance and use it instead. |
| The method does not accept low-level ``**urlopen_kw`` keyword arguments. |
| """ |
|
|
| return _DEFAULT_POOL.request( |
| method, |
| url, |
| body=body, |
| fields=fields, |
| headers=headers, |
| preload_content=preload_content, |
| decode_content=decode_content, |
| redirect=redirect, |
| retries=retries, |
| timeout=timeout, |
| json=json, |
| ) |
|
|