Ë
|
ê^ik© ã óú d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
|
Z d dl m Z ddlmZ ddlmZ ddlmZ dd lmZmZmZmZmZmZmZm Z dd
|
lm Z dd l m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ dd l,m-Z- dd l.m/Z/ ddl0m1Z1 ddl2m3Z3m4Z4 ddl5m6Z6 ddl7m8Z8 ddl9m:Z:m;Z;m<Z< ddl=m>Z>m?Z? ddl=m@ZA ddl=mBZB ddlCmDZD ej rd dlFZFd dlGmHZH ddlmIZImJZJ ej eL« ZMej e<eOe;df ZP G d d« ZQej¤ ej¦ hZT G d d eQe« ZU G d d eU« ZVd%d ZWej° d&d « Z@ej° d'd!« Z@d(d"Z@ d) d*d#ZYd+d$ZZy),é )Ú annotationsN©Útimeout)Ú TracebackTypeé )Ú
|
_TYPE_BODY)ÚHTTPHeaderDict)ÚRequestMethods)Ú BaseSSLErrorÚBrokenPipeErrorÚDummyConnectionÚHTTPConnectionÚ HTTPExceptionÚHTTPSConnectionÚ ProxyConfigÚ_wrap_proxy_error)Úport_by_scheme) ÚClosedPoolErrorÚEmptyPoolErrorÚ FullPoolErrorÚHostChangedErrorÚInsecureRequestWarningÚLocationValueErrorÚ MaxRetryErrorÚNewConnectionErrorÚ ProtocolErrorÚ
|
ProxyErrorÚReadTimeoutErrorÚSSLErrorÚ TimeoutError)ÚBaseHTTPResponse)Úis_connection_dropped)Ú connection_requires_http_tunnel)Ú_TYPE_BODY_POSITIONÚset_file_position)ÚRetry)ÚCertificateError)Ú_DEFAULT_TIMEOUTÚ _TYPE_DEFAULTÚTimeout)ÚUrlÚ_encode_target)Ú_normalize_host)Ú parse_url)Úto_str)ÚSelf)ÚBaseHTTPConnectionÚBaseHTTPSConnectionc ór e Zd ZU dZdZded< ej Zd
|
d dZ d dZ
|
d dZ ddZ dd Z y)ÚConnectionPoola;
|
Base class for all connection pools, such as
|
:class:`.HTTPConnectionPool` and :class:`.HTTPSConnectionPool`.
|
|
.. note::
|
ConnectionPool.urlopen() does not normalize or percent-encode target URIs
|
which is useful if your target server doesn't support percent-encoded
|
target URIs.
|
Nú
|
str | NoneÚschemec ó¸ |s t d« t || j ¬« | _ || _ t || j ¬« j « | _ y )NzNo host specified.©r6 )r r- r6 ÚhostÚportÚnormalize_hostÚlowerÚ _tunnel_host)Úselfr9 r: s õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/connectionpool.pyÚ__init__zConnectionPool.__init__Q sH ÙÜ$Ð%9Ó:Ð :ä# D°·±Ô= Ø ô +¨4¸¿ ¹ Ô D× JÑ JÓ LÕó c óf t | « j d| j d| j dS )Nz(host=z, port=ú))ÚtypeÚ__name__r9 r: ©r> s r? Ú__str__zConnectionPool.__str__^ s. Üt*×%Ñ%Ð& f¨T¯Y©Y¨M¸ÀÇÁÀ ÈQÐOÐOrA c ó | S ©N© rF s r? Ú __enter__zConnectionPool.__enter__a s Ø rA c ó$ | j « y)NF)Úclose)r> Úexc_typeÚexc_valÚexc_tbs r? Ú__exit__zConnectionPool.__exit__d s ð
|
|
àrA c ó y©zD
|
Close all pooled connections and disable the pool.
|
NrJ rF s r? rM zConnectionPool.closen ó rA rI )r9 Ústrr: ú
|
int | NoneÚreturnÚNone)rW rU )rW r0 )rN ztype[BaseException] | NonerO zBaseException | NonerP zTracebackType | NonerW ztyping.Literal[False]©rW rX )rE Ú
|
__module__Ú __qualname__Ú__doc__r6 Ú__annotations__ÚqueueÚ LifoQueueÚQueueClsr@ rG rK rQ rM rJ rA r? r4 r4 C s]
ñð FJÓ ØHô MóPóðà,ðð &ðð %ð ð
|
|
ó ô rA r4 c ór e Zd ZU dZdZeZded< dedddddddf ddZ dd Z
|
ddd
|
Z dd Z dd Z dd ZddZ d dZdddedddddf d dZd dZd dZdddddeddddddf d dZy)!ÚHTTPConnectionPoola
|
Thread-safe connection pool for one host.
|
|
:param host:
|
Host used for this HTTP Connection (e.g. "localhost"), passed into
|
:class:`http.client.HTTPConnection`.
|
|
:param port:
|
Port used for this HTTP Connection (None is equivalent to 80), passed
|
into :class:`http.client.HTTPConnection`.
|
|
:param timeout:
|
Socket timeout in seconds for each individual connection. This can
|
be a float or integer, which sets the timeout for the HTTP request,
|
or an instance of :class:`urllib3.util.Timeout` which gives you more
|
fine-grained control over request timeouts. After the constructor has
|
been parsed, this is always a `urllib3.util.Timeout` object.
|
|
:param maxsize:
|
Number of connections to save that can be reused. More than 1 is useful
|
in multithreaded situations. If ``block`` is set to False, more
|
connections will be created but they will not be saved once they've
|
been used.
|
|
:param block:
|
If set to True, no more than ``maxsize`` connections will be used at
|
a time. When no free connections are available, the call will block
|
until a connection has been released. This is a useful side effect for
|
particular multithreaded situations where one does not want to use more
|
than maxsize connections per host to prevent flooding.
|
|
:param headers:
|
Headers to include with all requests, unless other headers are given
|
explicitly.
|
|
:param retries:
|
Retry configuration to use by default with requests in this pool.
|
|
:param _proxy:
|
Parsed proxy URL, should not be used directly, instead, see
|
:class:`urllib3.ProxyManager`
|
|
:param _proxy_headers:
|
A dictionary with proxy headers, should not be used directly,
|
instead, see :class:`urllib3.ProxyManager`
|
|
:param \**conn_kw:
|
Additional parameters are used to create fresh :class:`urllib3.connection.HTTPConnection`,
|
:class:`urllib3.connection.HTTPSConnection` instances.
|
Úhttpz4type[BaseHTTPConnection] | type[BaseHTTPSConnection]Ú ConnectionClsNr Fc óÖ t j | ||« t j | |« t |t « st j
|
|« }|t j }|| _ || _ | j |« | _ || _ || _ | xs i | _ |
|
| _ t! |« D ] } | j j# d « d| _ d| _ | | _ | j rN| j( j+ dg « | j | j( d< | j | j( d< | j } t- j. | t0 | « y )Nr Úsocket_optionsÚproxyÚ proxy_config)r4 r@ r
|
Ú
|
isinstancer* Ú
|
from_floatr& ÚDEFAULTr Úretriesr` ÚpoolÚblockrg Ú proxy_headersrh ÚrangeÚputÚnum_connectionsÚ num_requestsÚconn_kwÚ
|
setdefaultÚweakrefÚfinalizeÚ_close_pool_connections)r> r9 r: r Úmaxsizern Úheadersrl Ú_proxyÚ_proxy_headersÚ _proxy_configrt Ú_rm s r? r@ zHTTPConnectionPool.__init__¯ s1 ô × Ñ d¨DÔ1Ü× Ñ gÔ.ä'¤7Ô+Ü ×(Ñ(¨Ó1Gà ?ÜmmGà Ø à8<¿ ¹ ÀgÓ8N Ø
|
à
|
Ø +Ò 1¨rÔØ )Ôô w ò AØ IIMM$Õ ð ð !Ô Ø ÔØ à ::ð LL× #Ñ #Ð$4°bÔ 9à$(§J¡JDLLÑ !Ø+/×+<Ñ+<DLL Ñ (ð yyô ×ÑÔ 6¸Õ=rA c ó4 | xj dz c_ t j d| j | j | j xs d« | j
|
d| j | j | j j d| j ¤}|S )z9
|
Return a fresh :class:`HTTPConnection`.
|
r z(Starting new HTTP connection (%d): %s:%sÚ80)r9 r: r rJ ) rr ÚlogÚdebugr9 r: rd r Úconnect_timeoutrt ©r> Úconns r? Ú _new_connz HTTPConnectionPool._new_connì s ð × Ò Ñ!Õ Ü Ø 6Ø × Ñ Ø IIØ IIÒ ô
|
ð "t×!Ñ!ð
|
ØØØLL×0Ñ0ñ
|
ð llñ
|
ð rA c ó¶ d}| j t | d« | j j | j |¬« }|r;t |« r0t j d| j « |j « |xs | j « S # t $ r t | d« dt
|
j $ r | j r t | d« dY w xY w)a
|
Get a connection. Will return a pooled connection if one is available.
|
|
If no connections are available and :prop:`.block` is ``False``, then a
|
fresh connection is returned.
|
|
:param timeout:
|
Seconds to wait before giving up and raising
|
:class:`urllib3.exceptions.EmptyPoolError` if the pool is empty and
|
:prop:`.block` is ``True``.
|
NzPool is closed.)rn r zHPool is empty and a new connection can't be opened due to blocking mode.z Resetting dropped connection: %s)rm r Úgetrn ÚAttributeErrorr^ ÚEmptyr r" r r r9 rM r )r> r r
s r? Ú _get_connz HTTPConnectionPool._get_conn sÍ ð à 99Ð Ü! $Ð(9Ó:Ð :ð Ø99== t§z¡z¸7=ÓCDñ Ô)¨$Ô/Ü IIÐ8¸$¿)¹)Ô DØ JJLàÒ't~~Ó'Ð'øô! ò EÜ! $Ð(9Ó:ÀÐ Dä{{ò ØzzÜ$ØØ^óð ð ñ ð ús 'B ÂACÃCc ó | j | j j |d¬« y|r|j « yy# t $ r Y t j $ rg |r|j « | j r t | d« dt j d| j | j j « « Y w xY w)aä
|
Put a connection back into the pool.
|
|
:param conn:
|
Connection object for the current host and port as returned by
|
:meth:`._new_conn` or :meth:`._get_conn`.
|
|
If the pool is already full, the connection is closed and discarded
|
because we exceeded maxsize. If connections are discarded frequently,
|
then maxsize should be increased.
|
|
If the pool is closed, then the connection will be closed and discarded.
|
NF©rn z>Pool reached maximum size and no more connections are allowed.zLConnection pool is full, discarding connection: %s. Connection pool size: %s) rm rq r r^ ÚFullrM rn r r Úwarningr9 Úqsizer s r? Ú _put_connz HTTPConnectionPool._put_conn& s® ð 99Ð ð Ø d¨% Ô0Øñ. Ø JJLð øô- "ò áÜ::ò áØJJLà::ä'Ø ØXóð ð ô
|
ØbØIIØIIOOÓ%öð ús A Á CÁ A6CÃCc ó y)úU
|
Called right before a request is made, after the socket is created.
|
NrJ r s r? Ú_validate_connz!HTTPConnectionPool._validate_connQ rT rA c ó y rI rJ r s r? Ú_prepare_proxyz!HTTPConnectionPool._prepare_proxyV s à rA c ó° |t u r| j j « S t |t « r|j « S t j
|
|« S )z:Helper that always returns a :class:`urllib3.util.Timeout`)r( r Úcloneri r* rj )r> r s r? Ú _get_timeoutz HTTPConnectionPool._get_timeoutZ sG à Ô&Ñ &Ø<<×%Ñ%Ó'Ð 'ä gwÔ 'Ø==?Ð "ô ×%Ñ% gÓ.Ð .rA c óª t |t « rt | |d| d« |t |d« r%|j t
|
v rt | |d| d« |yy)zAIs the error actually a timeout? Will raise a ReadTimeout or passú Read timed out. (read timeout=rC ÚerrnoN)ri Ú SocketTimeoutr Úhasattrr Ú_blocking_errnos)r> ÚerrÚurlÚ timeout_values r? Ú_raise_timeoutz!HTTPConnectionPool._raise_timeoutf sq ô c=Ô )Ü"ØcÐ ;¸M¸?È!ÐLóàð ô
|
3Ô S§Y¡YÔ2BÑ%BÜ"ØcÐ ;¸M¸?È!ÐLóàð ð &CÐ rA Tc óP | xj dz c_ | j |« } | j « t j | j
|
« |_ | j |« |j+ ||||||
|
| | ¬« | j4 }|j6 s |dk( rt9 | |d| d« ||_ |j; « }||_ | |_ | |_ tB jE d| j( | jF | jH |||jJ |jL |jN « |S # t t f$ r$}| j |||j ¬« d}~ww xY w# t t t t t t f$ r}|}t! |t t f« r t |« }t! |t t t t f« r:|r8|j" r,|j$ s t' ||j" j( « }|d}~ww xY w# t, $ r Y ¢t $ rF}|j. t. j0 k7 r |j. t. j2 k7 r Y d}~ëd}~ww xY w# t t f$ r}| j |||¬« d}~ww xY w) a8
|
|
Perform a request on a given urllib connection object taken from our
|
pool.
|
|
:param conn:
|
a connection from one of our connection pools
|
|
:param method:
|
HTTP request method (such as GET, POST, PUT, etc.)
|
|
:param url:
|
The URL to perform the request on.
|
|
:param body:
|
Data to send in the request body, either :class:`str`, :class:`bytes`,
|
an iterable of :class:`str`/:class:`bytes`, or a file-like object.
|
|
:param headers:
|
Dictionary of custom headers to send, such as User-Agent,
|
If-None-Match, etc. If None, pool headers are used. If provided,
|
these headers completely replace any pool-specific headers.
|
|
:param retries:
|
Configure the number of retries to allow before raising a
|
:class:`~urllib3.exceptions.MaxRetryError` exception.
|
|
Pass ``None`` to retry until you receive a response. Pass a
|
:class:`~urllib3.util.retry.Retry` object for fine-grained control
|
over different types of retries.
|
Pass an integer number to retry connection errors that many times,
|
but no other types of errors. Pass zero to never retry.
|
|
If ``False``, then retries are disabled and any exception is raised
|
immediately. Also, instead of raising a MaxRetryError on redirects,
|
the redirect response will be returned.
|
|
:type retries: :class:`~urllib3.util.retry.Retry`, False, or an int.
|
|
:param timeout:
|
If specified, overrides the default timeout for this one
|
request. It may be a float (in seconds) or an instance of
|
:class:`urllib3.util.Timeout`.
|
|
:param chunked:
|
If True, urllib3 will send the body using chunked transfer
|
encoding. Otherwise, urllib3 will send the body using the standard
|
content-length form. Defaults to False.
|
|
:param response_conn:
|
Set this to ``None`` if you will handle releasing the connection or
|
set the connection to have the response release it.
|
|
:param preload_content:
|
If True, the response's body will be preloaded during construction.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
|
:param enforce_content_length:
|
Enforce content length checking. Body returned by server must match
|
value of Content-Length header, if present. Otherwise, raise error.
|
r ©r r¡ r¢ N)Úbodyrz ÚchunkedÚpreload_contentÚdecode_contentÚenforce_content_lengthr r rC z%s://%s:%s "%s %s %s" %s %s)(rs r Ú start_connectr* Úresolve_default_timeoutr r r r r r£ ÚOSErrorr r r' r ri rg Úhas_connected_to_proxyr r6 Úrequestr r Ú
|
EPROTOTYPEÚ
|
ECONNRESETÚ read_timeoutÚ is_closedr Ú getresponserl Ú _connectionÚ_poolr r r9 r: Úversion_stringÚstatusÚlength_remaining)r> r
Úmethodr¡ r¦ rz rl r r§ Ú response_connr¨ r© rª Ú timeout_objÚeÚnew_er² Úresponses r? Ú _make_requestz HTTPConnectionPool._make_requesty s} ð\ ×ÒQÑ Õà×'Ñ'¨Ó0 Ø×!Ñ!Ô#Ü ×6Ñ6°{×7RÑ7RÓS ð ð Ø×#Ñ# DÕ)ð8 Ø LLØØØØ Ø Ø /Ø -Ø'=ð ô ð2 #×/Ñ/ à~~ð qÒ Ü&Ø#Ð!?À ¸~ÈQÐ Oóð ð (DLð Ø×'Ñ'Ó)Hð #ÔØ ,Ô Ø ä Ø )Ø KKØ IIØ IIØ Ø Ø × #Ñ #Ø OOØ × %Ñ %ô
|
|
ð øôw "¤<Ð0ò Ø×#Ñ#¨¨sÀ$Ç,Á,Ð#ÔOØûð ûô Ü Ü Ü Ü Ü ð
|
ò ð !EÜ!lÔ,<Ð =Ô>Ü ô ØÔ!3´\Ä8ÐLôáDJJ¨t×/JÒ/JÜ)¨%°·±×1BÑ1BÓCØKûð# ûôH ò Ú Üò ð
|
ww%×*Ñ*Ò*¨q¯w©w¼%×:JÑ:JÒ/JØÿùð ûô4 gÐ&ò Ø × Ñ A¨3¸lÐ Ô KØ ûð úsg Á D? Á0H Â?I< Ä?E2Å E-Å-E2Å2E5 Å5#H ÆA?HÈH È I9È+I9È3;I4É4I9É<J%Ê J Ê J%c ó\ | j y| j dc}| _ t |« yrS )rm rx )r> Úold_pools r? rM zHTTPConnectionPool.close. s- ð 99Ð Ø à "ii¨Ð$)ô Õ)rA c óV |j d« ryt |« ^}}}}}|xs d}| t ||¬« }| j r|st j
|
|« }n&| j s|t j
|
|« k( rd}|||f| j | j | j fk( S )zj
|
Check if the given ``url`` is a member of the same host as this
|
connection pool.
|
ú/Trc Nr8 )Ú
|
startswithr. r- r: r r r6 r9 )r> r¡ r6 r~ r9 r: s r? Ú is_same_hostz HTTPConnectionPool.is_same_host: s£ ð
|
>>#Ô Øô %.¨c£NÐ!4 ØÒ!6Ø Ð Ü" 4°Ô7Dð 99TÜ!×%Ñ% fÓ-DØt¤~×'9Ñ'9¸&Ó'AÒ AØDàdÐ#¨¯ © °T·Y±YÀÇ Á Ð'JÑJÐJrA c óâ
|
t |« }|j }| | j }t |t « s"t j
|
||| j ¬« }|
|
| }
|
|r | j |« s t | ||« |j d« rt t |« « }nt |j « }d}|
|
}t | j | j |« }|s+|j! « }|j# | j$ « d}d}t' || « } | j) |« }| j+ | ¬« }|j, |_ | j |r |j0 r | j3 |« |
|
s|nd} | j< |||f|||| ||| |d|¤}d}|s|r|j[ « d}d}|r| j] |« |s9t^ ja d |||« | jb |||||||f|| |
|
| | | |d |¤S |xr je « } | rjf dk( r d}d}ti |« jk « } |jS |||| ¬« }|jq « |js |« t^ ju d|| « | jb || ||f||||| |
|
| | | |d
|
|¤S tw j jy d« « } |j{ ||jf | « rn |jS |||| ¬« }|jq « |jY |« t^ ju d|« | jb ||||f||||| |
|
| | | |d
|
|¤S |S # t4 t6 t8 f$ r8}| j; || j j |j. ¬« d}~ww xY w# t> $ r d}d} t@ tB t6 tD t4 tF tH tJ f$ rï}d}|}t |t4 tH f« r tG |« }t |t6 tL t@ tF tB f« r;|r9|j r-|jN s!tQ ||j j « }n"t |t6 tB f« r tE d |« }|jS |||| tU jV « d
|
¬ « }|jY « |}Y d}~<d}~ww xY w# |s|r|j[ « d}d}|r| j] |« w w xY w# tl $ r" |jn r|jq « |cY S w xY w# tl $ r" |j| r|jq « |cY S w xY w)a
|
Get a connection from the pool and perform an HTTP request. This is the
|
lowest level call for making a request, so you'll need to specify all
|
the raw details.
|
|
.. note::
|
|
More commonly, it's appropriate to use a convenience method
|
such as :meth:`request`.
|
|
.. note::
|
|
`release_conn` will only behave as expected if
|
`preload_content=False` because we want to make
|
`preload_content=False` the default behaviour someday soon without
|
breaking backwards compatibility.
|
|
:param method:
|
HTTP request method (such as GET, POST, PUT, etc.)
|
|
:param url:
|
The URL to perform the request on.
|
|
:param body:
|
Data to send in the request body, either :class:`str`, :class:`bytes`,
|
an iterable of :class:`str`/:class:`bytes`, or a file-like object.
|
|
:param headers:
|
Dictionary of custom headers to send, such as User-Agent,
|
If-None-Match, etc. If None, pool headers are used. If provided,
|
these headers completely replace any pool-specific headers.
|
|
:param retries:
|
Configure the number of retries to allow before raising a
|
:class:`~urllib3.exceptions.MaxRetryError` exception.
|
|
If ``None`` (default) will retry 3 times, see ``Retry.DEFAULT``. Pass a
|
:class:`~urllib3.util.retry.Retry` object for fine-grained control
|
over different types of retries.
|
Pass an integer number to retry connection errors that many times,
|
but no other types of errors. Pass zero to never retry.
|
|
If ``False``, then retries are disabled and any exception is raised
|
immediately. Also, instead of raising a MaxRetryError on redirects,
|
the redirect response will be returned.
|
|
:type retries: :class:`~urllib3.util.retry.Retry`, False, or an int.
|
|
:param redirect:
|
If True, automatically handle redirects (status codes 301, 302,
|
303, 307, 308). Each redirect counts as a retry. Disabling retries
|
will disable redirect, too.
|
|
:param assert_same_host:
|
If ``True``, will make sure that the host of the pool requests is
|
consistent else will raise HostChangedError. When ``False``, you can
|
use the pool on an HTTP proxy and request foreign hosts.
|
|
:param timeout:
|
If specified, overrides the default timeout for this one
|
request. It may be a float (in seconds) or an instance of
|
:class:`urllib3.util.Timeout`.
|
|
:param pool_timeout:
|
If set and the pool is set to block=True, then this method will
|
block for ``pool_timeout`` seconds and raise EmptyPoolError if no
|
connection is available within the time period.
|
|
:param bool preload_content:
|
If True, the response's body will be preloaded into memory.
|
|
:param bool decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
|
:param release_conn:
|
If False, then the urlopen call will not release the connection
|
back into the pool once a response is received (but will release if
|
you read the entire contents of the response such as when
|
`preload_content=True`). This is useful if you're not preloading
|
the response's content immediately. You will need to call
|
``r.release_conn()`` on the response ``r`` to return the connection
|
back into the pool. If None, it takes the value of ``preload_content``
|
which defaults to ``True``.
|
|
:param bool chunked:
|
If True, urllib3 will send the body using chunked transfer
|
encoding. Otherwise, urllib3 will send the body using the standard
|
content-length form. Defaults to False.
|
|
:param int body_pos:
|
Position to seek to in file-like body in the event of a retry or
|
redirect. Typically this won't need to be set because urllib3 will
|
auto-populate the value when needed.
|
N)ÚredirectÚdefaultrÄ Fr r¥ )r r¦ rz r§ rl r» r¨ r© TzConnection aborted.é )Úerrorr¶ Ú _stacktracez1Retrying (%r) after connection broken by '%r': %s)r Ú pool_timeoutÚ release_connr§ Úbody_posr¨ r© i/ ÚGET)r¿ r¶ zRedirecting %s -> %s)
|
rl rÈ Úassert_same_hostr rÍ rÎ r§ rÏ r¨ r© z Retry-Afterz Retry: %s)?r. r6 rz ri r& Úfrom_intrl rÆ r rÅ r/ r, r¡ r# rg rh ÚcopyÚupdatero r% r r r r r³ r r r r r£ rÀ r r r r r r' r r r® r Ú incrementÚsysÚexc_infoÚsleeprM r r r ÚurlopenÚget_redirect_locationr¸ r Ú_prepare_for_method_changer Úraise_on_redirectÚ
|
drain_connÚsleep_for_retryr Úboolr Úis_retryÚraise_on_status) r> rº r¡ r¦ rz rl rÈ rÑ r rÍ rÎ r§ rÏ r¨ r© Ú response_kwÚ
|
parsed_urlÚdestination_schemer
Úrelease_this_connÚhttp_tunnel_requiredr Ú
|
clean_exitr¼ r½ r» r¿ r¾ Úredirect_locationÚhas_retry_afters r? rÙ zHTTPConnectionPool.urlopenP sá ôb s^
|
Ø '× .Ñ .Ðà ?ØllGä'¤5Ô)Ünn W°xÈÏ É ÔVGà Ð Ø*Lñ D×$5Ñ$5°cÔ$:Ü" 4¨¨gÓ6Ð 6ð >>#Ô Ü ¨Ó,Ó-Cä Ó(Càð )Ðä >Ø JJ×)Ñ)Ð+=ó
|
Ð ñ $Ø llnGØ NN4×-Ñ-Ô .ð ð
|
ô % T¨8Ó4ðe %à ×+Ñ+¨GÓ4KØ>>¨,>Ó7Dà&×6Ñ6DLð zzÐ%Ñ*>À4Ç>Â>ðØ×'Ñ'¨Ô-ñ )5D¸$Mð *t×)Ñ)ØØØð ð $ØØ Ø Ø Ø +Ø /Ø -ñ ð ñ Hð Jñ^ ñ
|
ØJJLØ DØ$(Ð!á ð tÕ$áä KKØCÀWÈcÐSVô ð 4<<ØØØØØØØ ðð Ø )Ø )Ø Ø!Ø /Ø -ñ ð ñ ð ð& %Ò I¨×)GÑ)GÓ)IÐÙ Ø #Ò%à àÜ(¨Ó1×LÑLÓNð Ø!×+Ñ+¨F°CÀ(ÐRVÐ+ÓWð × Ñ Ô !Ø × #Ñ # HÔ -Ü IIÐ,¨cÐ3DÔ EØ 4<<ØØ!ØØð ð
|
Ø!Ø!1Ø Ø )Ø )Ø Ø!Ø /Ø -ñ ð ñ ð ô& x× /Ñ /× 3Ñ 3°MÓ BÓCØ × Ñ F H§O¡O°_Ô Eð Ø!×+Ñ+¨F°CÀ(ÐRVÐ+ÓWð × Ñ Ô !Ø MM(Ô #Ü IIk 3Ô 'Ø 4<<ØØØØð ð
|
Ø!Ø!1Ø Ø )Ø )Ø Ø!Ø /Ø -ñ ð ñ ð ð$ øôu %¤g¬}Ð=ò Ø×'Ñ'Ø 4§:¡:§>¡>ÀÇ Á ð (ô ð ûð ûô> ò à JØ %Ð Ø ô Ü Ü Ü Ü Ü Ü Ü ð
|
ò $ ð JØ EÜ!lÔ,<Ð =Ô>Ü ÜØäÜ&Ü Ü Ü!ð ô ñ DJJ¨t×/JÒ/JÜ)¨%°·±×1BÑ1BÓCÜE¤G¬]Ð#;Ô<Ü%Ð&;¸UÓCà ×'Ñ'Ø 5°Ä#Ç,Á,Ã.ÐQRÑBSð (ó Gð MMOð CûðI$ ûñN ñ
|
ØJJLØ DØ$(Ð!á ð tÕ$ð !ûôR !ò Ø×,Ò,Ø ×'Ñ'Ô)ØØ ð ûô@ !ò Ø×*Ò*Ø ×'Ñ'Ô)ØØ ð úst ÄAN8 Å)M) Å:&N8 É
|
T Ë:U Í)N5Í=3N0Î0N5Î5N8 Î8:S!Ï2C$S ÓS$ Ó S!Ó!S$ Ó$.TÔ(U Ô?U Õ(U.Õ-U.)r9 rU r: rV r ú_TYPE_TIMEOUT | Nonery Úintrn rß rz ú typing.Mapping[str, str] | Nonerl úRetry | bool | int | Noner{ ú
|
Url | Noner| rì r} zProxyConfig | Nonert ú
|
typing.Any)rW r1 rI )r z float | NonerW r1 )r
úBaseHTTPConnection | NonerW rX ©r
r1 rW rX )r Ú _TYPE_TIMEOUTrW r* )r z&BaseSSLError | OSError | SocketTimeoutr¡ rU r¢ rê rW rX )r
r1 rº rU r¡ rU r¦ ú_TYPE_BODY | Nonerz rì rl z Retry | Noner rò r§ rß r» rð r¨ rß r© rß rª rß rW r! rY )r¡ rU rW rß ) rº rU r¡ rU r¦ ró rz rì rl rí rÈ rß rÑ rß r rò rÍ rV rÎ z bool | Noner§ rß rÏ z_TYPE_BODY_POSITION | Noner¨ rß r© rß râ rï rW r! )rE rZ r[ r\ r6 r rd r] r( r@ r r r r r r r£ rÀ rM rÆ rÙ rJ rA r? rb rb x s
ñ1ðf FØJXMÐGÓXð
|
Ø(8ØØØ37Ø-1Ø !Ø:>Ø,0ð;>àð;>ð ð;>ð &ð ;>ð
|
ð ;>ð ð ;>ð 1ð;>ð +ð;>ð ð;>ð 8ð;>ð *ð;>ð ó;>ózô($(óL)óV ó
|
ó
|
/ðà 3ðð ðð ,ð ð
|
|
ó ð0 #'Ø37Ø $Ø!1Ø Ø37Ø $Ø #Ø'+ðsà ðsð ðsð ð sð
|
ð sð 1ð sð ðsð ðsð ðsð 1ðsð ðsð ðsð !%ðsð
|
ó sój
|
*óKð4 #'Ø37Ø-1Ø Ø!%Ø!1Ø#'Ø$(Ø Ø/3Ø $Ø #ð pàðpð ðpð ð pð
|
1ð pð +ð pð ðpð ðpð ðpð !ðpð "ðpð ðpð -ðpð ð pð ð pð "ð!pð"
|
ô#prA rb c óÒ e Zd ZU dZdZeZded< dedddddddddddddddddf d fd Z d d Z
|
dd
|
Z d fd Z xZ S )ÚHTTPSConnectionPoola
|
Same as :class:`.HTTPConnectionPool`, but HTTPS.
|
|
:class:`.HTTPSConnection` uses one of ``assert_fingerprint``,
|
``assert_hostname`` and ``host`` in this order to verify connections.
|
If ``assert_hostname`` is False, no verification is done.
|
|
The ``key_file``, ``cert_file``, ``cert_reqs``, ``ca_certs``,
|
``ca_cert_dir``, ``ssl_version``, ``key_password`` are only used if :mod:`ssl`
|
is available and are fed into :meth:`urllib3.util.ssl_wrap_socket` to upgrade
|
the connection socket into an SSL socket.
|
Úhttpsztype[BaseHTTPSConnection]rd Nr Fc óÐ t | ||||||||| f i |¤ |
|
| _ | | _ | | _ | | _ || _ || _ || _ || _ || _
|
|| _ || _ y rI ) Úsuperr@ Úkey_fileÚ cert_fileÚ cert_reqsÚ key_passwordÚca_certsÚ ca_cert_dirÚ ssl_versionÚssl_minimum_versionÚssl_maximum_versionÚassert_hostnameÚassert_fingerprint)r> r9 r: r ry rn rz rl r{ r| rù rú rû rü rý rÿ r r r r rþ rt Ú __class__s r? r@ z HTTPSConnectionPool.__init__Ô s ø ô0 ÑØ Ø Ø Ø Ø Ø Ø Ø Ø ñ
|
ð ò
|
ð ! Ø"Ø"Ø (ÔØ Ø&ÔØ&ÔØ#6Ô Ø#6Ô Ø .Ô Ø"4Õ rA c óÞ | j r | j j dk( rd}nd}|j || j | j | j
|
¬« |j « y)z5Establishes a tunnel connection through HTTP CONNECT.rö rc )r6 r9 r: rz N)rg r6 Ú
|
set_tunnelr= r: ro Úconnect)r> r
Ú tunnel_schemes r? r z"HTTPSConnectionPool._prepare_proxy s\ à ::$**×+Ñ+¨wÒ6Ø #Mà "Mà Ø Ø×"Ñ"ØØ×&Ñ&ð ô
|
ð rA c ó | xj dz c_ t j d| j | j | j xs d« | j
|
r| j
|
t u r t d« | j }| j }| j B| j j ,| j j }| j j } | j
|
d||| j j | j | j | j | j | j | j | j" | j$ | j& | j( | j* d| j, ¤S )zL
|
Return a fresh :class:`urllib3.connection.HTTPConnection`.
|
r z)Starting new HTTPS connection (%d): %s:%sÚ443zCCan't connect to HTTPS URL because the SSL module is not available.)r9 r: r rú rù rü rû rý rþ r r rÿ r r rJ )rr r r r9 r: rd r Ú ImportErrorrg r r rú rù rü rû rý rþ r r rÿ r r rt )r> Ú actual_hostÚ actual_ports r? r z HTTPSConnectionPool._new_conn sC ð × Ò Ñ!Õ Ü Ø 7Ø × Ñ Ø IIØ IIÒ ô
|
ð ×!Ò! T×%7Ñ%7¼?Ñ%JÜ ØUóð ð 99 Øii Ø ::Ð ! d§j¡j§o¡oÐ&AØ **//KØ **//Kà!t×!Ñ!ð
|
Ø Ø ØLL×0Ñ0ØnnØ]]Ø ×*Ñ*ØnnØ]]Ø ×(Ñ(Ø × 0Ñ 0Ø #× 6Ñ 6Ø ×(Ñ(Ø $× 8Ñ 8Ø $× 8Ñ 8ñ
|
ð llñ
|
ð
|
rA c óà t | |« |j r|j « |j s6|j
|
s)t j d|j dt « yyy)r z0Unverified HTTPS request is being made to host 'z'. Adding certificate verification is strongly advised. See: https://urllib3.readthedocs.io/en/latest/advanced-usage.html#tls-warningsN)
|
rø r r³ r Ú is_verifiedÚproxy_is_verifiedÚwarningsÚwarnr9 r )r> r
r s r? r z"HTTPSConnectionPool._validate_conn= sf ø ô Ñ tÔ$ð >>Ø LLNð × Ò ¨×(>Ò(>Ü MMàFÀtÇyÁyÀkð R$ð $ô
|
'õ ð )?Ð rA ),r9 rU r: rV r rê ry rë rn rß rz rì rl rí r{ rî r| rì rù r5 rú r5 rû úint | str | Nonerü r5 rý r5 rÿ r r ússl.TLSVersion | Noner r r z"str | typing.Literal[False] | Noner r5 rþ r5 rt rï rW rX )r
r rW rX )rW r2 rñ )rE rZ r[ r\ r6 r rd r] r( r@ r r r Ú __classcell__)r s @r? rõ rõ Ã sJ ø
ñ ð FØ/>MÐ,Ó>ð
|
Ø(8ØØØ37Ø-1Ø !Ø:>Ø #Ø $Ø&*Ø#'Ø #Ø(,Ø59Ø59Ø>BØ)-Ø"&ð+/5àð/5ð ð/5ð &ð /5ð
|
ð /5ð ð /5ð 1ð/5ð +ð/5ð ð/5ð 8ð/5ð ð/5ð ð/5ð $ð/5ð !ð /5ð ð /5ð &ð!/5ð" 3ð#/5ð$ 3ð%/5ð& <ð'/5ð( 'ð)/5ð* ð+/5ð, ð-/5ð.
|
õ//5ób ó '
|
÷Rñ rA rõ c ó¤ t | « ^}}}}}|xs d}|xs t j |d« }|dk( rt |fd|i|¤S t |fd|i|¤S )a
|
Given a url, return an :class:`.ConnectionPool` instance of its host.
|
|
This is a shortcut for not having to parse out the scheme, host, and port
|
of the url before creating an :class:`.ConnectionPool` instance.
|
|
:param url:
|
Absolute URL string that must include the scheme. Port is optional.
|
|
:param \**kw:
|
Passes additional parameters to the constructor of the appropriate
|
:class:`.ConnectionPool`. Useful for specifying things like
|
timeout, maxsize, headers, etc.
|
|
Example::
|
|
>>> conn = connection_from_url('http://google.com/')
|
>>> r = conn.request('GET', '/')
|
rc éP rö r: )r. r r rõ rb )r¡ Úkwr6 r~ r9 r: s r? Úconnection_from_urlr T sk ô( !*¨#£Ð FAtTAØ Ò vFØ Ò 1>×%Ñ% f¨bÓ1DØ ÒÜ" 4Ñ9¨dÐ9°bÑ9Ð9ä! $Ñ8¨TÐ8°RÑ8Ð8rA c ó y rI rJ ©r9 r6 s r? r- r- q s Ø=@rA c ó y rI rJ r s r? r- r- u s Ø;>rA c óp t | |« } | r'| j d« r| j d« r| dd } | S )z?
|
Normalize hosts for comparisons and use with sockets.
|
ú[ú]r éÿÿÿÿ)r; rÅ Úendswithr s r? r- r- y s; ô
|
$ Ó 'Dñ Ô$¨¯ © °sÔ);ØAbzØ KrA c óp t | j | j | j |¬« j S )zZReturns the URL from a given connection pool. This is mainly used for testing and logging.)r6 r9 r: Úpath)r+ r6 r9 r: r¡ )rm r# s r? Ú_url_from_poolr$ s' ô dkk¨¯ © ¸¿ ¹ ÈÔ M× QÑ QÐQrA c ó | j d¬« }|r|j « %# t j $ r Y yw xY w)z2Drains a queue of connections and closes each one.Fr N)r rM r^ r )rm r
s r? rx rx sC ð ØØ88 %8Ó(DÙØ
|
|
ð øô ;;ò Ù ð ús &( ¨>½>)r¡ rU r rï rW rb )r9 rX r6 r5 rW rX )r9 rU r6 r5 rW rU )r9 r5 r6 r5 rW r5 rI )rm z(HTTPConnectionPool | HTTPSConnectionPoolr# r5 rW rU )rm zqueue.LifoQueue[typing.Any]rW rX )[Ú
|
__future__r r Úloggingr^ rÖ Útypingr rv Úsocketr r Útypesr Ú_base_connectionr Ú _collectionsr Ú_request_methodsr
|
Ú
|
connectionr r r r r r r r r Ú
|
exceptionsr r r r r r r r r r r r r r¿ r! Úutil.connectionr" Ú
|
util.proxyr# Ú util.requestr$ r% Ú
|
util.retryr& Úutil.ssl_match_hostnamer' Ú util.timeoutr( r) r* Úutil.urlr+ r, r- r; r. Ú util.utilr/ Ú TYPE_CHECKINGÚsslÚtyping_extensionsr0 r1 r2 Ú getLoggerrE r ÚUnionÚfloatrò r4 ÚEAGAINÚ EWOULDBLOCKr rb rõ r Úoverloadr$ rx rJ rA r? ú<module>rA sW ðÝ "ã Û Û Û
|
Û Û Û Ý +Ý å (Ý (Ý ,÷ ÷ ó õ 9÷÷ ÷ õ õ 'Ý 2Ý 7ß @Ý Ý 5ß BÑ Bß )Ý 7Ý Ý à ×ÒÛå&çIàg×ÑÓ!à W e¨]¸DÐ @ÑA ÷. ñ . ðd LL %×"3Ñ"3Ð4Ð ôH ¨ ô H ôVNÐ,ô Nób9ð: Ú @ó Ø @ð Ú >ó Ø >óð& HLðRØ
|
2ðRØ:DðRàóRô rA
|
