Ë
|
¸^iÖ ã ó^ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
|
Z
|
d dl m Z m Z mZ d dlmZmZ d dlmZmZ d dlmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z! d dl"Z"d dl#m$Z$m%Z%m&Z&m'Z' d dl(m)Z) d d
|
l*m+Z+m,Z,m-Z-m.Z.m/Z/ d d l0m1Z1m2Z2m3Z3 d d l4m5Z5 d d l6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z< d dl=m>Z>m?Z? d dl@mAZA d dl,mBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZK d dl-mLZLmMZMmNZNmOZOmPZP d dlQmRZR d dlSmTZTmUZUmVZVmWZWmXZXmYZY er d dlZZZd dlZm[Z[ n d dlZZZd dlZm[Z[ dZ^erd dl_m`Z` d dlambZb d dlcmdZd e7d« Ze ejÌ d« Zg ejÌ d« Zhd eifd Zj e"jÖ d d d ¬ « G d d!« « Zl G d" d#e « Zm G d$ d%em« Zn G d& d'« ZoeZeZj¶ epeo eqd« fZrn
|
ep eqd« fZrd(e!d)epeof d*e ep d+e d) d,e es d e!d)epeof f
|
d-Zt eud.« Zv G d/ d0e « Zwd1eid2eid epfd3Zxd;d4e/jò d5ezd dfd6Z{ G d7 d8eE« Z| G d9 d:« Z}y# e\$ r dZZe]Z[Y $w xY w)<é N)ÚMapping)Úmd5Úsha1Úsha256)ÚMorselÚ SimpleCookie)ÚMappingProxyTypeÚ TracebackType) Ú TYPE_CHECKINGÚAnyÚCallableÚDictÚIterableÚListÚLiteralÚ
|
NamedTupleÚOptionalÚTupleÚTypeÚUnion)Ú CIMultiDictÚCIMultiDictProxyÚ MultiDictÚMultiDictProxy)ÚURLé )ÚhdrsÚhelpersÚhttpÚ multipartÚpayload)Úparse_cookie_headerÚparse_set_cookie_headersÚ preserve_morsel_with_coded_value)ÚAbstractStreamWriter)ÚClientConnectionErrorÚ ClientOSErrorÚClientResponseErrorÚContentTypeErrorÚ
|
InvalidURLÚServerFingerprintMismatch)Ú
|
HAS_BROTLIÚHAS_ZSTD)ÚFormData)
|
Ú _SENTINELÚBaseTimerContextÚ BasicAuthÚ HeadersMixinÚ TimerNoopÚnoopÚreifyÚsentinelÚ set_exceptionÚ
|
set_result)ÚSERVER_SOFTWAREÚ HttpVersionÚ HttpVersion10Ú HttpVersion11Ú StreamWriter)Ú StreamReader)ÚDEFAULT_JSON_DECODERÚ JSONDecoderÚ LooseCookiesÚ LooseHeadersÚQueryÚ
|
RawHeaders)Ú
|
SSLContext)Ú ClientRequestÚClientResponseÚ RequestInfoÚ Fingerprint)Ú ClientSession)Ú
|
Connection)ÚTraceúConnection closedz[^-!#$%&'*+.^_`|~0-9a-zA-Z]z!^application/(?:[\w.+-]+?\+)?jsonÚreturnc ó ddg} t r| j d« t r| j d« dj | « S )NÚgzipÚdeflateÚbrÚzstdú, )r, Úappendr- Újoin)Ú encodingss õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/client_reqrep.pyÚ _gen_default_accept_encodingrY i sB àØðIõ Ø×ÑÔ ÝØ×ÑÔ Ø 99YÓ Ð ó T)Ú auto_attribsÚfrozenÚslotsc ó8 e Zd ZU ee ed< ded< ee ed< y)ÚContentDispositionÚtypezMappingProxyType[str, str]Ú
|
parametersÚfilenameN)Ú__name__Ú
|
__module__Ú __qualname__r ÚstrÚ__annotations__© rZ rX r_ r_ u s
à
|
3-ÓØ,Ó,ØsmÔrZ r_ c ó6 e Zd ZU eed< eed< ded< eed< y)Ú _RequestInfoÚurlÚmethodúCIMultiDictProxy[str]ÚheadersÚreal_urlN)rc rd re r rg rf rh rZ rX rj rj | s
Ø HØ KØ $Ó$ØMrZ rj c ó6 e Zd Zefdededddeeef dd f
|
dZy) rH rk rl rn rm ro rN c óT t j | ||||t u r|f« S |f« S )zuCreate a new RequestInfo instance.
|
|
For backwards compatibility, the real_url parameter is optional.
|
)ÚtupleÚ__new__r6 )Úclsrk rl rn ro s rX rs zRequestInfo.__new__
s: ô }}Ø #vw¨x¼8Ñ/C¨ÐRó
|
ð
|
ØIQÐRó
|
ð
|
rZ N) rc rd re r6 r rf r r/ rs rh rZ rX rH rH sE ð +3ñ
|
à ð
|
ð ð
|
ð )ð
|
ð
|
YÑ'ð
|
ð
|
ô
|
rZ rH c ób e Zd ZeeedZdeddfdZe defd« Z
|
de j ddfdZ y) rI )é é é Ú fingerprintrN Nc ó¼ t |« }| j j |« }|s t d« |t u s|t
|
u r t d« || _ || _ y )Nz fingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)ÚlenÚHASHFUNC_BY_DIGESTLENÚgetÚ
|
ValueErrorr r Ú _hashfuncÚ _fingerprint)Úselfry Ú digestlenÚhashfuncs rX Ú__init__zFingerprint.__init__ sZ Ü Ó$ Ø×-Ñ-×1Ñ1°)Ó<ÙÜ Ð =Ó>Ð >Ø _ ¬DÑ 0Ü Ð WÓXÐ XØ!Ø 'ÕrZ c ó | j S ©N)r ©r s rX ry zFingerprint.fingerprint¦ ó à× Ñ Ð rZ Ú transportc ó" |j d« sy |j d« }|j d¬« }| j |« j « }|| j k7 r,|j d« ^}}}t | j |||« y )NÚ
|
sslcontextÚ
|
ssl_objectT)Ú binary_formÚpeername)Úget_extra_infoÚ getpeercertr Údigestr r+ )r r ÚsslobjÚcertÚgotÚhostÚportÚ_s rX ÚcheckzFingerprint.checkª s Ø×'Ñ'¨ Ô5Ø Ø×)Ñ)¨,Ó7Ø×!Ñ!¨dÐ!Ó3ØnnTÓ"×)Ñ)Ó+Ø $×#Ñ#Ò #Ø &× 5Ñ 5°jÓ AND$Ü+¨D×,=Ñ,=¸sÀDÈ$ÓOÐ Oð $rZ )rc rd re r r r r| Úbytesr Úpropertyry ÚasyncioÚ Transportr rh rZ rX rI rI s] à Ø Ø ñ Ðð ( Eð (¨dó (ð ð!Uò !ó ð!ðPw× 0Ñ 0ð P°Tô PrZ rI ÚsslrE Ú
|
verify_sslÚ ssl_contextry c ó | d} |/|s-t j dt d¬« | dur t d« d} |-t j dt d¬« | dur t d« |} |6t j dt d¬« | dur t d« t |« } t | t « st d j | « « | S )
|
NTz/verify_ssl is deprecated, use ssl=False insteadé ©Ú
|
stacklevelzNverify_ssl, ssl_context, fingerprint and ssl parameters are mutually exclusiveFz2ssl_context is deprecated, use ssl=context insteadzCfingerprint is deprecated, use ssl=Fingerprint(fingerprint) insteadzFssl should be SSLContext, bool, Fingerprint or None, got {!r} instead.) ÚwarningsÚwarnÚDeprecationWarningr~ rI Ú
|
isinstanceÚSSL_ALLOWED_TYPESÚ TypeErrorÚformat)r r r ry s rX Ú_merge_ssl_paramsr« » sù ð {ØØÐ ¡jÜ Ø =Ü Øõ
|
ð
|
d?Ü ð4óð ð
|
CØÐ Ü Ø @Ü Øõ
|
ð
|
d?Ü ð4óð ð
|
CØÐ Ü Ø QÜ Øõ
|
ð
|
d?Ü ð4óð ô
|
kÓ*CÜ cÔ,Ô -Üð ß &¡ s£ ó
|
ð
|
ð JrZ )ÚhttpsÚwssc óx e Zd ZU eed< ee ed< eed< ee ee
|
f ed< ee ed< ee ed< ee ed< y) Ú ConnectionKeyr r Úis_sslr ÚproxyÚ
|
proxy_authÚproxy_headers_hashN) rc rd re rf rg r ÚintÚboolr rE rI r r1 rh rZ rX r¯ r¯ ø sI
ð IØ
|
3-ÓØ LØ z4 Ð,Ñ -Ó-Ø C=ÓØÑ#Ó#Ø Ô%rZ r¯ Úresponse_content_typeÚexpected_content_typec óB |dk( rt j | « d uS || v S )Núapplication/json)Újson_reÚmatch)r¶ r· s rX Ú_is_expected_content_typer¼ s. ð Ð 2Ò2Ü}}Ð 2Ó3¸4Ð?Ð?Ø Ð$9Ð 9Ð9rZ r! r£ c óp | j s*| j s t j dt |¬« yyy)zöWarn if the payload is not closed.
|
|
Callers must check that the body is a Payload before calling this method.
|
|
Args:
|
payload: The payload to check
|
stacklevel: Stack level for the warning (default 2 for direct callers)
|
z¬The previous request body contains unclosed resources. Use await request.update_body() instead of setting request.body directly to properly close resources and avoid leaks.r¢ N)Ú autocloseÚconsumedr¤ r¥ ÚResourceWarning)r! r£ s rX Ú_warn_if_unclosed_payloadrÁ s7 ð × Ò W×%5Ò%5Ü ð Dô Ø!ö
|
ð &6Ð rZ c ó e Zd ZU dZee ed< dZeed< dZ ee
|
ed< dZ e ed< dZ ee ed< dZee
|
ed< dZed ed
|
< dZeed < dZed ed < dZee ed< dZeee
|
df ed< dZed ed< dZeej8 ed< dZ ed ed< dZ dZ dZ d Z!e"d ege
|
f ed< dZ#ed ed< d e
|
d e$d d d ed d!e%d"e&d#e'd$ d%e(jR d&dd'dfd(Z*dYd)e+d'dfd*Z,e-d'ed fd+« Z.e.j^ d ed d'dfd,« Z.e-d'efd-« Z0e0j^ d.ed'dfd/« Z0e1d'e$fd0« Z2e1d'e$fd1« Z3e1d'e$fd2« Z4e1d'e
|
fd3« Z5e1dZd4« Z6e1d'efd5« Z7e1d'e&fd6« Z8e1d'ee9 fd7« Z:e;fd8e<d'dfd9Z=d'e
|
fd:Z>e-d'ed fd;« Z?e1d'ed fd<« Z@e1d[d=« ZAd\d>ZBd]d?ZCe-d'eDfd@« ZEd]dAZFd'e<fdBZGe-d'eDfdC« ZHd]dDZId]dEZJd]dFZKd]dGZLd]dHZMd]dIZNd'efdJZOd'e
|
fdKZPd^dLee
|
dMe
|
d'e
|
fdNZQdeRdOdPdLee
|
dQeSdRee
|
d'e<fdSZTd_dTZUdUeeVeW dVeeW dWeeX d'dfdXZYy)`rG NÚversionÚstatusÚreasonÚcontentÚ_bodyÚ_headersrh )rG .Ú_historyÚ _raw_headersrK Ú _connectionÚ_cookies.Ú_raw_cookie_headerszasyncio.Future[bool]Ú _continueÚ_source_tracebackrJ Ú_sessionTFc ó y)Núutf-8rh )r s rX ú<lambda>zClientResponse.<lambda>; s rZ Ú_resolve_charsetúasyncio.Task[None]Ú_ClientResponse__writerrl rk Úwriterz Optional[asyncio.Task[None]]Ú continue100ÚtimerÚ request_infoÚtracesrL ÚloopÚsessionrN c óÀ t |« t u sJ || _ || _ |j r|j d « n|| _ ||| _ ||| _ || _ ||n t « | _ i | _ || _ || _ | | | _ | j | _ |j# « r.t% j& t) j* d« « | _ y y )Nr )r` r rl Ú _real_urlÚ raw_fragmentÚ with_fragmentÚ_urlÚ_writerrÎ Ú _request_infor3 Ú_timerÚ_cacheÚ_tracesÚ_looprÐ rÔ Ú get_debugÚ tracebackÚ extract_stackÚsysÚ _getframerÏ )
|
r rl rk r× rØ rÙ rÚ rÛ rÜ rÝ s
|
rX r zClientResponse.__init__? sÏ ô CyCÑ Ð Ð à à Ø/2×/?Ò/?C×%Ñ% dÔ+ÀS Ø Ð Ø!DLØ Ð "Ø (DNØ )ÔØ $Ð 0e´i³k Ø&( Ø Ø
|
ð Ð à #DMØ$+×$<Ñ$<DÔ !Ø >>Ô Ü%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NDÕ "ð rZ r c ó d | _ y r ©rÖ ©r r s rX Ú__reset_writerz ClientResponse.__reset_writerf ó Ø rZ c ó | j S )zThe writer task for streaming data.
|
|
_writer is only provided for backwards compatibility
|
for subclasses that may need to access it.
|
rï r s rX rã zClientResponse._writeri s ð }}Ð rZ c óà | j %| j j | j « || _ |y|j « rd| _ y|j | j « y)z'Set the writer task for streaming data.N)rÖ Úremove_done_callbackÚ _ClientResponse__reset_writerÚdoneÚadd_done_callback©r r× s rX rã zClientResponse._writerr sY ð ==Ð $Ø MM× .Ñ .¨t×/BÑ/BÔ CØ Ø >Ø Ø ;;=à DMà × $Ñ $ T×%8Ñ%8Õ 9rZ c óê | j \| j At « }|j t | j « « || _ | j S t « | _ | j S r )rÌ rÍ r Úupdater# ©r Úcookiess rX rý zClientResponse.cookies sa à ==Ð Ø×'Ñ'Ð3ä&.ð Ô 7¸×8PÑ8PÓ QÔRØ ' ð }}Ð ô !-£ Ø}}Ð rZ rý c óp || _ |r&t d |j « D « « | _ y d | _ y )Nc 3 ó< K | ] }|j « y wr )Ú OutputString)Ú.0Úmorsels rX ú <genexpr>z)ClientResponse.cookies.<locals>.<genexpr> s è ø ò -Ø*0×#Ñ#×%ñ-ùs )rÌ rr ÚvaluesrÍ rü s rX rý zClientResponse.cookies s7 à á Ü',ñ -Ø4;·N±NÓ4Dô-ó (DÕ $ð (,DÕ $rZ c ó | j S r )râ r s rX rk zClientResponse.url ó àyyÐrZ c óR t j dt d¬« | j S )NzDeprecated, use .url #1654é r¢ )r¤ r¥ r¦ râ r s rX Úurl_objzClientResponse.url_obj s ä Ð2Ô4FÐSTÕUØyyÐrZ c ó | j S r )rß r s rX ro zClientResponse.real_url¢ s à~~Ð rZ c ó^ | j j J | j j S r )râ r r s rX r zClientResponse.host¦ s$ àyy~~Ð)Ð)Ð)Øyy~~Ð rZ c ó | j S r )rÈ r s rX rn zClientResponse.headers« ó à}}Ð rZ c ó | j S r )rÊ r s rX Ú raw_headerszClientResponse.raw_headers¯ r rZ c ó | j S r )rä r s rX rÚ zClientResponse.request_info³ s à×!Ñ!Ð!rZ c óä | j j t j « }|y t j
|
|« \ }}t |« }t j |« }t |||« S r ) rÈ r} r ÚCONTENT_DISPOSITIONr Úparse_content_dispositionr Ú content_disposition_filenamer_ )r ÚrawÚdisposition_typeÚ
|
params_dctÚparamsrb s rX Úcontent_dispositionz"ClientResponse.content_disposition· sd àmm× Ñ ¤× 8Ñ 8Ó9Ø ;ØÜ'0×'JÑ'JÈ3Ó'OÑ$Ð*Ü! *Ó-Ü ×9Ñ9¸&ÓAÜ!Ð"2°F¸HÓEÐErZ Ú _warningsc óv | j ry | j | j j « | j « | j j « r[d| i} |j d| t fi |¤ | dd}| j r| j |d< | j j |« y y y )NÚsourcezUnclosed response zUnclosed response)Úclient_responseÚmessageÚsource_traceback)
|
Ú_closedrË ÚreleaseÚ_cleanup_writerrè ré r¥ rÀ rÏ Úcall_exception_handler)r r ÚkwargsÚcontexts rX Ú__del__zClientResponse.__del__Á s¯ Ø <<Ø à × Ñ Ð 'Ø × Ñ × $Ñ $Ô &Ø × Ñ Ô "àzz×#Ñ#Ô%Ø" DÐ)Ø Ð!3°D°8Ð <¼oÑXÐQWÒXØ.2Ð?RÑSØ×)Ò)Ø26×2HÑ2HGÐ .Ñ/Ø
|
|
×1Ñ1°'Õ:ð &ð (rZ c óf t j « }t | j « }| j r,| j j dd« j d« }nd}t dj || j |« |¬« t | j |¬« |j « S )NÚasciiÚbackslashreplaceÚNonez <ClientResponse({}) [{} {}]>)Úfile) ÚioÚStringIOrf rk rÅ ÚencodeÚdecodeÚprintrª rÄ rn Úgetvalue)r ÚoutÚascii_encodable_urlÚascii_encodable_reasons rX Ú__repr__zClientResponse.__repr__Ñ s ÜkkmÜ ! $§(¡(mÐØ ;;Ø%)§[¡[×%7Ñ%7ØÐ+ó&çfWoñ #ð &,Ð "Ü Ø *× 1Ñ 1Ø# T§[¡[Ð2Hó ð õ
|
ô dll Õ%Ø||~Ð rZ c ó | j S r )rË r s rX Ú
|
connectionzClientResponse.connectionã s à× Ñ Ð rZ c ó | j S )z2A sequence of of responses, if redirects occurred.)rÉ r s rX ÚhistoryzClientResponse.historyç s ð }}Ð rZ c óú dj | j j dg « « }|st t « « S t « }t j d|« D ] }t j d|« }| |j « \ }}|j d« dd }t « }|D ]Q } t j d| t
|
j « }|+|j « \ }
|
} } } |j |
|
| « S |j d|« }
|
|j d | j j t |« « « |j t |
|
« t |« « t |« S )
|
NrT Úlinkz ,(?=\s*<)z \s*<(.*)>(.*)ú;r z%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$Úrelrk )rV rn Úgetallr r ÚreÚsplitr» ÚgroupsÚMÚaddr} rk r rf ) r Ú links_strÚlinksÚvalr» rk Ú
|
params_strr r; ÚparamÚkeyr Úvalues rX rE zClientResponse.linksì s@ àIIdll× 1Ñ 1°&¸"Ó =Ó> áÜ!¤)£+Ó.Ð .ä<E»Kä88L¨)Ó4ó 6CÜHHÐ -¨sÓ3EØ}àØ #llnOCØ ×%Ñ% cÓ*¨1¨2Ð.Fä/8«{Dà ò %ÜÐ!IÈ5ÔRT×RVÑRVÓWØ=à Ø#(§<¡<£>Ñ QqàeÕ$ð %ð ((5 #Ó&Cà HHUDHHMM¬#¨c«(Ó 3Ô 4à IIc#h¤¨tÓ 4Ö 5ð/ 6ô2 eÓ$Ð$rZ c ó¾ K d| _ |j | _ || _ | j 5 | j }|j « d{ \ }}|j dk s |j dkD s|j dk( rn*| j t | j d« d| _ ddd« j | j" « j$ | _ |j | _ |j( | _ |j | _ |j, | _ || _ | j j3 t4 j6 d« x}rt9 |« | _ | S 7 # t j $ rH}t | j | j |j |j |j ¬« |d}~ww xY w# 1 sw Y !xY ww) zStart response processing.FTN©rÄ r rn éd éÇ ée rh ) r ÚprotocolÚ _protocolrË rå Úreadr ÚHttpProcessingErrorr( rÚ r9 Úcoder rn rÎ r8 Úon_eofÚ _response_eofrà rÄ rÅ rÈ r rÊ rÆ r> r Ú
|
SET_COOKIErr rÍ )r r7 rP r r! ÚexcÚ cookie_hdrss rX ÚstartzClientResponse.start s è ø à Ø#×,Ñ,Ø%Ôà [[ñ *Øð
|
Ø #~~HØ-5¯]©]«_×'<Ñ$GWð << #Ò%¨¯ © ¸Ò);¸w¿|¹|ÈsÒ?RØà>>Ð-Ü t~~¨tÔ4Ø%)DNð' ð ÷! *ð. t×)Ñ)Ô*ð Ø ll Ø nn ð Ø #× /Ñ /Ôð ð ,,×-Ñ-¬d¯o©o¸rÓBÐ B;Ð Bä',¨[Ó'9DÔ $Ø ðI (=úÜ×/Ñ/ò Ü-Ø ×)Ñ)Ø Ø "xxØ #§ ¡ Ø #§ ¡ ô ð ð ûð ú÷ *ñ *üsT ,G ®G± E2ÁE/ÁE2ÁAGÂ1B>G Å/E2Å2G ÆAGÇG Ç GÇGÇG c óÒ | j ry | j xr | j j }| |j ry d| _ | j « | j « y ©NT)r rË rP Úupgradedr" Ú_release_connection)r rP s rX rV z ClientResponse._response_eofA sZ Ø <<Ø ð ×#Ñ#ÒA¨×(8Ñ(8×(AÑ(AØ Ð H×$5Ò$5Ø à Ø × Ñ Ô Ø × Ñ Õ"rZ c ó | j S r )r r s rX ÚclosedzClientResponse.closedN s à||ÐrZ c ó | j s| j « d| _ | j | j j « ry | j « | j "| j j « d | _ y y r\ )Ú _releasedÚ_notify_contentr rè Ú is_closedr" rË Úcloser s rX re zClientResponse.closeR so Ø~~Ø × Ñ Ô "à Ø ::Ð §¡×!5Ñ!5Ô!7Ø à × Ñ Ô Ø × Ñ Ð 'Ø × Ñ × "Ñ "Ô $Ø #DÕ ð (rZ c ó | j s| j « d| _ | j « | j « t « S r\ )rb rc r r" r^ r4 r s rX r! zClientResponse.release_ s; Ø~~Ø × Ñ Ô "à à × Ñ Ô Ø × Ñ Ô"Üv rZ c ó d| j kD S )zºReturns ``True`` if ``status`` is less than ``400``, ``False`` if not.
|
|
This is **not** a check for ``200 OK`` but a check that the response
|
status is under 400.
|
i )rÄ r s rX ÚokzClientResponse.oki s ð T[[Ñ Ð rZ c óô | j sl| j J | j s| j « t | j
|
| j | j | j | j ¬« y )NrL ) rh rÅ Ú _in_contextr! r( rÚ r9 rÄ rn r s rX Úraise_for_statusz ClientResponse.raise_for_statusr sd Øwwà;;Ð*Ð *Ð*ð ×#Ò#Ø ä%Ø×!Ñ!Ø Ø{{Ø Ø ô ð ð rZ c ó¸ j M j " j j « d _ y j j fd« y y )Nc ó$ j « S r )r^ )Úfr s rX rÓ z4ClientResponse._release_connection.<locals>.<lambda> s ø ¸$×:RÑ:RÓ:T rZ )rË rÖ r! rø r s `rX r^ z"ClientResponse._release_connection sK ø Ø × Ñ Ð 'Ø}}Ð$Ø× Ñ ×(Ñ(Ô*Ø#'Õ à ×/Ñ/Ó0TÕUð (rZ c ó K | j | j d { | j « y 7 # t j $ r= t j dk\ r't j
|
« x}r|j « r Y bw xY ww©N)r¡ é )rÖ r ÚCancelledErrorrì Ú version_infoÚ current_taskÚ
|
cancellingr^ ©r Útasks rX Ú_wait_releasedz ClientResponse._wait_released sy è ø Ø ==Ð $ð Ømm×#Ð#ð × Ñ Õ"ð $ùÜ×)Ñ)ò ä×$Ñ$¨Ò/Ü!(×!5Ñ!5Ó!7Ð7Ð7Ø Ô)àùð üó2 B
|
7 5 7 ¤B
|
µ7 ·A BÂB
|
ÂBÂB
|
c ó^ | j | j j « d | _ y r )rÖ ÚcancelrÐ r s rX r" z ClientResponse._cleanup_writer s# Ø ==Ð $Ø MM× Ñ Ô "Ø rZ c ón | j }|r |j « t |t « d| _ y r\ )rÆ Ú exceptionr7 Ú _CONNECTION_CLOSED_EXCEPTIONrb )r rÆ s rX rc z ClientResponse._notify_content s. Ø,,Ù w×(Ñ(Ó*Ð2Ü 'Ô#?Ô @Ø rZ c ó K | j | j d { | j « y 7 # t j $ r= t j dk\ r't j
|
« x}r|j « r Y bw xY wwrp )rÖ r rr rì rs rt ru r! rv s rX Úwait_for_closez ClientResponse.wait_for_close¤ sv è ø Ø ==Ð $ð Ømm×#Ð#ð ð $ùÜ×)Ñ)ò ä×$Ñ$¨Ò/Ü!(×!5Ñ!5Ó!7Ð7Ð7Ø Ô)àùð üry c ó* K | j s | j j « d{ | _ | j D ]; }|j | j
|
| j | j « d{ = n| j r t d« | j xr | j j }| |j s| j « d{ | j S 7 Á7 v# t $ r | j « w xY w7 2w)zRead response payload.NrM )rÇ rÆ rR rç Ú send_response_chunk_receivedrl rk Ú BaseExceptionre rb r& rË rP r] rx )r ÚtracerP s rX rR zClientResponse.read± sò è ø à ::Ð ð Ø#'§<¡<×#4Ñ#4Ó#6× 6
|
Ø !\\ò EØ ×<Ñ<Ø T§X¡X¨t¯z©zó÷ ñ ñð ^^Ü'Ð(;Ó<Ð <à×#Ñ#ÒA¨×(8Ñ(8×(AÑ(AØ Ð 8×#4Ò#4Ø×%Ñ%Ó'× 'Ð 'ØzzÐð 7øðùô !ò Ø
|
|
Øð úð (úsL D C3 C/®A C3 Á:C1Á;C3 ÂA DÃ DÃ DÃ/C3 Ã1C3 Ã3DÄDc ó> | j j t j d« j « }t j |« }|j j d« }|rGt j t t « 5 t j |« j cd d d « S |j dk( r |j dk( s|j dk( ry| j" t% d« | j' | | j" « S # 1 sw Y jxY w)NÚ ÚcharsetÚ applicationÚjsonÚrdaprÒ z7Cannot compute fallback encoding of a not yet read body)rn r} r Ú CONTENT_TYPEÚlowerr Úparse_mimetypera Ú
|
contextlibÚsuppressÚ LookupErrorr~ ÚcodecsÚlookupÚnamer` ÚsubtyperÇ Ú RuntimeErrorrÔ )r ÚctypeÚmimetypeÚencodings rX Ú get_encodingzClientResponse.get_encodingÅ sí Ø × Ñ ¤×!2Ñ!2°BÓ7×=Ñ=Ó?Ü×)Ñ)¨%Ó0à×&Ñ&×*Ñ*¨9Ó5Ù Ü×$Ñ$¤[´*Ó=ñ 4Ü }} XÓ.×3Ñ3÷ 4ñ 4ð ==MÒ )Ø × Ñ Ò &¨(×*:Ñ*:¸fÒ*Dð à ::Ð Ü ØIóð ð ×$Ñ$ T¨4¯:©:Ó6Ð6÷ 4ð 4ús  DÄD r Úerrorsc ó´ K | j | j « d{ || j « }| j j ||¬« S 7 3w)z!Read response payload and decode.N)r )rÇ rR r r/ )r r r s rX ÚtextzClientResponse.textÜ sR è ø à ::Ð Ø))+× Ð à Ð Ø×(Ñ(Ó*Hàzz× Ñ °&Ð Ó9Ð9ð ús A¢A£4Ar¹ )r ÚloadsÚ content_typer r c óä K | j | j « d{ |r| j j t j
|
d« j « }t ||« s;t | j | j | j d|z | j ¬« | j j « }|sy|| j « } ||j |« « S 7 Ëw)z Read and decodes JSON response.Nr z3Attempt to decode JSON with unexpected mimetype: %srL )rÇ rR rn r} r r r r¼ r) rÚ r9 rÄ Ústripr r/ )r r r r r Ústrippeds rX r zClientResponse.jsonæ sÎ è ø ð ::Ð Ø))+× Ð á ØLL×$Ñ$¤T×%6Ñ%6¸Ó;×AÑAÓCEÜ,¨U°LÔAÜ&Ø×%Ñ%ØLLØ ;;àMÐPUÑUà LLôð ð ::×#Ñ#Ó%ÙØà Ð Ø×(Ñ(Ó*HáX__ XÓ.Ó/Ð/ð- ús C0¢C.£C C0c ó K d| _ | S wr\ )rj r s rX Ú
|
__aenter__zClientResponse.__aenter__ s è ø Ø ÔØ ùs
|
Úexc_typeÚexc_valÚexc_tbc ón K d| _ | j « | j « d { y 7 w)NF)rj r! r )r r¤ r¥ r¦ s rX Ú __aexit__zClientResponse.__aexit__ s- è ø ð !Ôð Ø×!Ñ!Ó#×#Ò#ús +53®5r )rN rm )rN z/MultiDictProxy[MultiDictProxy[Union[str, URL]]])r7 rK rN rG ©rN N)NÚstrict)rN rG )Zrc rd re rà r r: rg rÄ r´ rÅ rf rÆ r> rÇ r rÈ r rÉ r rÊ rD rË rÌ r rÍ rÎ rÏ rê Ú StackSummaryrÐ r rb rj rÔ r rÖ r r0 rH r r ÚAbstractEventLoopr Úobjectrö r rã Úsetterrý r5 rk r ro r rn r rÚ r_ r r¤ r r& r5 r7 r9 rE rZ rV rµ r` re r! rh rk r^ rx r" rc r rR r r r? r@ r r£ r r r
|
r¨ rh rZ rX rG rG s¹
ð &*GXkÑ "Ó)ØFCÓØ FHSMÓ à G\Ó Ø !E8E?Ó!Ø&*HÐ sÑ#Ó*Ø-/HeÐ)Ñ*Ó/Ø #L*Ó#à*.K,Ñ'Ó.Ø'+Hh|Ñ$Ó+Ø59Ð %¨¨S¨¡/Ñ2Ó9Ø26IxÐ.Ñ/Ó6Ø:>Ðx × 6Ñ 6Ñ7Ó>Ø*.HhÑ'Ó.ð GØIØKáASÐhÐ 0°%Ð 8¸#Ð =Ñ>ÓSà/3HhÐ+Ñ,Ó3ð%Oàð%Oð ð%Oð
|
/ð %Oð Ð 4Ñ5ð %Oð ð%Oð "ð%Oð W ð%Oð ×'Ñ'ð%Oð !ð%Oð
|
ó%OñN ð °$ó ð ð Ð"6Ñ7ò ó ð ð ^^ð :hÐ';Ñ <ð :Àò :ó ð :ð ð ò ó ð ð ^^ð,|ð ,°ò ,ó ð,ð ðSò ó ðð ðò ó ðð ð #ò ó ð ð ð cò ó ð ð ò ó ð ð ð!Zò !ó ð!ð ð"kò "ó ð"ð ðF XÐ.@Ñ%Aò Fó ðFð (0ñ ; ð ;°Dó ;ð #ó ð$ ð H \Ñ 2ò ó ð ð ð Ð 4Ñ5ò ó ð ð ò!%ó ð!%óF/ób #ð ð ò ó ð ó $ðó ð ð!Dò !ó ð!óó$Vó #ó ó
|
ó ðEó ð(7có 7ñ.: 8¨C¡=ð :Àð :ÐTWó :ð #'Ø 1Ø&8ò 0ð 3-ð 0ð ð 0ð
|
smð 0ð
|
ó 0óBð $à4 Ñ.Ñ/ð $ð -Ñ(ð $ð Ñ'ð $ð
|
|
ô $rZ rG c 0 ó e Zd ZU ej ej
|
ej ej hZej ej ej hZ ej e « j ej h« Zej dej" e« iZdZedej. f ed< dZdZdZe d ed< e « Z dZ dZ dZ!e d ed< dddddde"jF ddd ddddddd
|
ddd dd d e$d e de%de e& de e'e$ de(de e) de e* de"jV dee$e,df de e, de,de e-j\ de e/d de e d e e* d e e0 d e d d ee1e,e2f d!e e& d"e e3d# d$e,d%e e$ f.d&Z4dVd'e5d(dfd)Z6d(e e7 fd*Z8e9d(e:d fd+« Z;e9d(e d fd,« Z<e<jz dWd.« Z<d(e,fd/Z>e9d(ed0e,e2f fd1« Z?e9d(e@fd2« ZAe9d(e$fd3« ZBe9d(e e7 fd4« ZCe9d(eej. eDd5 f fd6« ZEeEjz d7e(d(dfd8« ZEe9d(eFfd9« ZGe9dXd:« ZHd e d(dfd;ZIdee"jV e$f d(dfd<ZJde e& d(dfd=ZKde e'e$ d(dfd>ZLde e) d(dfd?ZMde(d(dfd@ZNdYdAZOdZde e* d$e,d(dfdBZPd[dCe(dDe7d(dfdEZQdCe(d(dfdFZRdCe(d(dfdGZSdZdHe,d(dfdIZTde e d e e* d!e e& d(dfdJZU dVd-eVdKdLdMe e7 d(dfdNZWd\dOZXdYdPZYdYdQZZd e$d e dRe[d(dfdSZ\d e$d e ddTd(dfdUZ]y)]rF z*/*NrÇ rÕ Ú_ClientRequest__writerÚGETzCIMultiDict[None]Ú_skip_auto_headersFT)r rn Úskip_auto_headersÚdatarý Úauthrà ÚcompressÚchunkedÚ expect100rÜ Úresponse_classr± r² rÙ rÝ r Ú proxy_headersrÛ Ú trust_envÚserver_hostnamerl rk r rn r³ r´ rý rµ rà r¶ r· r¸ rÜ r¹ rG r± r² rÙ rÝ rJ r rº rÛ rL r» r¼ c óº | t j « } t j |« x}r t d|d|j « d« t |« t u sJ |« |t |« t u sJ |« t r|J || _ |r|j |« }|| _ |j r|j d « n|| _ |j « | _ | | _ |
|
| _ | | _ d | _ |t* }n|}|| _ ||n t/ « | _ ||nd| _ || _ | j7 « r-t9 j: t= j> d« « | _ | jC | « | jE |« | jG |« | jI |« | jK |« | jM |« | jO ||« | jQ |||« | jS |« || j | jT vr| jW « | jY | « |g | _- y || _- y )Nz+Method cannot contain non-token characters z (found at least ú)Tr ).r Úget_event_loopÚ_CONTAINS_CONTROL_CHAR_REÚsearchr~ Úgroupr` r r rÐ Ú extend_queryÚ original_urlrà rá rk Úupperrl r· r¶ rÜ ÚlengthrG r¹ r3 rå Ú_sslr¼ ré rê rë rì rí rÏ Úupdate_versionÚ update_hostÚupdate_headersÚupdate_auto_headersÚupdate_cookiesÚupdate_content_encodingÚ update_authÚ update_proxyÚupdate_body_from_dataÚ GET_METHODSÚupdate_transfer_encodingÚupdate_expect_continuerç )r rl rk r rn r³ r´ rý rµ rà r¶ r· r¸ rÜ r¹ r± r² rÙ rÝ r rº rÛ r» r¼ r» Úreal_response_classs rX r zClientRequest.__init__= s4 ð6 <Ü×)Ñ)Ó+DÜ-×4Ñ4°VÓ<Ð <5Ð <Ü Ø=¸f¸Zð H#Ø#(§;¡;£=Ð"3°1ð6óð ô
|
CyCÑ Ð$ Ó$Ð Ø Ð Ü;¤#Ñ%Ð , uÓ ,Ð%õ ØÐ&Ð &Ð&Ø Ù Ø×"Ñ" 6Ó*CØ ÔØ.1×.>Ò.>3×$Ñ$ TÔ*ÀCØ lln Ø Ø Ø Ø Ø Ð !Ü"0Ñ à"0Ð Ø4GÔØ $Ð 0e´i³k Ø ?C° Ø .Ô à >>Ô Ü%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NDÔ "à ×ÑGÔ$Ø ×ÑÔ Ø ×ÑGÔ$Ø × Ñ Ð!2Ô3Ø ×ÑGÔ$Ø ×$Ñ$ TÔ*Ø ×ÑyÔ)Ø ×Ñ% ¨]Ô;à ×"Ñ" 4Ô(Ø Ð t{{°$×2BÑ2BÑ BØ × )Ñ )Ô +Ø ×#Ñ# IÔ.Ø #^r ° rZ r rN c ó d | _ y r ©r° rð s rX rñ z ClientRequest.__reset_writer rò rZ c óÆ t j | j vry| j t j } t |« S # t $ r t d| « dw xY w)zÊExtract and validate Content-Length header value.
|
|
Returns parsed Content-Length value or None if not set.
|
Raises ValueError if header exists but cannot be parsed as an integer.
|
Nz Invalid Content-Length header: )r ÚCONTENT_LENGTHrn r´ r~ )r Úcontent_length_hdrs rX Ú_get_content_lengthz!ClientRequest._get_content_length sj ô × Ñ d§l¡lÑ 2Øà !\\¬$×*=Ñ*=Ñ >Ðð ÜÐ)Ó*Ð *øÜò Ü Ø1Ð2DÐ1EÐFóàð ð ús ¼
|
A ÁA c ó2 | j xs
|
t « S r )r² r r s rX r³ z ClientRequest.skip_auto_headers s à×&Ñ&Ò7¬+«-Ð7rZ c ó | j S r rÖ r s rX rã zClientRequest._writer¤ r rZ r× c óª | j %| j j | j « || _ |j | j « y r )r° rõ Ú _ClientRequest__reset_writerrø rù s rX rã zClientRequest._writer¨ s? à ==Ð $Ø MM× .Ñ .¨t×/BÑ/BÔ CØ Ø× Ñ ×!4Ñ!4Õ5rZ c ó: | j j t v S r )rk ÚschemeÚ _SSL_SCHEMESr s rX r° zClientRequest.is_ssl¯ s Øxx¤,Ð.Ð.rZ rE c ó | j S r )rÇ r s rX r zClientRequest.ssl² r rZ c
|
óN | j x}r#t t |j « « « }nd }| j }t j t |j xs d|j |j t v | j | j | j |f« S )Nr )rº Úhashrr Úitemsrk rs r¯ Úraw_hostr rà rá rÇ r± r² )r rº Úhrk s rX Úconnection_keyz ClientRequest.connection_key¶ s à × .Ñ .Ð .=Ð .Ü #¤E¨-×*=Ñ*=Ó*?Ó$@Ó AAàAØhhÜ}}Ü à Ò" ØØ
|
|
lÐ*Ø Ø
|
|
ØØð ó
|
ð
|
rZ c ó: | j j }|J |S r )rk ræ )r Úrets rX r zClientRequest.hostÊ s àhh× Ñ ØÐ Ø
|
rZ c ó. | j j S r )rk r r s rX r zClientRequest.portÐ s àxx}}Ð rZ rZ c ó" | j xs dS )z Request body.rZ )rÇ r s rX ÚbodyzClientRequest.bodyÔ s ð zzÒ SÐ rZ rJ c ó | j 1t | j d¬« | j j « | j |« y)aÆ Set request body with warning for non-autoclose payloads.
|
|
WARNING: This setter must be called from within an event loop and is not
|
thread-safe. Setting body outside of an event loop may raise RuntimeError
|
when closing file-based payloads.
|
|
DEPRECATED: Direct assignment to body is deprecated and will be removed
|
in a future version. Use await update_body() instead for proper resource
|
management.
|
Nr¡ r¢ )rÇ rÁ Ú_closeÚ _update_body)r rJ s rX rí zClientRequest.bodyÚ s> ð ::Ð !ô & d§j¡j¸QÕ ?ð
|
JJ× Ñ Ô Ø ×Ñ%Õ rZ c ó¤ t | j « }t j t | j
|
| j || j f« S r )r rn rr rs rH rk rl rÄ )r rn s rX rÚ zClientRequest.request_infoò s? ä)9¸$¿,¹,Ó)Gô
|
}}Ü $(( D§K¡K°¸$×:KÑ:KÐLó
|
ð
|
rZ c ó | j S )zÜReturn the ClientSession instance.
|
|
This property provides access to the ClientSession that initiated
|
this request, allowing middleware to make additional requests
|
using the same session.
|
)rÐ r s rX rÝ zClientRequest.sessioný s ð }}Ð rZ c óÒ |j s t |« |j s |j r8t j
|
|j xs d|j xs d« | _ yy)z8Update destination host, port and connection type (ssl).r N) ræ r* Úraw_userÚ raw_passwordr r1 ÚuserÚpasswordrµ )r rk s rX rÉ zClientRequest.update_host sP ð ||Ü S/Ð !ð <<3×+Ò+Ü ×)Ñ)¨#¯(©(ª.°b¸#¿,¹,Ò:LÈ"ÓMDIð ,rZ c ó< t |t « rd|j dd« D cg c] }|j « }} t j
|
t |d « t |d « « }|| _ y|| _ yc c}w # t $ r t d| « dw xY w)zdConvert request version to two elements tuple.
|
|
parser HTTP version '1.1' => (1, 1)
|
ú.r r z#Can not parse http version number: N) r§ rf r@ r r r: r´ r~ rà )r rà ÚpartÚvs rX rÈ z ClientRequest.update_version s ô
|
gsÔ #Ø*1¯-©-¸¸QÓ*?Ö@ $ Ð@AÐ@ð Ü ×*Ñ*¬3¨q°©t«9´c¸!¸A¹$³iÓ@ð
|
w ùò Aøô ò Ü Ø9¸'¸ÐCóàð ð ús ¥A=¿.B ÂBc ó| t « | _ | j j }|J || j t j
|
< |syt |t t t f« r|j « }|D ]C \ }}|t j v r|| j |< (| j j ||« E y)zUpdate request headers.N) r rn rk Úhost_port_subcomponentr ÚHOSTr§ Údictr r rå ÚHOST_ALLrC )r rn r rI rJ s rX rÊ z ClientRequest.update_headers s ä)4« ð xx×.Ñ.ð Ð Ð Ð Ø"& TYYÑ áØ ä g¤¤n´iÐ @Ô AØ mmoGà!ò -JCàdmmÑ#Ø$) SÒ!à × Ñ eÕ,ñ -rZ c ó |Vt d t |« D « « | _ | j j « }|j | j « n | j }| j j « D ] \ }}||vs || j |< t j |vr"t | j t j < y y )Nc 3 ó$ K | ] }|d f
|
y wr rh )r Úhdrs rX r z4ClientRequest.update_auto_headers.<locals>.<genexpr>; s è ø ò 2Ø #d ñ2ùs ) r Úsortedr² rn ÚcopyÚextendÚDEFAULT_HEADERSrå r Ú
|
USER_AGENTr9 )r r³ Ú used_headersr rF s rX rË z!ClientRequest.update_auto_headers9 s¸ Ø Ð (Ü&1ñ 2Ü'-Ð.?Ó'@ô2ó 'DÔ #ð <<×,Ñ,Ó.LØ × Ñ × 7Ñ 7Õ 8ð <<Là ×,Ñ,×2Ñ2Ó4ò (HCØ,Ò&Ø$' SÒ!ð (ô ?? ,Ñ .Ü,;DLL Ò )ð /rZ c ó* |syt « }t j | j v r]|j t | j j t j d« « « | j t j = t |t « r|j « }n|}|D ]) \ }}t |t « rt |« ||< %|||< + |j dd¬« j « | j t j < y)z Update request cookies header.Nr r< )ÚheaderÚsep)r r ÚCOOKIErn rû r" r} r§ r rå r r$ Úoutputr )r rý ÚcÚ iter_cookiesr rJ s rX rÌ z ClientRequest.update_cookiesL sÎ áØ ä NÜ ;;$,,Ñ &à HHÔ(¨¯ © ×)9Ñ)9¼$¿+¹+ÀrÓ)JÓKÔ LØ T[[Ð)ä gwÔ 'Ø"==?Là"LØ'ò KD%Ü%¤Ô(ä:¸5ÓA$à $ð ð %&§H¡H°B¸C HÓ$@×$FÑ$FÓ$H T[[Ò!rZ c óR |sd| _ y| j j t j « r| j r t d« y| j rPt | j t « sd| _ | j | j t j < d| _ yy)z Set request content encoding.Nz9compress can not be set if Content-Encoding header is setrQ T) r¶ rn r} r ÚCONTENT_ENCODINGr~ r§ rf r· )r r´ s rX rÍ z%ClientRequest.update_content_encodingd s
áà DMØ à <<× Ñ D× 1Ñ 1Ô 2Ø}}Ü ØOóð ð ð ]]Ü dmm¬SÔ1Ø ) Ø26·-±-DLL×.Ñ.Ñ /Ø DLð rZ c óN | j j t j d« j « }d|v r| j
|
r t d« y| j
|
rEt j | j v r t d« d| j t j < yy)z!Analyze transfer-encoding header.r r· zDchunked can not be set if "Transfer-Encoding: chunked" header is setz6chunked can not be set if Content-Length header is setN)rn r} r ÚTRANSFER_ENCODINGr r· r~ rØ )r Útes rX rÒ z&ClientRequest.update_transfer_encodingv s à \\× Ñ d× 4Ñ 4°bÓ 9× ?Ñ ?Ó Aà ?Ø||Ü ðDóð ð ð \\Ü×"Ñ" d§l¡lÑ2Ü ØLóð ð 4=DLL×/Ñ/Ò 0ð rZ c óÆ | | j }|yt |t j « s t d« |j « | j t j < y)zSet basic auth.Nz%BasicAuth() tuple is required instead) rµ r§ r r1 r© r. rn r Ú AUTHORIZATION)r rµ r» s rX rÎ zClientRequest.update_auth sN à <Ø99DØ <Ø ä$¤× 1Ñ 1Ô2ÜÐ CÓDÐ Dà+/¯;©;«= T×'Ñ'Ò(rZ rí Ú _stacklevelc óf | j t | j |¬« |ed| _ | j | j vrE| j s9t
|
j | j vr d| j t
|
j < yt |t « r |« n|} t j j |d¬« }|| _ | j sXt
|
j | j vr<|j x}'t |« | j t
|
j < nd| _ |j sJ | j }| j }|j j# « D ] \ }} ||v s|||v r| ||< y# t j $ r t |« « }Y éw xY w)z Update request body from data.Nr¢ Ú0)Ú dispositionT)rÇ rÁ rl rÑ r· r rØ rn r§ r. r! ÚPAYLOAD_REGISTRYr} r Úsizerf r² rå )
|
r rí r Ú maybe_payloadÚ body_payloadr rn Ú skip_headersrI rJ s
|
rX rÐ z#ClientRequest.update_body_from_data s| à ::Ð !Ü % d§j¡j¸[Õ Ià <Ø DJð 4×#3Ñ#3Ñ3Ø Ü×'Ñ'¨t¯|©|Ñ;à47 T× 0Ñ 0Ñ1Ø ô #-¨T´8Ô"<À$ ð 5Ü"×3Ñ3×7Ñ7¸ ÐSWÐ7ÓXLð "
|
à||¤× 3Ñ 3¸4¿<¹<Ñ GØ$×)Ñ)Ð)Ð6Ü47¸³I T× 0Ñ 0Ò1à # ð ×#Ò#Ð#Ð#Ø,,Ø×.Ñ. Ø&×.Ñ.×4Ñ4Ó6ò !JCØg~ ,Ð":¸sÀlÑ?RØØ GCLñ !øô ×"Ñ"ò 5Ø28 MÓ2Ó4Lð 5ús Â%!F
|
Æ
|
#F0Æ/F0c ót t j | j v r| j t j = | j r7t j | j v r| j t j = | j |d¬« || j | j vr| j « yy)z/Update request body after its already been set.é )r N) r rØ rn r· r rÐ rl rÑ rÒ ©r rí s rX rð zClientRequest._update_body¾ s ô × Ñ $§,¡,Ñ .Ø T× 0Ñ 0Ð1ð <<D× 2Ñ 2°d·l±lÑ BØ T× 3Ñ 3Ð4ð ×"Ñ" 4°QÐ"Ô7ð Ð t{{°$×2BÑ2BÑ BØ × )Ñ )Õ +ð CrZ c ó K | j "| j j « d{ | j |« y7 w)ac
|
Update request body and close previous payload if needed.
|
|
This method safely updates the request body by first closing any existing
|
payload to prevent resource leaks, then setting the new body.
|
|
IMPORTANT: Always use this method instead of setting request.body directly.
|
Direct assignment to request.body will leak resources if the previous body
|
contains file handles, streams, or other resources that need cleanup.
|
|
Args:
|
body: The new body content. Can be:
|
- bytes/bytearray: Raw binary data
|
- str: Text data (will be encoded using charset from Content-Type)
|
- FormData: Form data that will be encoded as multipart/form-data
|
- Payload: A pre-configured payload object
|
- AsyncIterable: An async iterable of bytes chunks
|
- File-like object: Will be read and sent as binary data
|
- None: Clears the body
|
|
Usage:
|
# CORRECT: Use update_body
|
await request.update_body(b"new request data")
|
|
# WRONG: Don't set body directly
|
# request.body = b"new request data" # This will leak resources!
|
|
# Update with form data
|
form_data = FormData()
|
form_data.add_field('field', 'value')
|
await request.update_body(form_data)
|
|
# Clear body
|
await request.update_body(None)
|
|
Note:
|
This method is async because it may need to close file handles or
|
other resources associated with the previous payload. Always await
|
this method to ensure proper cleanup.
|
|
Warning:
|
Setting request.body directly is highly discouraged and can lead to:
|
- Resource leaks (unclosed file handles, streams)
|
- Memory leaks (unreleased buffers)
|
- Unexpected behavior with streaming payloads
|
|
It is not recommended to change the payload type in middleware. If the
|
body was already set (e.g., as bytes), it's best to keep the same type
|
rather than converting it (e.g., to str) as this may result in unexpected
|
behavior.
|
|
See Also:
|
- update_body_from_data: Synchronous body update without cleanup
|
- body property: Direct body access (STRONGLY DISCOURAGED)
|
|
N)rÇ re rð r# s rX Ú update_bodyzClientRequest.update_bodyÐ s< è ø ðt ::Ð !Ø**×"Ñ"Ó$× $Ð $Ø ×Ñ$Õ ð %ús *A¬AAÚexpectc ó |r d| j t j < nLt j | j v r0| j t j j « dk( rd}|r | j j « | _ y y )Nz 100-continueT)rn r ÚEXPECTr rÜ Ú create_futurerÎ )r r& s rX rÓ z$ClientRequest.update_expect_continue sf Ù Ø(6DLLÒ %ä KK4<<Ñ 'Ø T[[Ñ)×/Ñ/Ó1°^ÒCàFá Ø !YY× 4Ñ 4Ó 6DNð rZ c óä || _ |d | _ d | _ y |r%t |t j
|
« s t d« || _ |!t |t t f« s t |« }|| _ y )Nz,proxy_auth must be None or BasicAuth() tuple)
|
r± r² rº r§ r r1 r~ r r r )r r± r² rº s rX rÏ zClientRequest.update_proxy sr ð
|
Ø =Ø "DOØ!%DÔ Ø á j¨´W×5FÑ5FÔ GÜ Ð KÓLÐ LØ$à Ð $¬ZØ I¤~Ð6ô.
|
ô (¨ Ó 6MØ *ÕrZ ÚconnrK Úcontent_lengthc
|
ó K | j <|j « |j « d{ | j d{ |j }|J | j $| j j ||« d{ |j « d{ |j « y7 7 p7 17 # t $ ri}|}|j duxs t |t j « }|r#t |j d| j « }t |||« Y d}~yd}~wt j $ r |j# « t$ $ r&}t |t' d|d|« |« Y d}~yd}~ww xY ww)a:
|
Write the request body to the connection stream.
|
|
This method handles writing different types of request bodies:
|
1. Payload objects (using their specialized write_with_length method)
|
2. Bytes/bytearray objects
|
3. Iterable body content
|
|
Args:
|
writer: The stream writer to write the body to
|
conn: The connection being used for this request
|
content_length: Optional maximum number of bytes to write from the body
|
(None means write the entire body)
|
|
The method properly handles:
|
- Waiting for 100-Continue responses if required
|
- Content length constraints for chunked encoding
|
- Error handling for network issues, cancellation, and other exceptions
|
- Signaling EOF and timeout management
|
|
Raises:
|
ClientOSError: When there's an OS-level error writing the body
|
ClientConnectionError: When there's a general connection error
|
asyncio.CancelledError: When the operation is cancelled
|
|
Nz Can not write request body for z4Failed to send bytes into the underlying connection z: )rÎ Ú send_headersÚdrainrP rÇ Úwrite_with_lengthÚ write_eofÚ start_timeoutÚOSErrorÚerrnor§ r Ú TimeoutErrorr' rk r7 rr re Ú Exceptionr& )r r× r+ r, rP Úunderlying_excÚ reraised_excÚexc_is_not_timeouts rX Ú write_byteszClientRequest.write_bytes0 s
è ø ðB >>Ð %à × Ñ Ô !Ø,,.× Ð Ø..× Ð à==ØÐ#Ð#Ð#ð' %ð zzÐ%Øjj×2Ñ2°6¸>ÓJ×JÐJð< ×"Ñ"Ó$× $Ð $Ø × "Ñ "Õ $ðY !øØ øð Køð< %ùô; ò BØ)Lð "0×!5Ñ!5¸TÐ!Aò "ÌØ ¤× 4Ñ 4óJð FÐ ñ "Ü ,Ø"×(Ñ(Ø5°d·h±h°]ÐCó ô
|
( L°.× AÑ AûÜ×%Ñ%ò à JJLØ Üò Ü ØÜ%ØJØir .Ð!3ð5óð ÷ ñ ûð üs 0F²B5³FÁB7ÁFÁ +B= ÂB9ÂB=  F B; FÂ7FÂ9B= Â;FÂ= E?ÃA D*Ä%FÄ*/E?Å E:Å5FÅ:E?Å?Fc ór K | j t j k( r6| j j }|J | d| j j
|
}nH| j r&| j « st | j « }n| j j }|j }|J t || j | j r5t j | j | j | j « nd | j r5t j | j" | j | j « nd ¬« }| j$ r|j' | j$ « | j( |j+ « | j | j, v ra| j. t j0 | j. vr9t j0 | j2 vr d| j2 t j0 < | j4 }t j6 | j2 vrc|j8 j: r'|t< k( rDd| j2 t j6 < n&|t> k( r d| j2 t j6 < | j d| d|j@ d|jB }|jE || j2 « d { | jF s| jH |jJ r| jM ||| jO « « }tP jR d k\ r#tU jV || j d
|
¬ « } n| j jY |« } | j[ « rd } n*| | _. n"|j_ « |ja « d } | jb }
|
|
|
J |
|
| j | jd | | jH | jf | jh | j | j | jj ¬ « | _6 | jl S 7 Zw) Nú:)Ú on_chunk_sentÚon_headers_sentzapplication/octet-streamre z
|
keep-aliveú z HTTP/rù )r¡ é T)rÜ Ú eager_start)r× rØ rÙ rÚ rÛ rÜ rÝ )7rl r Ú METH_CONNECTrk Úhost_subcomponentr r± r° rf Ú raw_path_qsrP r= rÜ rç Ú functoolsÚpartialÚ_on_chunk_request_sentÚ_on_headers_request_sentr¶ Úenable_compressionr· Úenable_chunkingÚ POST_METHODSr² r rn rà Ú
|
CONNECTIONÚ
|
_connectorÚ force_closer< r; ÚmajorÚminorÚ write_headersrÇ rÎ Úwriting_pausedr: rÚ rì rs r ÚTaskÚ create_taskr÷ rã r2 Úset_eofr¹ rÄ rå rÚ rÐ Úresponse) r r+ Ú connect_hostÚpathrP r× rû Ú status_lineÚcororw r¹ s rX ÚsendzClientRequest.send s? è ø ð
|
;;$×+Ñ+Ò +Ø 88×5Ñ5LØ Ð+Ð +Ð+Ø"^ 1 T§X¡X§]¡] OÐ4DØ ZZ § ¡ ¤ Ütxx=Dà88×'Ñ'Dà==ØÐ#Ð#Ð#Ü Ø Ø IIð <<ô ×!Ñ! $×"=Ñ"=¸t¿{¹{ÈDÏHÉHÔUàð <<ô ×!Ñ! $×"?Ñ"?ÀÇÁÈdÏhÉhÔWàô
|
ð ==Ø × %Ñ % d§m¡mÔ 4à <<Ð #Ø × "Ñ "Ô $ð KK4×,Ñ,Ñ ,à×'Ñ'Ð/Ü×$Ñ$¨D×,CÑ,CÑCä×!Ñ!¨¯ © Ñ5à.HDLL×*Ñ*Ñ +à LLÜ ?? $§,¡,Ñ .Ø×*Ò*Ø Ò%Ø4;DLL¤§ ¡ Ò1ØmÒ#Ø0< T__Ñ-ð Q t f¨F°1·7±7°)¸1¸Q¿W¹W¸IÐF ð ×"Ñ" ;°· ± Ó=×=Ð=ð :: Ð3°x×7NÒ7NØ×#Ñ# F¨D°$×2JÑ2JÓ2LÓMDÜ× Ñ 7Ò*ô || D¨t¯y©yÀdÔKàyy×,Ñ,¨TÓ2Øyy{Øà # ð × "Ñ "Ô $Ø NNÔ ØDØ ×,Ñ,Ø Ð)Ð)Ð)Ù&Ø KKØ × Ñ ØØ Ø++Ø ×*Ñ*Ø<<ØØMMô
|
|
ð }}Ð ðK >ûs KP7ËP4ËEP7c ó K | j | j d { y y 7 # t j $ rA t j dk\ r+t j
|
« x}r|j « r Y y Y y Y y w xY wwrp )r° r rr rì rs rt ru rv s rX re zClientRequest.closeå s| è ø Ø ==Ð $ð Ømm×#Ñ#ð %à#ùÜ×)Ñ)ò ä×$Ñ$¨Ò/Ü!(×!5Ñ!5Ó!7Ð7Ð7Ø Ô)àñ *ñ 8ñ 0ð üs2 A?( & ( ¤A?¦( ¨A A<Á5A?Á;A<Á<A?c óÞ | j a| j j « s| j j « | j j | j
|
« d | _ y y r )r° rÜ rd r{ rõ rÞ r s rX Ú terminatezClientRequest.terminateñ sP Ø ==Ð $Ø99×&Ñ&Ô(Ø ×$Ñ$Ô&Ø MM× .Ñ .¨t×/BÑ/BÔ CØ DMð %rZ Úchunkc óh K | j D ] }|j |||« d { y 7 wr )rç Úsend_request_chunk_sent)r rl rk r_ r s rX rG z$ClientRequest._on_chunk_request_sentø s6 è ø Ø\\ò DEØ×/Ñ/°¸¸UÓC× CÑ Cñ DØ Cúó &2¨0©2zCIMultiDict[str]c óh K | j D ] }|j |||« d { y 7 wr )rç Úsend_request_headers)r rl rk rn r s rX rH z&ClientRequest._on_headers_request_sentü s8 è ø ð \\ò CEØ×,Ñ,¨V°S¸'ÓB× BÑ Bñ CØ Búrb r )r× rÕ rN N)rN rJ r© )F)r¡ )r+ rK rN rG )^rc rd re r ÚMETH_GETÚ METH_HEADÚ METH_OPTIONSÚ
|
METH_TRACErÑ Ú
|
METH_PATCHÚ METH_POSTÚMETH_PUTrK ÚunionÚ METH_DELETEÚ ALL_METHODSÚACCEPTÚACCEPT_ENCODINGrY r rÇ r r! ÚPayloadrg rµ rV r° r r rk rl rÎ r² r r< rf rC rB r r rA r1 r: rµ r r¬ r r0 rE rI r r r rÞ r´ rÚ r r r³ rã r® r° r r¯ rè r r r rí rH rÚ rÝ rÉ rÈ rÊ rË rÌ rÍ rÒ rÎ rÐ rð r% rÓ rÏ r% r: r[ re r^ r rG rH rh rZ rX rF rF s
à Ø Ø ×ÑØ ð Kð OO T§^¡^°T·]±]ÐCLØ ×#Ñ# LÓ1×7Ñ7¸×9IÑ9IÐ8JÓKKð UØ × Ñ Ñ :Ó <ðOð +/E5wÐ&Ñ 'Ó.Ø DØHà/3HhÐ+Ñ,Ó3ñ %CØ FàIà8<ÐÐ!4Ñ5Ó<ð Ø*.Ø59ØØ*.Ø$(Ø$(×$6Ñ$6Ø+/Ø"&Ø Ø48Ø;?Ø #Ø*.Ø,0Ø-1Ø48Ø04Ø*.Ø Ø)-ò3M8àðM8ð ðM8ð
|
ð M8ð ,Ñ'ð M8ð $ H¨S¡MÑ2ðM8ð ðM8ð ,Ñ'ðM8ð yÑ!ðM8ð ×!Ñ!ðM8ð T 4Ñ(ðM8ð $ ðM8ð ð M8ð w×0Ñ0Ñ1ð M8ð ! Ð&6Ñ!7Ñ8ð!M8ð" }ð#M8ð$ YÑ'ð%M8ð& Ð(Ñ)ð'M8ð( /Ñ*ð)M8ð* :t [Ð0Ñ 1ð+M8ð, Ñ-ð-M8ð. g Ñ'ð/M8ð0 ð1M8ð2 " # ó3M8ñ^ ð °$ó ð X¨c¡]ó ð" ð8 ;¨tÑ#4ò 8ó ð8ð ð Ð"6Ñ7ò ó ð ð ^^ò6ó ð6ð /ó /ð ðU<¨¨{Ð:Ñ;ò ó ðð ð
|
ò
|
ó ð
|
ð& ðcò ó ðð
|
ð hsmò ó ð ð ð!eGOO¨W°S©\Ð 9Ñ:ò !ó ð!ð
|
|
[[ð!#ð ! $ò !ó ð!ð. ð
|
kò
|
ó ð
|
ð ò ó ð ðNsð N tó Nð e¨D×,<Ñ,<¸cÐ,AÑ&Bð Àtó ð - h¨|Ñ&<ð -Àó -ð2<°X¸hÀs¹mÑ5Lð <ÐQUó <ð&I h¨|Ñ&<ð IÀó Ið0 ¨Cð °Dó ó$=ñ&
|
9 ¨Ñ 3ð
|
9Àð
|
9ÐQUó
|
9ñ'!¨#ð '!¸Cð '!Èó '!ðR, ð ,¨ó ,ð$< cð < ¨dó < ñ|
|
7¨Tð
|
7¸dó
|
7ð+à}ð+ð YÑ'ð+ð Ñ-ð +ð
|
|
ó +ð4 )-ñ P%à$ðP%ð ðP%ð ! ð P%ð
|
|
ó P%óda óF
|
ó!ðD°3ð D¸Sð DÈð DÐSWó DðCØðCØ #ðCØ.@ðCà ôCrZ rF )r )~r r r rE r, r? rì rê r¤ Úcollections.abcr Úhashlibr r r Ú http.cookiesr r Útypesr r
|
Útypingr r r r r r r r r r r r ÚattrÚ multidictr r r r Úyarlr r r r r r r! Ú_cookie_helpersr" r# r$ Úabcr% Úclient_exceptionsr& r' r( r) r* r+ Úcompression_utilsr, r- Úformdatar. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= Ústreamsr> Útypedefsr? r@ rA rB rC rD r rE Ú ImportErrorr Ú__all__ÚclientrJ Ú connectorrK ÚtracingrL r~ ÚcompilerÀ rº rf rY Úsr_ rj rH rI rµ r` r¨ r r« Ú frozensetrá r¯ r¼ rq r´ rÁ rG rF rh rZ rX ú<module>r sj ðÛ Û Û Û Û Û Û
|
Û Û Ý #ß %Ñ %ß -ß 1÷ ÷ ÷ ó ó ß NÓ NÝ ç 5Õ 5÷ñ õ
|
&÷÷ ÷ 4Ý ÷ ÷ ÷ ÷õ õ "÷÷ ñ ÛÞ ð ÛÝ"ð Lñ Ý%Ý%Ý ñ 5Ð5HÓ IÐ Ø &BJJÐ'EÓ FÐ Ø
|
"**Ð9Ó
|
:ð có ð T $¨dÔ3÷ ð ó 4ð ô :ô ô
|
,ô
|
÷$ Pñ Pð@ ?Ø ¨¨{¹DÀ»JÐGÑà t DzÐ*Ðð4Ø |T ;Ð.Ñ /ð4àð4ð ,Ñ'ð4ð % ð 4ð
|
<{Ð *Ñ+ó 4ñn Ð)Ó* ô &Jô &ð:Ø ð:Ø7:ð:à ó:ñ
|
w§¡ð
|
ÀCð
|
ÐPTó
|
ô&w$\ô w$÷tg Cò g CøðG ò ØØ
|
ð ús Ã=
|
H È H,È+H,
|
