/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/client.cpython-36.pyc (29965B)
3
8%Eg0 * @ s U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z m
Z
ddlmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z ddl Z ddl m!Z!m"Z"m#Z#m$Z$ ddl%m&Z& dd l'm(Z(m)Z)m*Z* dd
l+m,Z, dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m
Z>m?Z?m@Z@ dd lAmBZBmCZCmDZDmEZEmFZF dd
lGmHZH ddlImJZJmKZKmLZLmMZM ddlNmOZO ddlPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZY ddl)mZZZm[Z[m\Z\m]Z] ddl^m_Z_m`Z`maZambZb ddlcmdZd ddlemfZfmgZg ddlhmiZimjZjmkZkmlZlmmZm y ddlnZoW n epk
rT ddlqZoY nX dNZrydd5lsmtZt W n epk
r euZtY nX e jvd6d6d6d7G d8d3 d3ZwewdOd;Zxeiew xe d<ZyeeCezge{f Z|eCeze{d=d>d?Z}G d@d2 d2Z~G dAdB dBeeeeyf eey ZG dCdD dDeeC ZG dEdF dFeeH ZG dGdH dHZddddddd6dIdddJdd6ddeXde)jddddKe{emeee{e{f eeeel eee{ eeS eeee{ ee eee eeem eeS e eweuf eek e[eeJ ee eej edLdMd4ZdS )PzHTTP Client for asyncio. N)suppress)SimpleNamespace
TracebackType)Any AwaitableCallable Coroutine FrozenSet GeneratorGenericIterableListMappingOptionalSetTupleTypeTypeVarUnion) CIMultiDict MultiDictMultiDictProxyistr)URL )hdrshttppayload)AbstractCookieJar)ClientConnectionError ClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLError ClientErrorClientHttpProxyError
ClientOSErrorClientPayloadErrorClientProxyConnectionErrorClientResponseErrorClientSSLErrorContentTypeError
InvalidURLServerConnectionErrorServerDisconnectedErrorServerFingerprintMismatchServerTimeoutErrorTooManyRedirectsWSServerHandshakeError)
ClientRequestClientResponse Fingerprint RequestInfo_merge_ssl_params)ClientWebSocketResponse)
BaseConnectorNamedPipeConnector TCPConnector
UnixConnector) CookieJar) DEBUGPY_36 BasicAuth
TimeoutHandle ceil_timeoutget_env_proxy_for_urlget_running_loopsentinelstrip_auth_from_url)WS_KEY HttpVersionWebSocketReaderWebSocketWriter)WSHandshakeError WSMessage
ws_ext_gen ws_ext_parse)FlowControlDataQueue)Trace TraceConfig)Final JSONEncoder LooseCookies LooseHeadersStrOrURLr r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r8 r: r; r9 r7
ClientSession
ClientTimeoutrequest)
SSLContextT)Z auto_attribsfrozenslotsc @ s> e Zd ZU dZee dZee dZee dZee dS )rW N) __name__
__module__ __qualname__totalr floatconnect sock_read sock_connect rd rd :/usr/local/lib64/python3.6/site-packages/aiohttp/client.pyrW s
< )r_ _RetType)responsebodyreturnc C s. t j|d pd}|dkr*tjdtdd |S )Nencodingzutf-8zAutomatic charset detection will be removed in 3.9, see: https://docs.aiohttp.org/en/stable/client_advanced.html#character-set-detection )
stacklevel)chardetdetectwarningswarnDeprecationWarning)ri rj retrd rd re "_default_fallback_charset_resolver s ru c sX e Zd ZdZedddddddd d
d d d
ddddddddddgZdZdZdddddddej e
e e e
jdddededdddded ee ee eej ee ee eee ee ee e
e e e e e ee e e e e!e"f ee! e e"e#f e e e ee$e% e&e'dd d d Z(e d dd!d"d#Z)e*rZ:e8j9f d6dddddddddddddddd7dd:eeee e!ee! e e ee! ee ee ee2eef ee ee ee e e4e de5f ee ee3 ee4 ee e&e&e d<d?d@Z;ee dAdBdCdDZddEee e+d*dFdKdLZ?ddMee+e+d*dNdOdPZ@ddMee+e+d*dNdQdRZAddMee+e+d*dNdSdTZBee+d*dUdVdWZCddXdYdZZDeEe dXd[d\ZFeEee dXd]d^ZGeEe dXd_d`ZHeEeIe&e&f dXdadbZJeEe dXdcddZKeKjLe ddedfddZKeEejdXdgdhZMeEe#dXdidjZNeEdAdXdkdlZOeEePeQ dXdmdnZReEee dXdodpZSeEedXdqdrZTeEe dXdsdtZUeEe e eVe geWd f f dXdudvZXeEe dXdwdxZYeEe dXdydzZZeEe$e% dXd{d|Z[ddXd}d~Z\ddXddZ]ee e^ ee^ ee_ ddddZ`d dXddZaee e^ ee^ ee_ ddddZb ZcS )rV z/First-class interface for making HTTP requests. _base_url_source_traceback
_connectorrequote_redirect_url_loop _cookie_jar_connector_owner
_default_auth_version_json_serialize_requote_redirect_url_timeout_raise_for_status_auto_decompress
_trust_env_default_headers_skip_auto_headers_request_class_response_class_ws_response_class_trace_configs
_read_bufsizeNTF ) connectorloopcookiesheadersskip_auto_headersauthjson_serialize
request_classresponse_classws_response_classversion
cookie_jarconnector_ownerraise_for_status read_timeout conn_timeouttimeoutauto_decompress trust_envry
trace_configs read_bufsizefallback_charset_resolver)base_urlr r r r r r r r r r r r r r r r r r r ry r r r rk c C s |d kr|d k r|j }t|}|d ks0t|tr8|| _n"t|| _| jj | jksZtd|d krlt|d}|j |k r~td|| _ |j rt
j t j
d| _|
d krt|d}
|
| _|d k r| jj| || _|| _|| _| | _|| _|tkrRt| _|tk r$tjdt dd t j | j|d| _|d k r|t j | j|d | _tjd
t dd n*|| _|tk rjt d |d k r|t d || _ || _!|| _"|| _#|| _$|rt%|}nt% }|| _&|d k rt'd
d |D | _(nt' | _(| | _)|
| _*| | _+|pg | _,x| j,D ]}|j- qW || _.d S )Nz2Only absolute URLs without path part are supported)r z0Session and connector has to use same event loopr z8read_timeout is deprecated, use timeout argument insteadr )rn )r_ )ra z8conn_timeout is deprecated, use timeout argument insteadzGread_timeout and timeout parameters conflict, please setup timeout.readzJconn_timeout and timeout parameters conflict, please setup timeout.connectc s s | ]}t |V qd S )N)r ).0ird rd re H s z)ClientSession.__init__..)/rz rC
isinstancer rv originAssertionErrorr: RuntimeError get_debug traceback
extract_stacksys _getframerw r< r{ update_cookiesrx r| r} r~ r rD DEFAULT_TIMEOUTr rq rr rs attrZevolve
ValueErrorr r r r r r r frozensetr r r r r freezeZ_resolve_charset)selfr r r r r r r r r r r r r r r r r r r r ry r r r real_headers trace_configrd rd re __init__ s
zClientSession.__init__)clsrk c C s t jdj| jtdd d S )Nz6Inheritance class {} from ClientSession is discouragedr )rn )rq rr formatr\ rs )r rd rd re __init_subclass__V s
z ClientSession.__init_subclass__)namevalrk c s2 || j kr tjdj|tdd t j|| d S )Nz8Setting custom ClientSession.{} attribute is discouragedr )rn )ATTRSrq rr r rs super __setattr__)r r r ) __class__rd re r ` s
zClientSession.__setattr__) _warningsrk c C s\ | j sXtrd| i}ni }|jd| tf| | dd}| jd k rL| j|d< | jj| d S )NsourcezUnclosed client session zUnclosed client session)Zclient_sessionmessagesource_traceback)closedr> rr ResourceWarningrw rz call_exception_handler)r r kwargscontextrd rd re __del__j s
zClientSession.__del___RequestContextManager)methodurlr rk c K s t | j||f|S )zPerform HTTP request.)r _request)r r r r rd rd re rX x s zClientSession.request)
str_or_urlrk c C s@ t |}| jd kr|S |j r,|jjds0t| jj|S d S )N/)r rv is_absolutepath
startswithr join)r r r rd rd re
_build_url~ s
zClientSession._build_url
)paramsdatajsonr r r r allow_redirects
max_redirectscompresschunked expect100r read_until_eofproxy
proxy_authr
verify_ssl fingerprint ssl_contextssl
proxy_headerstrace_request_ctxr )r r r r r r r r r r r r r r r r r r r r r r r r r r rk c 3 d sv j rtdt||||}|d k r6|d k r6tdn|d k rNtj| jd}t|
t rn|
d k rnt j
dt d}g } j } j
|} j
|}y j|} W n, tk
r } zt|| W Y d d } ~ X nX t j} |d k rx|D ]}!| jt|! qW |d k r@y t|}W n. tk
r> } zt|| W Y d d } ~ X nX |tkrR j}"n t|tsjt|d}"n|}"t j|"j}#|#j }$|d kr j } fdd j D }%x(|%D ] }&|&j || j ||I d H qW |#j }'y&|' xt!| \} }(| r |(r td | d kr|(} | d kr* j"} |d k rR| d k rRt#j$|krRtd
j%j&| })|d k rt' }*|*j(| |*j&| }+|+r|)j)|+ |d k rt|}n( j*rt+t, t-| \}}W d Q R X j.|| ||| ||)| | | |
| j j/|||' |||%d },yPt0|"j14 I d H . j2d k s,t3 j2j1|,|%|"d I d H }-W d Q I d H R X W n6 t4j5k
r }. zt6d
j7| |.W Y d d }.~.X nX |-j8d k st3|-j9d k st3|-j9j:|'|j; dk| j<|"j=|d ypyJ|,j>|-I d H }/y|/j|-I d H W n t?k
r |/j@ Y nX W n t?k
r> |-j@ Y nX W nb tAk
rZ Y nL tBk
r }. z.|.jCd krt|.t4j5r tD|.jE |.W Y d d }.~.X nX j%j(|/jF|/jG |/jHdkrn|
rnx*|%D ]"}&|&jI|| j |||/I d H qW |d7 }| jJ|/ | r4|| kr4|/j@ tK| d jLtM| |/jHdkrN|/jNt#jOksh|/jHd kr|/jNt#jPkrt#jQ}d }|jRt#jSr|jTt#jS |/jUjRt#jVp|/jUjRt#jW}0|0d krP n|/jX yt|0 jY d}1W n. tk
r } zt|0| W Y d d } ~ X nX |1jZ}2|2d kr&|/j@ tdn|2s6| j[|1}1| j\ |1j\ krZd } |jTt#j$d |1} d }|/jX qP qW W d Q R X |d kr j]}|r|/j^ |$d k r|/j_d k r|/j_j`|$ja n|$ja tM| |/_bx*|%D ]"}&|&jc|| j |||/I d H qW |/S t?k
rp } zN|#j@ |$r2|$ja d }$x*|%D ]"}&|&jd|| j ||| I d H q8W W Y d d } ~ X nX d S ) NzSession is closedz9data and json parameters can not be used at the same time)dumpsz Chunk size is deprecated #1615r )r_ c s g | ]}t ||jd qS ))r )rO Ztrace_config_ctx)r r )r r rd re
s z*ClientSession._request..z.r r )r T)Zuse_maskr
notakeover)r& r) r Zclient_notakeoveri )0r r UPGRADEZ
CONNECTIONZSEC_WEBSOCKET_VERSIONitems
setdefaultbase64 b64encodeosurandomdecodeZSEC_WEBSOCKET_KEYr ZSEC_WEBSOCKET_PROTOCOLZORIGINrL ZSEC_WEBSOCKET_EXTENSIONSr6 rX r r1 r
r r r lowerZSEC_WEBSOCKET_ACCEPThashlibsha1rF digestsplitrM rJ r
r r r r rN rz
set_parserrH rI r r r )*r r r r% r r& r' r( r) r r r r r r r r r r r r r* r default_headerskeyvalueZsec_keyZextstrr" Zr_keymatchr Zresp_protocolsr2 r3 Z
compress_hdrsr! r Z
conn_protor readerwriterrd rd re r, s
zClientSession._ws_connectzCIMultiDict[str])r rk c C sl t | j}|rht|ttfs$t |}t }x<|j D ]0\}}||krR|j|| q4|||< |j| q4W |S )z3Add default headers and transform it to CIMultiDict)r r r r r r r5 r )r r resultZ added_namesrC rD rd rd re r s
z ClientSession._prepare_headers)r )r r r rk c K s t | jtj|fd|i|S )zPerform HTTP GET request.r )r r r r )r r r r rd rd re r s zClientSession.getc K s t | jtj|fd|i|S )z Perform HTTP OPTIONS request.r )r r r Z METH_OPTIONS)r r r r rd rd re options s zClientSession.optionsc K s t | jtj|fd|i|S )zPerform HTTP HEAD request.r )r r r r )r r r r rd rd re head s zClientSession.head)r )r r r rk c K s t | jtj|fd|i|S )zPerform HTTP POST request.r )r r r r )r r r r rd rd re post s zClientSession.postc K s t | jtj|fd|i|S )zPerform HTTP PUT request.r )r r r ZMETH_PUT)r r r r rd rd re put s zClientSession.putc K s t | jtj|fd|i|S )zPerform HTTP PATCH request.r )r r r Z
METH_PATCH)r r r r rd rd re patch s zClientSession.patch)r r rk c K s t | jtj|f|S )z Perform HTTP DELETE request.)r r r Z METH_DELETE)r r r rd rd re delete s zClientSession.delete)rk c s0 | j s,| jdk r&| jr&| jj I dH d| _dS )zMClose underlying connector.
Release all acquired resources.
N)r rx r| r )r rd rd re r s zClientSession.closec C s | j dkp| j jS )z@Is client session closed.
A readonly property.
N)rx r )r rd rd re r s zClientSession.closedc C s | j S )z(Connector instance used for the session.)rx )r rd rd re r s zClientSession.connectorc C s | j S )zThe session cookies.)r{ )r rd rd re r s zClientSession.cookie_jarc C s | j S )z"The session HTTP protocol version.)r~ )r rd rd re r s zClientSession.versionc C s | j S )z)Do URL requoting on redirection handling.)r )r rd rd re ry s z"ClientSession.requote_redirect_url)r rk c C s t jdtdd || _dS )z)Do URL requoting on redirection handling.z=session.requote_redirect_url modification is deprecated #2778r )rn N)rq rr rs r )r r rd rd re ry
s
c C s t jdtdd | jS )zSession's loop.z"client.loop property is deprecatedr )rn )rq rr rs rz )r rd rd re r s zClientSession.loopc C s | j S )zTimeout for the session.)r )r rd rd re r s zClientSession.timeoutc C s | j S )z*The default headers of the client session.)r )r rd rd re r $ s zClientSession.headersc C s | j S )z2Headers for which autogeneration should be skipped)r )r rd rd re r ) s z ClientSession.skip_auto_headersc C s | j S )z2An object that represents HTTP Basic Authorization)r} )r rd rd re r . s zClientSession.authc C s | j S )zJson serializer callable)r )r rd rd re r 3 s z ClientSession.json_serializec C s | j S )z-Should connector be closed on session closing)r| )r rd rd re r 8 s z ClientSession.connector_ownerc C s | j S )zGShould `ClientResponse.raise_for_status()` be called for each response.)r )r rd rd re r = s z ClientSession.raise_for_statusc C s | j S )z7Should the body response be automatically decompressed.)r )r rd rd re r D s z ClientSession.auto_decompressc C s | j S )z
Should proxies information from environment or netrc be trusted.
Information is from HTTP_PROXY / HTTPS_PROXY environment variables
or ~/.netrc file if present.
)r )r rd rd re r I s zClientSession.trust_envc C s | j S )z7A list of TraceConfig instances used for client tracing)r )r rd rd re r S s zClientSession.trace_configsc C s
d| _ dS )zwDetach connector from session without closing the former.
Session is switched to closed state anyway.
N)rx )r rd rd re detachX s zClientSession.detachc C s t dd S )NzUse async with instead) TypeError)r rd rd re __enter___ s zClientSession.__enter__)exc_typeexc_valexc_tbrk c C s d S )Nrd )r rR rS rT rd rd re __exit__b s zClientSession.__exit__c s | S )Nrd )r rd rd re
__aenter__k s zClientSession.__aenter__c s | j I d H d S )N)r )r rR rS rT rd rd re __aexit__n s zClientSession.__aexit__)Ni i i @ i i @ )dr\ r] r^ __doc__r r rw rx r r r2 r3 r7 r
HttpVersion11rD ru r rU r8 r AbstractEventLooprS rT r strr? rR r rG r r r r` objectrW r
rP int_CharsetResolverr r r= r r rq r rX r r r bytesrY r4 r r r r r- r, r r rI rJ rK rL rM rN r propertyr r r r r ry setterr r r r r r r r r r r r r r r rO rQ r r rU rV rW
__classcell__rd rd )r re rV sx _
x x
&
c @ s e Zd ZdZeddef ddddZdddd d
Zeddd d Z dd
ddZ
e e def d
ddZ
e e def d
ddZed
ddZdS )_BaseRequestContextManager_coro_respzasyncio.Future[Any]N)corork c C s
|| _ d S )N)rd )r rf rd rd re r { s z#_BaseRequestContextManager.__init__)argrk c C s | j j|S )N)rd r )r rg rd rd re r ~ s z _BaseRequestContextManager.sendc C s | j j| d S )N)rd throw)r rg rd rd re rh s z _BaseRequestContextManager.throw)rk c C s
| j j S )N)rd r )r rd rd re r s z _BaseRequestContextManager.closec C s | j j }|S )N)rd __await__)r rt rd rd re ri s
z$_BaseRequestContextManager.__await__c C s | j S )N)ri )r rd rd re __iter__ s z#_BaseRequestContextManager.__iter__c s | j I d H | _| jS )N)rd re )r rd rd re rV s z%_BaseRequestContextManager.__aenter__)rd re )r\ r] r^ __slots__r rh r r r rh r r
r ri rj rV rd rd rd re rc w s rc c @ s4 e Zd Zf Zeee ee ee ddddZdS )r N)rR r! tbrk c s | j j d S )N)re r )r rR r! rl rd rd re rW s z _RequestContextManager.__aexit__) r\ r] r^ rk r r r r rW rd rd rd re r s
r c @ s4 e Zd Zf Zeee ee ee ddddZdS )r+ N)rR r! rl rk c s | j j I d H d S )N)re r )r rR r! rl rd rd re rW s z"_WSRequestContextManager.__aexit__) r\ r] r^ rk r r r r rW rd rd rd re r+ s
r+ c @ s^ e Zd ZdZeddef eddddZed d
d Ze e
e e e e e dd d
dZ
dS ) _SessionRequestContextManagerrd re _sessionzasyncio.Future[Any]N)rf r rk c C s || _ d | _|| _d S )N)rd re rn )r rf r rd rd re r s z&_SessionRequestContextManager.__init__)rk c sD y| j I d H | _W n& tk
r8 | jj I d H Y nX | jS d S )N)rd re r rn r )r rd rd re rV s z(_SessionRequestContextManager.__aenter__)rR r! rl rk c s, | j d k st| j j | jj I d H d S )N)re r r rn )r rR r! rl rd rd re rW s
z'_SessionRequestContextManager.__aexit__)rd re rn )r\ r] r^ rk r r3 rV r rV r r r r rW rd rd rd re rm s
rm r F)r r r r r r r r r r r r r r r r r r r r r )r r r r r r r r r r r r r r r r r r r r r r r rk c C sd d}|dkr d}t |dd}t||||||d}t|j| ||||||||| |
| | |
||||d|S )a Constructs and sends a request.
Returns response object.
method - HTTP method
url - request url
params - (optional) Dictionary or bytes to be sent in the query
string of the new request
data - (optional) Dictionary, bytes, or file-like object to
send in the body of the request
json - (optional) Any json compatible python object
headers - (optional) Dictionary of HTTP Headers to send with
the request
cookies - (optional) Dict object to send with the request
auth - (optional) BasicAuth named tuple represent HTTP Basic Auth
auth - aiohttp.helpers.BasicAuth
allow_redirects - (optional) If set to False, do not follow
redirects
version - Request HTTP version.
compress - Set to True if request has to be compressed
with deflate encoding.
chunked - Set to chunk size for chunked transfer encoding.
expect100 - Expect 100-continue response from server.
connector - BaseConnector sub-class instance to support
connection pooling.
read_until_eof - Read response until eof if response
does not have Content-Length header.
loop - Optional event loop.
timeout - Optional ClientTimeout settings structure, 5min
total timeout by default.
Usage::
>>> import aiohttp
>>> resp = await aiohttp.request('GET', 'http://python.org/')
>>> resp
>>> data = await resp.read()
FNT)r Z force_close)r r r r r r )r r r r r r r r r r r r r r r r )r: rV rm r )r r r r r r r r r r r r r r r r r r r r r r r r r rd rd re rX s@ > ) r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r8 r: r; r9 r7 rV rW rX i, )rX r r7 r= r r9 r r rq
contextlibr typesr r typingr r r r r r
r r r
r r r r r r r r Z multidictr r r r Zyarlr r r r r abcr Zclient_exceptionsr r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 Z
client_reqrepr2 r3 r4 r5 r6 Z client_wsr7 r r8 r9 r: r; cookiejarr< Zhelpersr= r> r? r@ rA rB rC rD rE rF rG rH rI Zhttp_websocketrJ rK rL rM streamsrN ZtracingrO rP ZtypedefsrQ rR rS rT rU Zcchardetro ImportErrorZcharset_normalizer__all__r rY r\ srW r rh r_ r[ r^ ru rV rc r r+ rm rY r r] rZ rX rd rd rd re s H T ,
E %~