Ë
|
|
çúhK; ã ó d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
|
Z
|
m Z m Z m Z mZmZ d dlmZmZ d dlmZmZ d dlmZmZ g d¢Zd d lmZ d d
|
l m Z d d l m Z d Z d Z!h d£Z"e G d d« « Z# G d de$« Z% G d d« Z&y)é )Ú annotationsN)Ú dataclass)ÚAnyÚDictÚMappingÚOptionalÚTupleÚUnion)Ú HTTPErrorÚURLError)Ú urlencodeÚurljoin)ÚRequestÚurlopen)Ú
|
HttpClientÚ HttpResponseÚ HttpErrorÚDEFAULT_TIMEOUT)Ú ExponentialWithJitterBackoff)ÚRetry©Ú
|
dummy_failz)HttpClient/1.0 (+https://example.invalid)g >@> é éô éö é÷ éø c óP e Zd ZU ded< ded< ded< ded< d dd
|
Zdd Zdd Zy )r ÚintÚstatusúDict[str, str]ÚheadersÚstrÚurlÚbytesÚcontentNc ód |xs | j « }| j j |d¬« S )NÚreplace)Úerrors)Ú _get_encodingr& Údecode)ÚselfÚencodingÚencs õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/http/http_client.pyÚtextzHttpResponse.text s/ ØÒ.$×,Ñ,Ó.Ø||×"Ñ" 3¨yÐ"Ó9Ð9ó c óh t j | j | j « ¬« « S )N)r- )ÚjsonÚloadsr0 r* )r, s r/ r3 zHttpResponse.json$ s% Üzz$))¨T×-?Ñ-?Ó-A)ÓBÓCÐCr1 c ó | j j dd« }|j d« D ]Z }|j « }|j « j d« s3|j dd« d j « xs dc S y)Nú content-typeÚ ú;zcharset=ú=é úutf-8)r" ÚgetÚsplitÚstripÚlowerÚ
|
startswith)r, ÚctypeÚpartÚps r/ r* zHttpResponse._get_encoding' sw à × Ñ °Ó4àKK Ó$ò =DØ
|
|
AØwwy×#Ñ# JÕ/Øwws A qÑ)×/Ñ/Ó1Ò<°WÒ<ð =ð r1 ©N)r- ú Optional[str]Úreturnr# )rF r )rF r# )Ú__name__Ú
|
__module__Ú __qualname__Ú__annotations__r0 r3 r* © r1 r/ r r s'
à KØ ÓØ HØ Nô:óDôr1 r c ó" e Zd Zdd fd Z xZS )r c óv || _ || _ |xs d| d| | _ t | | j « y )NzHTTP z for )r r$ ÚmessageÚsuperÚ__init__)r, r r$ rN Ú __class__s r/ rP zHttpError.__init__3 s; ø Ø ØØ Ò< E¨&¨°°s°eÐ"< Ü Ñ Õ&r1 rD )r r r$ r# rN rE )rG rH rI rP Ú __classcell__)rQ s @r/ r r 2 s ø ÷'ò 'r1 r c óD e Zd ZdZdde e edd¬« d¬« d dddddddef dd
|
Z d dd Z d dd Z
|
d d d Z d d dZ d d dZ d d dZ d d!dZd"dZ d# d$dZ d d%dZ d& d'dZ d(dZd)dZd*dZy)+r z7
|
A lightweight HTTP client for REST API calls.
|
r7 Nr: é
|
)ÚbaseÚcapé )ÚbackoffÚretriesTc óâ |r$|j d« s|j « dz n|| _ |xs i j « D ci c] \ }}|j « | c}}| _ || _ || _ | j j t t t j f« || _ || _ || _ || _ | | _ |
|
| _ | | _ | | _ | | _ yc c}}w )a
|
Initialize a new HTTP client instance.
|
|
Args:
|
base_url: Base URL for all requests. Will be prefixed to all paths.
|
headers: Default headers to include in all requests.
|
timeout: Default timeout in seconds for requests.
|
retry: Retry configuration for failed requests.
|
verify_tls: Whether to verify TLS certificates.
|
ca_file: Path to CA certificate file for TLS verification.
|
ca_path: Path to a directory containing CA certificates.
|
ca_data: CA certificate data as string or bytes.
|
client_cert_file: Path to client certificate for mutual TLS.
|
client_key_file: Path to a client private key for mutual TLS.
|
client_key_password: Password for an encrypted client private key.
|
auth_basic: Tuple of (username, password) for HTTP basic auth.
|
user_agent: User-Agent header value for requests.
|
|
The client supports both regular HTTPS with server verification and mutual TLS
|
authentication. For server verification, provide CA certificate information via
|
ca_file, ca_path or ca_data. For mutual TLS, additionally provide a client
|
certificate and key via client_cert_file and client_key_file.
|
ú/N)ÚendswithÚrstripÚbase_urlÚitemsr? Ú_default_headersÚtimeoutÚretryÚupdate_supported_errorsr r ÚsslÚSSLErrorÚ
|
verify_tlsÚca_fileÚca_pathÚca_dataÚclient_cert_fileÚclient_key_fileÚclient_key_passwordÚ
|
auth_basicÚ
|
user_agent)r, r^ r" ra rb rf rg rh ri rj rk rl rm rn ÚkÚvs r/ rP zHttpClient.__init__? sÖ ñZ × 1Ñ 1°#Ô 6ð OOÓ Ò #àð ð
|
<Cº=Àb×:OÑ:OÓ:Q× R±$°!°Q §¡£¨A¡ Ó RÔ Ø Ø
|
Ø
|
|
×*Ñ*¬I´xÄÇ Á Ð+NÔOØ$ð Ø Ø Ø 0Ô Ø .Ô Ø#6Ô à$Ø$ùó !Ss ÁC+c ó2 | j d||||d |¬« S )NÚGET©Úparamsr" ra ÚbodyÚ expect_json©Ú
|
_json_call©r, Úpathrt r" ra rv s r/ r< zHttpClient.get s/ ð Ø Ø ØØØØØ#ð ó
|
ð
|
r1 c ó2 | j d||||d |¬« S )NÚDELETErs rw ry s r/ ÚdeletezHttpClient.delete s/ ð Ø Ø ØØØØØ#ð ó
|
ð
|
r1 c óT | j d||||| j ||¬« |¬« S )NÚPOST©Ú json_bodyÚdatars ©rx Ú _prepare_body©r, rz r r rt r" ra rv s r/ ÚpostzHttpClient.post© s? ð Ø Ø ØØØØ×#Ñ#¨i¸dÐ#ÓCØ#ð ó
|
ð
|
r1 c óT | j d||||| j ||¬« |¬« S )NÚPUTr rs r r
s r/ ÚputzHttpClient.put¿ s? ð Ø Ø ØØØØ×#Ñ#¨i¸dÐ#ÓCØ#ð ó
|
ð
|
r1 c óT | j d||||| j ||¬« |¬« S )NÚPATCHr rs r r
s r/ ÚpatchzHttpClient.patchÕ s? ð Ø Ø ØØØØ×#Ñ#¨i¸dÐ#ÓCØ#ð ó
|
ð
|
r1 c ó, j ||« } j ||« }t |t « r|j d« n|} t ||j « | |¬« d |j « j d« r± j rut j j j j ¬« j rcj! j j" j$ ¬« n0t j « d_ t j( _ j, j/ fdd fd « S # t0 $ r§}
|
d
|
} |
|
j3 « } n# t4 $ r Y nw xY w|
|
j6 xs i j9 « D ci c] \ } } | j « | nc c} } w }} } j; | |« } t= |
|
d d « xs d }t? |||| ¬ « }|cY d }
|
~
|
S d }
|
~
|
ww xY w)Nr; )r$ Úmethodr r" Úhttps)ÚcafileÚcapathÚcadata)ÚcertfileÚkeyfileÚpasswordFc ó, j ¬« S )N)Úcontextra )Ú _make_request)r Úreqr, ra s r/ ú<lambda>z$HttpClient.request.<locals>.<lambda> s ø ×*Ñ*¨3¸ÈÐ*ÓQ r1 c ó t « S rD r )Ú_s r/ r z$HttpClient.request.<locals>.<lambda> s *, r1 c ó& j | « S rD )Ú_is_retryable_http_error)Úerrorr, s r/ r z$HttpClient.request.<locals>.<lambda> s ø d× ;Ñ ;¸EÓ B r1 r1 Úcoder ©r r" r$ r& ) Ú
|
_build_urlÚ_prepare_headersÚ
|
isinstancer# Úencoder Úupperr? r@ rf rd Úcreate_default_contextrg rh ri rj Úload_cert_chainrk rl Úcheck_hostnameÚ CERT_NONEÚ verify_moderb Úcall_with_retryr ÚreadÚ Exceptionr" r_ Ú_maybe_decompressÚgetattrr )r, r rz rt r" ru ra r$ Ú all_headersr ÚeÚerr_bodyro rp Ú headers_mapr Úresponser r s ` ` @@r/ ÚrequestzHttpClient.requestì sÍ û ð ood FÓ+Ø×+Ñ+¨G°TÓ: Ü'1°$¼Ô'<t{{7Ô#À$ä# f§l¡l£n¸4ÈÔUà,0Ø 99;× !Ñ ! 'Ô *Øä ×4Ñ4Ø <<Ø <<Ø <<ôð ×(Ò(Ø×+Ñ+Ø!%×!6Ñ!6Ø $× 4Ñ 4Ø!%×!9Ñ!9ð ,õ ô ×4Ñ4Ó6Ø).Ô&Ü&)§m¡mÔ#ð Ø::×-Ñ-ÞQÙ&ÛBóð øô
|
ò àHð Ø 668øÜ ò Ùð úà56·Y±Y²_À"×4KÑ4KÓ4M×N©D¨A¨q1779 a<ÑNùÓNKÑNØ×-Ñ-¨h¸ ÓDHÜ Q ¨Ó*Ò/¨aFÜ#Ø Ø#ØØ ô Hð Oûð! úsN Ä<&E# Å# HÅ,HÅ/F Å?HÆ F Æ HÆ F Æ $HÆ0G Ç =HÈHÈHc óz t ||xs | j |¬« 5 }|j « }|j j « D ci c] \ }}|j « | }}}| j ||« }t |j ||j « |¬« cd d d « S c c}}w # 1 sw Y y xY w)N)ra r r¡ )
|
r ra r r" r_ r? r¯ r r Úgeturl) r, r¶ r ra ÚrespÚrawro rp r´ s r/ r zHttpClient._make_request+ s¢ ô W gÒ&=°· ± ÀwÔ Oð ÐSWØ))+CØ48·L±L×4FÑ4FÓ4H×I©D¨A¨q1779 a<ÐIKÑIØ×(Ñ(¨¨kÓ:CÜ Ø{{Ø#ØKKMØô ÷ ñ ùãI÷ ð ús .B1Á B+Á&;B1Â+B1Â1B:c óZ t |t « r| j |j « S y)NF)r¤ r Ú_should_retry_statusr )r, r s r/ r z#HttpClient._is_retryable_http_error< s$ Ü eYÔ 'Ø×,Ñ,¨U¯Z©ZÓ8Ð 8Ør1 c óä | j ||||||¬« }d|j cxk rdk s1n t |j |j |j « « |r|j « S |S )N)r rz rt r" ru ra éÈ i )r¶ r r r$ r0 r3 ) r, r rz rt r" ra ru rv r¹ s r/ rx zHttpClient._json_callB sm ð ||ØØØØØØð ó
|
ð t{{Ô( SÔ(ÜDKK¨¯©°4·9±9³;Ó?Ð ?Ù Ø99;Ð Ø r1 c óX | | t d« |t j |dd¬« S |S )Nz+Provide either json_body or data, not both.F)ú,ú:)Ú ensure_asciiÚ
|
separators)Ú
|
ValueErrorr3 Údumps)r, r r s r/ r zHttpClient._prepare_body\ s9 ð Ð TÐ%5Ü Ð JÓKÐ KØ Ð Ü::i°eÈ
|
ÔSÐ SØ r1 c óÖ t | j xs d|« }|rFt |j « D ci c] \ }}| || c}}d¬« }d|v rdnd}|r| | | n|}|S c c}}w )Nr7 T)Údoseqú?ú&)r r^ r r_ )r, rz rt r$ ro rp ÚqueryÚ separators r/ r¢ zHttpClient._build_urle sx ô dmmÒ) r¨4Ó0Ù ä Ø"(§,¡,£.×B$!Q°A±MAÓBÈ$ôEð !$ s¡
|
°IÙ05SE) U GÑ,¸3CØ
|
ùó Cs µ
|
A%
|
Á A%
|
c ó i }|j | j « |j dd« |j d| j « |j dd« |"t |t
|
« r|j dd« | j rSd|vrO| j \ }}t j | d | j d
|
« « j d « }d | |d< |r+|j « D ] \ }}|||j « < |S ) NÚacceptzapplication/jsonz
|
user-agentzaccept-encodingz gzip, deflater6 z application/json; charset=utf-8Ú authorizationrÁ r; ÚasciizBasic ) Úupdater` Ú
|
setdefaultrn r¤ r# rm Úbase64Ú b64encoder¥ r+ r_ r? ) r, r" ru ÚpreparedÚuserÚpwdÚtokenro rp s r/ r£ zHttpClient._prepare_headersv s ð $&Ø×-Ñ-Ô.ð ×ÑHÐ&8Ô9Ø×ÑL¨$¯/©/Ô:à×ÑÐ -¨Ô?ð Ð ¤
|
¨4´Ô 5Ø × Ñ Ð0QÔ Rð ??°hÑ >Ø ID#Ü×$Ñ$¨ v¨Q¨s¨e _×%;Ñ%;¸GÓ%DÓE×LÑLÈWÓUEØ*0°°Ð(8H_Ñ %ñ Ø ò (1Ø&'Ò#ð (ð
|
r1 c ó |t v S rD )ÚRETRY_STATUS_CODES)r, r s r/ r¼ z HttpClient._should_retry_status s ØÔ+Ð+Ð+r1 c ó\ |s|S |j d« xs dj « } d|v rt j |« S d|v r& t j |t j
|
« S |S # t j $ r t j |« cY S w xY w# t $ r |cY S w xY w)Nzcontent-encodingr7 ÚgzipÚdeflate)r< r? rÛ Ú
|
decompressÚzlibÚ MAX_WBITSr r® )r, r& r" r- s r/ r¯ z HttpClient._maybe_decompress sª ÙØNØKKÐ 2Ó3Ò9°r×@Ñ@ÓBð ØÑ!Ü wÓ/Ð/ØHÑ$ð4Ü ??¨7´T·^±^°OÓDÐDð %ð øô zzò 4Ü ??¨7Ó3Ò3ð4ûäò àNð ús5 ©B ÁB Á$A/ Á/(BÂB ÂBÂB Â B+Â*B+) r^ r# r" úOptional[Mapping[str, str]]ra Úfloatrb r rf Úboolrg rE rh rE ri zOptional[Union[str, bytes]]rj rE rk rE rl rE rm zOptional[Tuple[str, str]]rn r# rF ÚNone)NNNT) rz r# rt úGOptional[Mapping[str, Union[None, str, int, float, bool, list, tuple]]]r" rà ra úOptional[float]rv râ rF úUnion[HttpResponse, Any])NNNNNT)rz r# r ú Optional[Any]r úOptional[Union[bytes, str]]rt rä r" rà ra rå rv râ rF ræ )NNNN)r r# rz r# rt rä r" rà ru rè ra rå rF r )NN)r¶ r r zOptional[ssl.SSLContext]ra rå )r r® rF râ )NNNNT)r r# rz r# rt rä r" rà ra rå ru rè rv râ rF ræ )r rç r rè rF rè rD )rz r# rt rä rF r# )r" rà ru rè rF r! )r r rF râ )r& r% r" zMapping[str, str]rF r% )rG rH rI Ú__doc__r r r ÚDEFAULT_USER_AGENTrP r< r} r r r r¶ r r rx r r¢ r£ r¼ r¯ rK r1 r/ r r : s ñð Ø/3Ø(Ù Ù0°a¸RÔ@È!ô
|
ð à!%Ø!%Ø/3à*.Ø)-Ø-1Ø04Ø,ð%?%àð?%ð -ð?%ð ð ?%ð
|
ð ?%ð ð?%ð ð?%ð ð?%ð -ð?%ð (ð ?%ð 'ð ?%ð +ð!?%ð" .ð#?%ð$ ð%?%ð&
|
ó'?%ðN Ø/3Ø#'Ø ð
|
àð
|
ð
|
ð
|
ð -ð
|
ð !ð
|
ð ð
|
ð
|
"ó
|
ð2 Ø/3Ø#'Ø ð
|
àð
|
ð
|
ð
|
ð -ð
|
ð !ð
|
ð ð
|
ð
|
"ó
|
ð. $(Ø,0ð Ø/3Ø#'Ø ð
|
àð
|
ð !ð
|
ð *ð
|
ð
|
|
ð
|
ð -ð
|
ð !ð
|
ð ð
|
ð
|
"ó
|
ð2 $(Ø,0ð Ø/3Ø#'Ø ð
|
àð
|
ð !ð
|
ð *ð
|
ð
|
|
ð
|
ð -ð
|
ð !ð
|
ð ð
|
ð
|
"ó
|
ð2 $(Ø,0ð Ø/3Ø#'Ø ð
|
àð
|
ð !ð
|
ð *ð
|
ð
|
|
ð
|
ð -ð
|
ð !ð
|
ð ð
|
ð
|
"ó
|
ð: Ø/3Ø,0Ø#'ð= àð= ð ð= ð
|
ð = ð -ð= ð *ð= ð !ð= ð
|
ó= ðD -1Ø#'ð àðð *ðð !ó ó"ð Ø/3Ø#'Ø,0Ø ðàðð ðð
|
ð ð -ðð !ðð *ðð ðð
|
"óð6 TXðØ&ðØ5Pðà $óð ð àðð
|
ðð
|
ó ð" Ø2ð Ø:Uð à ó ó@,ôr1 r )'Ú
|
__future__r rÒ rÛ r3 rd rÞ Ú dataclassesr Útypingr r r r r r
|
Ú urllib.errorr r Ú urllib.parser r Úurllib.requestr r Ú__all__Ú redis.backoffr Ú redis.retryr Ú redis.utilsr rê r rÙ r r® r r rK r1 r/ ú<module>rõ sy ðÝ "ã Û Û Û
|
Û Ý !ß =× =ß ,ß +ß +â
|
Hå 6Ý Ý "à@Ð ØÚ.Ð ð ÷ð ó ðô0' ô '÷oò or1
|
