U
|
¡ý°daL ã @ s¦ d Z ddlZddlZddlmZmZ ddlmZ ddlm Z
|
ddlm Z m Z m Z mZ ddlmZ ddlmZmZ dd lmZ dd
|
lmZmZ dd lmZ dd lmZ dd l m Z ddl m Z ddl m!Z!m"Z" ddl#m$Z$ ddl%m&Z&m'Z'm Z m(Z(m)Z)m*Z*mZm+Z+m,Z,mZ ddl-m.Z. ddl/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 zddl9m:Z: W n e;k
|
rr dd Z:Y nX dZ<dZ=dZ>dZ?G dd d Z@G d d d e@ZAdS ) z
|
requests.adapters
|
~~~~~~~~~~~~~~~~~
|
|
This module contains the transport adapters that Requests uses to define
|
and maintain connections.
|
é N)ÚClosedPoolErrorÚConnectTimeoutError)Ú HTTPError)Ú InvalidHeader)ÚLocationValueErrorÚ MaxRetryErrorÚNewConnectionErrorÚ ProtocolError)Ú
|
ProxyError)ÚReadTimeoutErrorÚ ResponseError)ÚSSLError)Ú PoolManagerÚproxy_from_url)ÚTimeout)Ú parse_url)ÚRetryé )Ú_basic_auth_str)Ú
|
basestringÚurlparse)Úextract_cookies_to_jar)
|
ÚConnectionErrorÚConnectTimeoutr ÚInvalidProxyURLÚ InvalidSchemaÚ
|
InvalidURLr
|
Ú ReadTimeoutÚ
|
RetryErrorr )ÚResponse)ÚCaseInsensitiveDict)ÚDEFAULT_CA_BUNDLE_PATHÚextract_zipped_pathsÚget_auth_from_urlÚget_encoding_from_headersÚprepend_scheme_if_neededÚ select_proxyÚ urldefragauth)ÚSOCKSProxyManagerc O s t dd S )Nz'Missing dependencies for SOCKS support.)r )ÚargsÚkwargs© r+ úHd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\requests/adapters.pyr( < s r( Fé
|
c s2 e Zd ZdZ fddZd ddZd d
|
Z ZS ) Ú BaseAdapterzThe Base Transport Adapterc s t ¡ d S ©N)ÚsuperÚ__init__©Úself©Ú __class__r+ r, r1 I s zBaseAdapter.__init__FNTc C s t dS )aC Sends PreparedRequest object. Returns Response object.
|
|
:param request: The :class:`PreparedRequest <PreparedRequest>` being sent.
|
:param stream: (optional) Whether to stream the request content.
|
:param timeout: (optional) How long to wait for the server to send
|
data before giving up, as a float, or a :ref:`(connect timeout,
|
read timeout) <timeouts>` tuple.
|
:type timeout: float or tuple
|
:param verify: (optional) Either a boolean, in which case it controls whether we verify
|
the server's TLS certificate, or a string, in which case it must be a path
|
to a CA bundle to use
|
:param cert: (optional) Any user-provided SSL certificate to be trusted.
|
:param proxies: (optional) The proxies dictionary to apply to the request.
|
N©ÚNotImplementedError)r3 ÚrequestÚstreamÚtimeoutÚverifyÚcertÚproxiesr+ r+ r, ÚsendL s zBaseAdapter.sendc C s t dS )z!Cleans up adapter specific items.Nr6 r2 r+ r+ r, Úclose_ s zBaseAdapter.close)FNTNN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r1 r> r? Ú __classcell__r+ r+ r4 r, r. F s ÿ
|
r. c s e Zd ZdZdddddgZeeeef fdd Zd d
|
Z d d Z
|
efd dZ dd Z dd Z dd Zd$ddZdd Zdd Zd d Zd d Zd%d"d#Z ZS )&Ú HTTPAdaptera The built-in HTTP Adapter for urllib3.
|
|
Provides a general-case interface for Requests sessions to contact HTTP and
|
HTTPS urls by implementing the Transport Adapter interface. This class will
|
usually be created by the :class:`Session <Session>` class under the
|
covers.
|
|
:param pool_connections: The number of urllib3 connection pools to cache.
|
:param pool_maxsize: The maximum number of connections to save in the pool.
|
:param max_retries: The maximum number of retries each connection
|
should attempt. Note, this applies only to failed DNS lookups, socket
|
connections and connection timeouts, never to requests where data has
|
made it to the server. By default, Requests does not retry failed
|
connections. If you need granular control over the conditions under
|
which we retry a request, import urllib3's ``Retry`` class and pass
|
that instead.
|
:param pool_block: Whether the connection pool should block for connections.
|
|
Usage::
|
|
>>> import requests
|
>>> s = requests.Session()
|
>>> a = requests.adapters.HTTPAdapter(max_retries=3)
|
>>> s.mount('http://', a)
|
Ú max_retriesÚconfigÚ_pool_connectionsÚ _pool_maxsizeÚ _pool_blockc s` |t krtddd| _n t |¡| _i | _i | _t ¡ || _|| _ || _
|
| j |||d d S )Nr F)Úread©Úblock) ÚDEFAULT_RETRIESr rF Úfrom_intrG Ú proxy_managerr0 r1 rH rI rJ Úinit_poolmanager)r3 Úpool_connectionsÚ pool_maxsizerF Ú
|
pool_blockr4 r+ r, r1 s
|
zHTTPAdapter.__init__c s fdd j D S )Nc s i | ]}|t |d qS r/ )Úgetattr)Ú.0Úattrr2 r+ r, Ú
|
<dictcomp> s z,HTTPAdapter.__getstate__.<locals>.<dictcomp>)Ú __attrs__r2 r+ r2 r, Ú __getstate__ s zHTTPAdapter.__getstate__c C sD i | _ i | _| ¡ D ]\}}t| || q| j| j| j| jd d S )NrL )rP rG ÚitemsÚsetattrrQ rH rI rJ )r3 ÚstaterW Úvaluer+ r+ r, Ú __setstate__ s ÿzHTTPAdapter.__setstate__c K s. || _ || _|| _tf |||d|| _dS )a Initializes a urllib3 PoolManager.
|
|
This method should not be called from user code, and is only
|
exposed for use when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param connections: The number of urllib3 connection pools to cache.
|
:param maxsize: The maximum number of connections to save in the pool.
|
:param block: Block when no free connections are available.
|
:param pool_kwargs: Extra keyword arguments used to initialize the Pool Manager.
|
)Ú num_poolsÚmaxsizerM N)rH rI rJ r Ú poolmanager)r3 Ú connectionsra rM Ú pool_kwargsr+ r+ r, rQ s ýüz HTTPAdapter.init_poolmanagerc K s || j kr| j | }n|| ¡ d¡r^t|\}}t|f||| j| j| jd| }| j |< n4| |¡}t |f|| j| j| jd| }| j |< |S )aÏ Return urllib3 ProxyManager for the given proxy.
|
|
This method should not be called from user code, and is only
|
exposed for use when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param proxy: The proxy to return a urllib3 ProxyManager for.
|
:param proxy_kwargs: Extra keyword arguments used to configure the Proxy Manager.
|
:returns: ProxyManager
|
:rtype: urllib3.ProxyManager
|
Úsocks)ÚusernameÚpasswordr` ra rM )Ú proxy_headersr` ra rM )
|
rP ÚlowerÚ
|
startswithr# r( rH rI rJ rh r )r3 ÚproxyÚ proxy_kwargsÚmanagerrf rg rh r+ r+ r, Úproxy_manager_forÇ s6
|
ÿúù
|
|
ÿûú z HTTPAdapter.proxy_manager_forc C sü | ¡ d¡rn|rnd}|dk r"|}|s.tt}|r>tj |¡sLtd| d|_tj |¡sf||_
|
q||_ nd|_d|_
|
d|_ |røt |t s¤|d |_|d |_n ||_d|_|jrÔtj |j¡sÔtd |j |jrøtj |j¡søtd
|
|j dS ) aA Verify a SSL certificate. This method should not be called from user
|
code, and is only exposed for use when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param conn: The urllib3 connection object associated with the cert.
|
:param url: The requested URL.
|
:param verify: Either a boolean, in which case it controls whether we verify
|
the server's TLS certificate, or a string, in which case it must be a path
|
to a CA bundle to use
|
:param cert: The SSL certificate to verify.
|
ÚhttpsNTzCCould not find a suitable TLS CA certificate bundle, invalid path: Ú CERT_REQUIREDÚ CERT_NONEr r z7Could not find the TLS certificate file, invalid path: z/Could not find the TLS key file, invalid path: )ri rj r" r! ÚosÚpathÚexistsÚOSErrorÚ cert_reqsÚisdirÚca_certsÚ ca_cert_dirÚ
|
isinstancer Ú cert_fileÚkey_file)r3 ÚconnÚurlr; r< Úcert_locr+ r+ r, Ú cert_verifyí s> ÿ
|
|
|
ÿ
|
ÿzHTTPAdapter.cert_verifyc C s t }t|dd|_tt|di |_t|j|_||_|jj|_t |j
|
t r^|j
|
d¡|_
|
n|j
|
|_
|
t |j|| ||_| |_|S )a¶ Builds a :class:`Response <requests.Response>` object from a urllib3
|
response. This should not be called from user code, and is only exposed
|
for use when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`
|
|
:param req: The :class:`PreparedRequest <PreparedRequest>` used to generate the response.
|
:param resp: The urllib3 response object.
|
:rtype: requests.Response
|
ÚstatusNÚheaderszutf-8)r rU Ú status_coder r r$ ÚencodingÚrawÚreasonrz r~ ÚbytesÚdecoder Úcookiesr8 Ú
|
connection)r3 ÚreqÚrespÚresponser+ r+ r, Úbuild_response& s
|
|
zHTTPAdapter.build_responseNc C sd t ||}|rDt|d}t|}|js.td| |¡}| |¡}n t|}| ¡ }| j |¡}|S )a Returns a urllib3 connection for the given URL. This should not be
|
called from user code, and is only exposed for use when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param url: The URL to connect to.
|
:param proxies: (optional) A Requests-style dictionary of proxies used on this request.
|
:rtype: urllib3.ConnectionPool
|
ÚhttpzFPlease check proxy URL. It is malformed and could be missing the host.)
|
r& r% r Úhostr rn Úconnection_from_urlr Úgeturlrb )r3 r~ r= rk Ú proxy_urlrP r} Úparsedr+ r+ r, Úget_connectionK s
|
|
ÿ
|
zHTTPAdapter.get_connectionc C s& | j ¡ | j ¡ D ] }| ¡ qdS )z¢Disposes of any internal state.
|
|
Currently, this closes the PoolManager and any active ProxyManager,
|
which closes any pooled connections.
|
N)rb ÚclearrP Úvalues)r3 rk r+ r+ r, r? h s
|
zHTTPAdapter.closec C s` t |j|}t|jj}|o"|dk}d}|rDt|j ¡ }| d¡}|j}|r\|s\t|j}|S )a? Obtain the url to use when making the final request.
|
|
If the message is being sent through a HTTP proxy, the full URL has to
|
be used. Otherwise, we should only use the path portion of the URL.
|
|
This should not be called from user code, and is only exposed for use
|
when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param request: The :class:`PreparedRequest <PreparedRequest>` being sent.
|
:param proxies: A dictionary of schemes or schemes and hosts to proxy URLs.
|
:rtype: str
|
ro Fre )r& r~ r Úschemeri rj Úpath_urlr' ) r3 r8 r= rk r Úis_proxied_http_requestÚusing_socks_proxyÚ proxy_schemer~ r+ r+ r, Ú request_urlr s
|
|
zHTTPAdapter.request_urlc K s dS )a" Add any headers needed by the connection. As of v2.0 this does
|
nothing by default, but is left for overriding by users that subclass
|
the :class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
This should not be called from user code, and is only exposed for use
|
when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param request: The :class:`PreparedRequest <PreparedRequest>` to add headers to.
|
:param kwargs: The keyword arguments from the call to send().
|
Nr+ )r3 r8 r* r+ r+ r, Ú add_headers s zHTTPAdapter.add_headersc C s& i }t |\}}|r"t|||d< |S )a Returns a dictionary of the headers to add to any request sent
|
through a proxy. This works with urllib3 magic to ensure that they are
|
correctly sent to the proxy, rather than in a tunnelled request if
|
CONNECT is being used.
|
|
This should not be called from user code, and is only exposed for use
|
when subclassing the
|
:class:`HTTPAdapter <requests.adapters.HTTPAdapter>`.
|
|
:param proxy: The url of the proxy being used for this request.
|
:rtype: dict
|
zProxy-Authorization)r# r )r3 rk r rf rg r+ r+ r, rh s
|
zHTTPAdapter.proxy_headersFTc C sÒ z| |j|¡}W n. tk
|
r@ } zt||dW 5 d}~X Y nX | ||j||¡ | ||¡} | j||||||d |jdkpd|jk }
|
t |t
|
rÖz|\} } t | | d}W qî t k
|
rÒ t d| dY qîX nt |t rân t ||d}z.|j |j| |j|jdddd| j||
|
d } W n¨ ttfk
|
rR } zt||dW 5 d}~X Y nt tk
|
rö } zt |jtrt |jtst||dt |jtr¦t||dt |jtrÀt||dt |jt rÚt ||dt||dW 5 d}~X Y nÐ t k
|
r$ } zt||dW 5 d}~X Y n¢ tk
|
rN } z t|W 5 d}~X Y nx t t fk
|
rÄ } zTt |t r~t ||dn6t |t rt!||dn t |t"r²t#||dn W 5 d}~X Y nX | $|| ¡S )
|
a Sends PreparedRequest object. Returns Response object.
|
|
:param request: The :class:`PreparedRequest <PreparedRequest>` being sent.
|
:param stream: (optional) Whether to stream the request content.
|
:param timeout: (optional) How long to wait for the server to send
|
data before giving up, as a float, or a :ref:`(connect timeout,
|
read timeout) <timeouts>` tuple.
|
:type timeout: float or tuple or urllib3 Timeout object
|
:param verify: (optional) Either a boolean, in which case it controls whether
|
we verify the server's TLS certificate, or a string, in which case it
|
must be a path to a CA bundle to use
|
:param cert: (optional) Any user-provided SSL certificate to be trusted.
|
:param proxies: (optional) The proxies dictionary to apply to the request.
|
:rtype: requests.Response
|
)r8 N)r9 r: r; r< r= zContent-Length)ÚconnectrK zInvalid timeout za. Pass a (connect, read) timeout tuple, or a single float to set both timeouts to the same value.F) Úmethodr~ Úbodyr ÚredirectÚassert_same_hostÚpreload_contentÚdecode_contentÚretriesr: Úchunked)%r r~ r r r r r r¡ r rz ÚtupleÚ TimeoutSauceÚ
|
ValueErrorÚurlopenr rF r ru r r r r r r r r Ú _ProxyErrorr
|
Ú _SSLErrorr r Ú
|
_HTTPErrorr r Ú_InvalidHeaderr r )r3 r8 r9 r: r; r< r= r} Úer~ r§ r rK r Úerrr+ r+ r, r> ² s ú
|
|
ÿ
|
õ zHTTPAdapter.send)N)FNTNN)r@ rA rB rC rY ÚDEFAULT_POOLSIZErN ÚDEFAULT_POOLBLOCKr1 rZ r_ rQ rn r r r r? r r rh r> rD r+ r+ r4 r, rE d s< û
|
ûÿ
|
&9%
|
|
ÿrE )BrC Úos.pathrr ÚsocketZurllib3.exceptionsr r r r® r r¯ r r r r r
|
r¬ r r r r Zurllib3.poolmanagerr r Z urllib3.utilr r© r Zurllib3.util.retryr Úauthr Úcompatr r r r Ú
|
exceptionsr r r r r r r Úmodelsr Ú
|
structuresr Úutilsr! r" r# r$ r% r& r' Zurllib3.contrib.socksr( Ú ImportErrorr³ r² rN ÚDEFAULT_POOL_TIMEOUTr. rE r+ r+ r+ r, Ú<module> s< 0 $
|
|
