관리-도구
편집 파일: client.cpython-37.pyc
B �k�a~� � @ 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>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 dZnyddlompZp W n eqk �rX erZpY nX e jsdddd�G dd� d��Ztetd d �Zueiet evd < e d �ZwG d d!� d!�ZxG d"d#� d#eeeewf eew �ZyG d$d%� d%eyeC �ZzG d&d'� d'eyeH �Z{G d(d)� d)�Z|dddddddd*ddd+ddddeXde)j}dddd,�e~emeee~e~f eeeel eee~ eeS ee�ee~ ee eee eeem eeS e eterf eek e[eeJ ee� eej� e|d-�d.d/�Z�dS )0zHTTP Client for asyncio.� N)�suppress)�SimpleNamespace� TracebackType)�Any� Awaitable�Callable� Coroutine� FrozenSet� Generator�Generic�Iterable�List�Mapping�Optional�Set�Tuple�Type�TypeVar�Union)� CIMultiDict� MultiDict�MultiDictProxy�istr)�URL� )�hdrs�http�payload)�AbstractCookieJar)�ClientConnectionError� ClientConnectorCertificateError�ClientConnectorError�ClientConnectorSSLError� ClientError�ClientHttpProxyError� ClientOSError�ClientPayloadError�ClientProxyConnectionError�ClientResponseError�ClientSSLError�ContentTypeError� InvalidURL�ServerConnectionError�ServerDisconnectedError�ServerFingerprintMismatch�ServerTimeoutError�TooManyRedirects�WSServerHandshakeError)� ClientRequest�ClientResponse� Fingerprint� RequestInfo�_merge_ssl_params)�ClientWebSocketResponse)� BaseConnector�NamedPipeConnector� TCPConnector� UnixConnector)� CookieJar) �DEBUG�PY_36� BasicAuth� TimeoutHandle� ceil_timeout�get_env_proxy_for_url�get_running_loop�sentinel�strip_auth_from_url)�WS_KEY� HttpVersion�WebSocketReader�WebSocketWriter)�WSHandshakeError� WSMessage� ws_ext_gen� ws_ext_parse)�FlowControlDataQueue)�Trace� TraceConfig)�Final� JSONEncoder� LooseCookies� LooseHeaders�StrOrURL) 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 � ClientSession� ClientTimeout�request)� SSLContextT)Z auto_attribs�frozen�slotsc @ sN e Zd ZU dZee ed< dZee ed< dZee ed< dZ ee ed< dS )rW N�total�connect� sock_read� sock_connect) �__name__� __module__� __qualname__r\ r �float�__annotations__r] r^ r_ � re re �A/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/client.pyrW � s rW i, )r\ �DEFAULT_TIMEOUT�_RetTypec sX e Zd ZdZedddddddd d d d d ddddddddddg�ZdZd�ddddddeje e e e j dddededddddd �ee ee eej ee ee eee ee eee ee ee eee e e e e e f ee e e e!f e e e ee"e# e$dd �d d �Z%ed dd �d!d"�Z&e'�r4ee(dd#�� fd$d%� Z)e*fe(dd&�d'd(�Z+eee(d)d*�d+d,�Z,ee-d-�d.d/�Z.ddddddddd0dddddddedddddddd1�eeee/eef e(e(ee ee eee ee e e$ee ee e ee e ee ee e e!e f ee ee0 ee1 ee e1e e2f ee ee3 ee$ e d2�d3d4�Z4e5j6d5d6dddddddddddddddd7d8d9�eeee e ee e e ee ee ee ee/eef ee ee ee e e1e de2f ee ee0 ee1 ee e$e$d:d;�d<d=�Z7e5j6d5d6dddddddddddddddd7d8d9�eeee e ee e e ee ee ee ee/eef ee ee ee e e1e de2f ee ee0 ee1 ee e$e$e d;�d>d?�Z8ee d@dA�dBdC�Z9ddD�ee e(d)dE�dFdG�Z:ddD�ee e(d)dE�dHdI�Z;ddD�ee e(d)dE�dJdK�Z<ddL�ee(e(d)dM�dNdO�Z=ddL�ee(e(d)dM�dPdQ�Z>ddL�ee(e(d)dM�dRdS�Z?ee(d)dT�dUdV�Z@ddW�dXdY�ZAeBe dW�dZd[��ZCeBee dW�d\d]��ZDeBe dW�d^d_��ZEeBeFe$e$f dW�d`da��ZGeBe dW�dbdc��ZHeHjIe ddd�dedc��ZHeBejdW�dfdg��ZJeBe e e!f dW�dhdi��ZKeBd@dW�djdk��ZLeBeMeN dW�dldm��ZOeBee dW�dndo��ZPeBedW�dpdq��ZQeBe dW�drds��ZReBe e eSe geTd f f dW�dtdu��ZUeBe dW�dvdw��ZVeBe dW�dxdy��ZWeBe"e# dW�dzd{��ZXddW�d|d}�ZYddW�d~d�ZZeee[ ee[ ee\ dd��d�d��Z]d dW�d�d��Z^eee[ ee[ ee\ dd��d�d��Z_� Z`S )�rV z/First-class interface for making HTTP requests.� _base_url�_source_traceback� _connector�requote_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_bufsizeNTFi )� connector�loop�cookies�headers�skip_auto_headers�auth�json_serialize� request_class�response_class�ws_response_class�version� cookie_jar�connector_owner�raise_for_status� read_timeout� conn_timeout�timeout�auto_decompress� trust_envrl � trace_configs� read_bufsize)�base_urlr r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rl r� r� �returnc C s |d kr|d k r|j }t|�}|d ks0t|t�r8|| _n"t|�| _| j�� | jksZtd��|d krlt|d�}|j |k r~td��|| _ |� � r�t � t � d��| _| d kr�t|d�} | | _|d k r�| j�|� || _|| _|| _| | _|| _|tk�rRt| _|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 ��|| _ || _!|| _"|| _#|| _$|�r�t%|�}nt%� }|| _&|d k �r�t'd d� |D ��| _(nt'� | _(| | _)| | _*| | _+|�p�g | _,x| j,D ]}|�-� �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 instead� )� stacklevel)r\ )r] 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 )�.0�ire re rf � <genexpr>/ s z)ClientSession.__init__.<locals>.<genexpr>).rm rC � isinstancer ri �origin�AssertionErrorr: � RuntimeErrorZ get_debug� traceback� extract_stack�sys� _getframerj r< rn �update_cookiesrk ro rp rq rr rD rg rt �warnings�warn�DeprecationWarning�attrZevolve� ValueErrorru rv rw rs r~ r rx � frozensetry rz r{ r| r} Zfreeze)�selfr� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rl r� r� � real_headers� trace_configre re rf �__init__� s� zClientSession.__init__)�clsr� c C s t jd�| j�tdd� d S )Nz6Inheritance class {} from ClientSession is discouragedr� )r� )r� r� �formatr` r� )r� re re rf �__init_subclass__; s z ClientSession.__init_subclass__)�name�valr� c s2 || j kr tjd�|�tdd� t� �||� d S )Nz8Setting custom ClientSession.{} attribute is discouragedr� )r� )�ATTRSr� r� r� r� �super� __setattr__)r� r� r� )� __class__re rf r� E s zClientSession.__setattr__)� _warningsr� c C s\ | j sXtrd| i}ni }|jd| ��tf|� | dd�}| jd k rL| j|d< | j�|� d S )N�sourcezUnclosed client session zUnclosed client session)Zclient_session�messageZsource_traceback)�closedr> r� �ResourceWarningrj rm Zcall_exception_handler)r� r� �kwargs�contextre re rf �__del__O s zClientSession.__del__�_RequestContextManager)�method�urlr� r� c K s t | j||f|��S )zPerform HTTP request.)r� �_request)r� r� r� r� re re rf rX ] s zClientSession.request)� str_or_urlr� c C s> t |�}| jd kr|S |�� s*|j�d�s.t�| j�|�S d S )N�/)r ri � is_absolute�path� startswithr� �join)r� r� r� re re rf � _build_urlc s zClientSession._build_url� )�params�data�jsonr� r� r� r� �allow_redirects� max_redirects�compress�chunked� expect100r� �read_until_eof�proxy� proxy_authr� � verify_ssl� fingerprint� ssl_context�ssl� proxy_headers�trace_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� r� c 3 � sX � j rtd��t||||�}|d k r6|d k r6td��n|d k rNtj|� jd�}t| t�sl| d k rlt � dt � d}g } � j } � � |�}� � |�}y� �|�} W n, tk r� } zt|�| �W d d } ~ X Y nX t� j�} |d k r�x|D ]}!| �t|!�� q�W |d k �r>y t|�}W n. tk �r< } zt|�| �W d d } ~ X Y nX |tk�rP� j}"n t|t��sht|d�}"n|}"t� j|"j�}#|#�� }$|d k�r�� j }� �fdd�� j D �}%x(|%D ] }&|&� || � |�|�I d H �q�W |#� � }'�y |'��x �xnt!| �\} }(| �r |(�r td ��| d k�r|(} | d k�r(� j"} |d k �rP| d k �rPt#j$|k�rPtd ��� j%�&| �})|d k �r�t'� }*|*�(|� |*�&| �}+|+�r�|)�)|+� |d k �r�t|�}n(� j*�r�t+t,�� t-| �\}}W d Q R X � j.|| ||| ||)| | | | |� j� j/|||'� |||%d �},yPt0|"j1�4 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 �7| ��|.�W d d }.~.X Y nX |-j8d k �s�t3�|-j9d k �s�t3�|-j9j:|'|�;� dk|� j<|"j=|d� ypyJ|,�>|-�I d H }/y|/�|-�I d H W n t?k �r |/�@� � Y nX W n t?k �r< |-�@� � Y nX W nF tAk �rX � Y n0 tBk �r� }. ztC|.jD� |.�W d d }.~.X Y nX � j%�(|/jE|/jF� |/jGdk�rP| �rPx*|%D ]"}&|&�H|| � |�||/�I d H �q�W |d7 }| �I|/� | �r|| k�r|/�@� tJ| d jKtL| ���|/jGdk�r0|/jMt#jNk�sJ|/jGdk�rn|/jMt#jOk�rnt#jP}d }|�Qt#jR��rn|�St#jR� |/jT�Qt#jU��p�|/jT�Qt#jV�}0|0d k�r�P n|/�W� yt|0� jX d�}1W n. tk �r� } zt|0�| �W d d } ~ X Y nX |1jY}2|2dk�r|/�@� td��n|2�s| �Z|1�}1| �[� |1�[� k�r<d } |�St#j$d � |1} d }|/�W� �q�P �q�W W d Q R X |d k�rr� j\}|�r�|/�]� |$d k �r�|/j^d k �r�|/j^�_|$j`� n|$�`� tL| �|/_ax*|%D ]"}&|&�b|| � |�||/�I d H �q�W |/S t?k �rR } zL|#�@� |$�r|$�`� d }$x*|%D ]"}&|&�c|| � |�|| �I d H �qW � W d d } ~ X Y 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 � ||j�d ���qS ))r� )rO Ztrace_config_ctx)r� r� )r� r� re rf � <listcomp>� s z*ClientSession._request.<locals>.<listcomp>z<Cannot combine AUTH argument with credentials encoded in URLzTCannot combine AUTHORIZATION header with AUTH argument or credentials encoded in URL)r� r� r� r� r� r� r� r� r� r� r� r� r� r� �timer�sessionr� r� �traces)r� r� z Connection timeout to host {}ZHEAD)r� Z skip_payloadr� r� r� r� )i- i. i/ i3 i4 r i/ )i- i. )�encoded)r �https� z"Can redirect only to http or https)dr� r� r6 r� r Z JsonPayloadrr r� �boolr� r� r� rq �_prepare_headersr� r+ �setry �addr r rD rt rW r@ rm r\ �startr~ r} Zsend_request_startZ update_queryr� rE rp r Z AUTHORIZATIONrn Zfilter_cookiesr< r� �loadrw r � LookupErrorrB rz r{ rA r] rk r� �asyncio� TimeoutErrorr/ r� � transport�protocolZset_response_params�upperrv r^ �send� BaseException�closer# �OSErrorr% �argsr� r� �statusZsend_request_redirect�appendr0 � request_info�tupler� � METH_HEAD� METH_POST�METH_GET�getZCONTENT_LENGTH�popr� ZLOCATION�URI�releasers �schemer� r� ru r� � connectionZ add_callback�cancelZ_historyZsend_request_endZsend_request_exception)3r� 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� Z redirects�historyr� r� �eZ skip_headersr� Z real_timeout�tm�handler� �tracer� Z auth_from_urlZ all_cookiesZtmp_cookie_jarZ req_cookies�req�conn�exc�respZr_url� parsed_urlr re )r� r� rf r� k sx # & zClientSession._requestre g $@r i @ )r� � protocolsr� �receive_timeout� autoclose�autoping� heartbeatr� r� r� r� r� r� r� r� r� r� r� r� � max_msg_size�_WSRequestContextManager)r� r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r r� c C s8 t | j||||||||| | | | | ||||||||d��S )z Initiate websocket connection.)r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r )r � _ws_connect)r� r� r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r re re rf � ws_connect� s. zClientSession.ws_connectc * � sP | d krt � }nt | �}tjdtjdtjdi}x |�� D ]\}}|�||� q8W t�t � d��}|� � |tj < |r�d� |�|tj< | d k r�| |tj< |r�t|d�}||tj< t||||�}| j||| |d| | |||d� I d H } �y&| jd k�rt| j| jd | j| jd ��| j�tjd ��� dk�r<t| j| jd | j| jd ��| j�tjd ��� dk�rpt| j| jd| j| jd ��| j�tjd �} t�t � |t �� � �� � } | | k�r�t| j| jd| j| jd ��d } |�rtj| jk�rdd� | jtj � d�D �} x | D ]}!|!|k�r�|!} P �q�W d}"|�r�| j�tj�}#|#�r�yt!|#�\}}"W nF t"k �r� }$ z&t| j| j|$j#d | j| jd �|$�W d d }$~$X Y nX nd}d}"| j$}%|%d k �s�t%�|%j&}&|&d k �s�t%�|%j'}'|'d k �s�t%�t(|&d| j)d�}(|&�*t+|(|�|(� t,|&|'d||"d�})W n t-k �r& | �.� � Y n&X | j/|(|)| | |||| j)||||"d� S d S )NZ websocketZupgradeZ13� �,)r� F)r� r� r� r� r� r� r� r� �e zInvalid response status)r� r� r� r� zInvalid upgrade headerzInvalid connection headerzInvalid challenge responsec S s g | ] }|� � �qS re )�strip)r� �protore re rf r� B s z-ClientSession._ws_connect.<locals>.<listcomp>r i )r� T)Zuse_maskr� � notakeover)r r r� Zclient_notakeover)0r r ZUPGRADEZ CONNECTIONZSEC_WEBSOCKET_VERSION�items� setdefault�base64� b64encode�os�urandom�decodeZSEC_WEBSOCKET_KEYr� ZSEC_WEBSOCKET_PROTOCOLZORIGINrL ZSEC_WEBSOCKET_EXTENSIONSr6 rX r� r1 r� r r� r� �lowerZSEC_WEBSOCKET_ACCEPT�hashlib�sha1rF �digest�splitrM rJ r� r r� r� r� rN rm Z 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� Zdefault_headers�key�valueZsec_keyZextstrr Zr_key�matchr� Zresp_protocolsr r Z compress_hdrsr r Z conn_protor� �reader�writerre re rf r � s� zClientSession._ws_connectzCIMultiDict[str])r� r� c C sl t | j�}|rht|ttf�s$t |�}t� }x<|�� D ]0\}}||krR|�||� q4|||< |�|� q4W |S )z3Add default headers and transform it to CIMultiDict)r rx r� r r r� r r� )r� r� �resultZ added_namesr( r) re re rf r� � s z ClientSession._prepare_headers)r� )r� r� r� r� c K s t | jtj|fd|i|���S )zPerform HTTP GET request.r� )r� r� r r� )r� r� r� r� re re rf 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� re re rf �options� s zClientSession.optionsc K s t | jtj|fd|i|���S )zPerform HTTP HEAD request.r� )r� r� r r� )r� r� r� r� re re rf �head� s zClientSession.head)r� )r� r� r� r� c K s t | jtj|fd|i|���S )zPerform HTTP POST request.r� )r� r� r r� )r� r� r� r� re re rf �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� re re rf �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� re re rf �patch� s zClientSession.patch)r� r� r� c K s t | jtj|f|��S )z Perform HTTP DELETE request.)r� r� r Z METH_DELETE)r� r� r� re re rf �delete� s zClientSession.delete)r� c � s0 | j s,| jdk r&| jr&| j�� I dH d| _dS )zMClose underlying connector. Release all acquired resources. N)r� rk ro r� )r� re re rf r� � s zClientSession.closec C s | j dkp| j jS )z@Is client session closed. A readonly property. N)rk r� )r� re re rf r� � s zClientSession.closedc C s | j S )z(Connector instance used for the session.)rk )r� re re rf r � s zClientSession.connectorc C s | j S )zThe session cookies.)rn )r� re re rf r� � s zClientSession.cookie_jarc C s | j S )z"The session HTTP protocol version.)rq )r� re re rf r� � s zClientSession.versionc C s | j S )z)Do URL requoting on redirection handling.)rs )r� re re rf rl � s z"ClientSession.requote_redirect_url)r� r� c C s t jdtdd� || _dS )z)Do URL requoting on redirection handling.z=session.requote_redirect_url modification is deprecated #2778r� )r� N)r� r� r� rs )r� r� re re rf rl � s c C s t jdtdd� | jS )zSession's loop.z"client.loop property is deprecatedr� )r� )r� r� r� rm )r� re re rf r� � s zClientSession.loopc C s | j S )zTimeout for the session.)rt )r� re re rf r� s zClientSession.timeoutc C s | j S )z*The default headers of the client session.)rx )r� re re rf r� s zClientSession.headersc C s | j S )z2Headers for which autogeneration should be skipped)ry )r� re re rf r� s z ClientSession.skip_auto_headersc C s | j S )z2An object that represents HTTP Basic Authorization)rp )r� re re rf r� s zClientSession.authc C s | j S )zJson serializer callable)rr )r� re re rf r� s z ClientSession.json_serializec C s | j S )z-Should connector be closed on session closing)ro )r� re re rf r� s z ClientSession.connector_ownerc C s | j S )zGShould `ClientResponse.raise_for_status()` be called for each response.)ru )r� re re rf r� s z ClientSession.raise_for_statusc C s | j S )z7Should the body response be automatically decompressed.)rv )r� re re rf r� ' 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. )rw )r� re re rf r� , s zClientSession.trust_envc C s | j S )z7A list of TraceConfig instances used for client tracing)r} )r� re re rf r� 6 s zClientSession.trace_configsc C s d| _ dS )zwDetach connector from session without closing the former. Session is switched to closed state anyway. N)rk )r� re re rf �detach; s zClientSession.detachc C s t d��d S )NzUse async with instead)� TypeError)r� re re rf � __enter__B s zClientSession.__enter__)�exc_type�exc_val�exc_tbr� c C s d S )Nre )r� r7 r8 r9 re re rf �__exit__E s zClientSession.__exit__c � s | S )Nre )r� re re rf � __aenter__N s zClientSession.__aenter__c � s | � � I d H d S )N)r� )r� r7 r8 r9 re re rf � __aexit__Q s zClientSession.__aexit__)N)ar` ra rb �__doc__r� r� rj r� r� r2 r3 r7 r � HttpVersion11rD r rU r8 r� �AbstractEventLooprS rT r �strr? rR r rG r r� r rc �objectrW r rP �intr� r� r= r r� r� r� rX r r� r �bytesrY r4 r r� r r� r r r� r� r. r/ r0 r1 r2 r3 r� �propertyr� r r� r r� rl �setterr� r� r� r r r� r� r� r� r r r� r� r� r� r4 r6 r� r r: r; r< � __classcell__re re )r� rf rV � st �] � x x & rV c @ s� e Zd ZdZeddef dd�dd�Zddd�dd �Zedd�d d �Z dd �d d�Z e e def d �dd�Z e e def d �dd�Zed �dd�ZdS )�_BaseRequestContextManager)�_coro�_respzasyncio.Future[Any]N)�coror� c C s || _ d S )N)rH )r� rJ re re rf r� ^ s z#_BaseRequestContextManager.__init__)�argr� c C s | j �|�S )N)rH r� )r� rK re re rf r� a s z _BaseRequestContextManager.sendc C s | j �|� d S )N)rH �throw)r� rK re re rf rL d s z _BaseRequestContextManager.throw)r� c C s | j �� S )N)rH r� )r� re re rf r� g s z _BaseRequestContextManager.closec C s | j �� }|S )N)rH � __await__)r� �retre re rf rM j s z$_BaseRequestContextManager.__await__c C s | � � S )N)rM )r� re re rf �__iter__n s z#_BaseRequestContextManager.__iter__c � s | j I d H | _| jS )N)rH rI )r� re re rf r; q s z%_BaseRequestContextManager.__aenter__)r` ra rb � __slots__r rh r� r� r� rL r� r r rM rO r; re re re rf rG Z s rG c @ s4 e Zd ZdZeee ee ee dd�dd�ZdS )r� re N)r7 r �tbr� c � s | j �� d S )N)rI r� )r� r7 r rQ re re rf r< y s z _RequestContextManager.__aexit__) r` ra rb rP r r r� r r< re re re rf r� v s r� c @ s4 e Zd ZdZeee ee ee dd�dd�ZdS )r re N)r7 r rQ r� c � s | j �� I d H d S )N)rI r� )r� r7 r rQ re re rf r< � s z"_WSRequestContextManager.__aexit__) r` ra rb rP r r r� r r< re re re rf r � s r c @ s^ e Zd ZdZeddef edd�dd�Zed�dd �Ze e e e e e e dd �d d �Z dS ) � _SessionRequestContextManager)rH rI �_sessionzasyncio.Future[Any]N)rJ r� r� c C s || _ d | _|| _d S )N)rH rI rS )r� rJ r� re re rf r� � s z&_SessionRequestContextManager.__init__)r� c � sD y| j I d H | _W n& tk r8 | j�� I d H � Y nX | jS d S )N)rH rI r� rS r� )r� re re rf r; � s z(_SessionRequestContextManager.__aenter__)r7 r rQ r� c � s, | j d k st�| j �� | j�� I d H d S )N)rI r� r� rS )r� r7 r rQ re re rf r< � s z'_SessionRequestContextManager.__aexit__)r` ra rb rP r r3 rV r� r; r r r� r r< re re re rf rR � s rR 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� r� 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 <ClientResponse(python.org/) [200]> >>> 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 rR 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� re re rf rX � s@ > rX )�r= r� r r$ r� r r� r� r� � 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; Z cookiejarr< Zhelpersr= r> r? r@ rA rB rC rD rE rF rG rH rI Zhttp_websocketrJ rK rL rM ZstreamsrN �tracingrO rP ZtypedefsrQ rR rS rT rU �__all__r� rY � ImportErrorrA �srW rg rd rh rV rG r� r rR r> r@ r� rB r? rX re re re rf �<module> s� H T , & = %~