Ë
|
|
çúh ã ó d dl Z d dlmZmZ d dlmZ d dlmZmZm Z m
|
Z
|
d dl m Z m Z dZdZh d£Z G d d
|
e« Z G d d e« Zy) é N)ÚABCÚabstractmethod)ÚThreadPoolExecutor)ÚAnyÚMappingÚOptionalÚUnion)Ú
|
HttpClientÚ HttpResponsez)HttpClient/1.0 (+https://example.invalid)g >@> é éô éö é÷ éø c óL e Zd Ze ddedeeeedeee e
|
e e f f deeeef dee de
|
dee ef f d« Ze ddedeeeedeee e
|
e e f f deeeef dee de
|
dee ef f d « Ze dded
|
ee d eeeef deeeedeee e
|
e e f f deeeef dee de
|
dee ef fd « Ze dded
|
ee d eeeef deeeedeee e
|
e e f f deeeef dee de
|
dee ef fd « Ze dded
|
ee d eeeef deeeedeee e
|
e e f f deeeef dee de
|
dee ef fd« Ze ddededeeeedeee e
|
e e f f deeeef deeeef dee de fd« Zy)ÚAsyncHTTPClientNÚpathÚparamsÚheadersÚtimeoutÚ expect_jsonÚreturnc ó K yw)z!
|
Invoke HTTP GET request.N© ©Úselfr r r r r s õq H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/http/http_client.pyÚgetzAsyncHTTPClient.get ó è ø ð ùó c ó K yw)z$
|
Invoke HTTP DELETE request.Nr r s r ÚdeletezAsyncHTTPClient.delete r r Ú json_bodyÚdatac ó K yw)z"
|
Invoke HTTP POST request.Nr ©r r r# r$ r r r r s r ÚpostzAsyncHTTPClient.post, ó è ø ð ùr c ó K yw)z!
|
Invoke HTTP PUT request.Nr r& s r ÚputzAsyncHTTPClient.put= r( r c ó K yw)z#
|
Invoke HTTP PATCH request.Nr r& s r ÚpatchzAsyncHTTPClient.patchN r( r ÚmethodÚbodyc ó K yw)z/
|
Invoke HTTP request with given method.Nr )r r- r r r r. r s r ÚrequestzAsyncHTTPClient.request_ s è ø ð ùr ©NNNT©NNNNNT©NNNN)Ú__name__Ú
|
__module__Ú __qualname__r Ústrr r r ÚintÚfloatÚboolÚlistÚtupler r r r" Úbytesr' r* r, r0 r ó r r r sL Øð Ø/3Ø#'Ø ñ àð ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð % ð ð ð ð
|
|SÐ Ñ !ò ó ð ð ð Ø/3Ø#'Ø ñ àð ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð % ð ð ð ð
|
|SÐ Ñ !ò ó ð ð ð $(Ø,0ð Ø/3Ø#'Ø ñ àð ð C=ð ð uU CZÑ(Ñ)ð ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð % ð ð ð ð
|
|SÐ Ñ !ò ó ð ð ð $(Ø,0ð Ø/3Ø#'Ø ñ àð ð C=ð ð uU CZÑ(Ñ)ð ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð % ð ð ð ð
|
|SÐ Ñ !ò ó ð ð ð $(Ø,0ð Ø/3Ø#'Ø ñ àð ð C=ð ð uU CZÑ(Ñ)ð ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð % ð ð ð ð
|
|SÐ Ñ !ò ó ð ð ð Ø/3Ø,0Ø#'ñ àð ð ð ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð ð ' # s (Ñ+Ñ,ð ð uU CZÑ(Ñ)ð ð % ð ð
|
ò ó ñ r> r c ó* e Zd ZdZddededdfdZ ddedee ee
|
deee e e ef f d ee eef d
|
ee d e de
|
eef f d Z ddedee ee
|
deee e e ef f d ee eef d
|
ee d e de
|
eef f d Z ddedee dee
|
eef dee ee
|
deee e e ef f d ee eef d
|
ee d e de
|
eef fdZ ddedee dee
|
eef dee ee
|
deee e e ef f d ee eef d
|
ee d e de
|
eef fdZ ddedee dee
|
eef dee ee
|
deee e e ef f d ee eef d
|
ee d e de
|
eef fdZ ddededee ee
|
deee e e ef f d ee eef dee
|
eef d
|
ee defdZy)ÚAsyncHTTPClientWrapperzN
|
An async wrapper around sync HTTP client with thread pool execution.
|
ÚclientÚ max_workersr Nc ó4 || _ t |¬« | _ y)aÿ
|
Initialize a new HTTP client instance.
|
|
Args:
|
client: Sync HTTP client instance.
|
max_workers: Maximum number of concurrent 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.
|
)rB N)rA r Ú _executor)r rA rB s r Ú__init__z AsyncHTTPClientWrapper.__init__u s ð Ü+¸ ÔDr> r r r r r c ó° K t j « }|j | j | j j
|
|||||« d { S 7 w©N)ÚasyncioÚget_event_loopÚrun_in_executorrD rA r ©r r r r r r Úloops r r zAsyncHTTPClientWrapper.get
sN è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNDKKOO¨T°6¸7ÀGÈ[ó
|
÷
|
ð
|
ð
|
úó A AÁAÁAc ó° K t j « }|j | j | j j
|
|||||« d { S 7 wrG )rH rI rJ rD rA r" rK s r r" z AsyncHTTPClientWrapper.delete sV è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNØ KK× Ñ Ø Ø Ø Ø Ø ó
|
÷
|
ð
|
ð
|
úrM r# r$ c ó´ K t j « }|j | j | j j
|
|||||||« d { S 7 wrG )rH rI rJ rD rA r' © r r r# r$ r r r r rL s r r' zAsyncHTTPClientWrapper.post© s\ è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNØ KK× Ñ Ø Ø Ø Ø Ø Ø Ø ó
|
|
÷
|
|
ð
|
|
ð
|
|
úó AAÁAÁAc ó´ K t j « }|j | j | j j
|
|||||||« d { S 7 wrG )rH rI rJ rD rA r* rP s r r* zAsyncHTTPClientWrapper.put sZ è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNØ KKOOØ Ø Ø Ø Ø Ø Ø ó
|
|
÷
|
|
ð
|
|
ð
|
|
úrQ c ó´ K t j « }|j | j | j j
|
|||||||« d { S 7 wrG )rH rI rJ rD rA r, rP s r r, z AsyncHTTPClientWrapper.patchÛ s\ è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNØ KK× Ñ Ø Ø Ø Ø Ø Ø Ø ó
|
|
÷
|
|
ð
|
|
ð
|
|
úrQ r- r. c
|
ó² K t j « }|j | j | j j
|
||||||« d { S 7 wrG )rH rI rJ rD rA r0 )r r- r r r r. r rL s r r0 z AsyncHTTPClientWrapper.requestô sY è ø ô ×%Ñ%Ó'Ø×)Ñ)Ø NNØ KK× Ñ Ø Ø Ø Ø Ø Ø ó
|
÷
|
ð
|
ð
|
ús AAÁAÁA)é
|
r1 r2 r3 )r4 r5 r6 Ú__doc__r
|
r8 rE r7 r r r r9 r: r; r< r r r r" r= r' r* r, r0 r r> r r@ r@ p s ññEzð E¸ð EÀTó Eð* Ø/3Ø#'Ø ñ
|
àð
|
ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð % ð
|
ð ð
|
ð
|
|SÐ Ñ !ó
|
ð( Ø/3Ø#'Ø ñ
|
àð
|
ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð % ð
|
ð ð
|
ð
|
|SÐ Ñ !ó
|
ð0 $(Ø,0ð Ø/3Ø#'Ø ñ
|
àð
|
ð C=ð
|
ð uU CZÑ(Ñ)ð
|
ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð % ð
|
ð ð
|
ð
|
|SÐ Ñ !ó
|
ð8 $(Ø,0ð Ø/3Ø#'Ø ñ
|
àð
|
ð C=ð
|
ð uU CZÑ(Ñ)ð
|
ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð % ð
|
ð ð
|
ð
|
|SÐ Ñ !ó
|
ð8 $(Ø,0ð Ø/3Ø#'Ø ñ
|
àð
|
ð C=ð
|
ð uU CZÑ(Ñ)ð
|
ð
|
Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð % ð
|
ð ð
|
ð
|
|SÐ Ñ !ó
|
ð> Ø/3Ø,0Ø#'ñ
|
àð
|
ð ð
|
ð Ø Ct S¨#¨u°d¸DÀ%Ð GÑHÐHÑ Iñ
|
ð
|
ð ' # s (Ñ+Ñ,ð
|
ð uU CZÑ(Ñ)ð
|
ð % ð
|
ð
|
ô
|
r> r@ )rH Úabcr r Úconcurrent.futuresr Útypingr r r r Úredis.http.http_clientr
|
r ÚDEFAULT_USER_AGENTÚDEFAULT_TIMEOUTÚRETRY_STATUS_CODESr r@ r r> r ú<module>r^ sE ðÛ ß #Ý 1ß 0Ó 0ç ;à@Ð ØÚ.Ð ô` cô ` ôFY
|
_õ Y
|
r>
|
