Ë
|
|
çúhÉ ã óâ U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
|
m Z d dl m Z d dlmZmZmZmZmZmZmZmZmZmZmZmZmZ d dl m Z m Z m Z m Z ddl!m"Z" e"rd dl#Z#d d l#m$Z$m%Z%m&Z& ndZ#dZ%dZ$dZ&dd
|
l'm(Z( dd l)m*Z*m+Z+ dd l!m,Z,m-Z- ej\ d k\ rd dl m/Z0 nd dl0m/Z0 d dl1m2Z2 d dl3m4Z4 d dl5m6Z6 d dl7m8Z8m9Z9 d dl:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZA d dlBmCZC d dlDmEZEmFZFmGZG ddlHmIZImJZJmKZKmLZLmMZM dZNdZOdZPdZQdZR G d d ej¦ « ZTeTjª ZVeeeLeMeKf eWd < eEreKZXneLZX G d d e« ZY G d! d"e« ZZeeYeZf Z[ G d# d$« Z\ G d% d&e\« Z] G d' d(e]« Z^ G d) d*« Z_ G d+ d,e\« Z`d-Zad.eeb fd/Zcd0 Zd e eeefefececeeeeecededefd1 « Zgeehed2eif f eWd3< G d4 d5ed6¬7« Zjd8ehd.ejfd9Zk ed:d;¬<« Zl G d= d;« Zm G d> d?em« Zny)@é N)Úabstractmethod)Úchain)ÚMappingProxyType) ÚAnyÚCallableÚIterableÚListÚMappingÚOptionalÚProtocolÚSetÚTupleÚTypeÚ TypedDictÚTypeVarÚUnion)Ú ParseResultÚparse_qsÚunquoteÚurlparseé )Ú SSL_AVAILABLE)Ú
|
SSLContextÚ
|
TLSVersionÚ VerifyFlags)ÚTokenInterface)Ú!AsyncAfterConnectionReleasedEventÚEventDispatcher)Údeprecated_argsÚformat_error_message)é é r! )Útimeout)ÚRetry)Ú NoBackoff)ÚDEFAULT_RESP_VERSION)ÚCredentialProviderÚ"UsernamePasswordCredentialProvider)ÚAuthenticationErrorÚ$AuthenticationWrongNumberOfArgsErrorÚConnectionErrorÚ DataErrorÚ
|
RedisErrorÚ ResponseErrorÚ TimeoutError)Ú
|
EncodableT)ÚHIREDIS_AVAILABLEÚget_lib_versionÚ str_if_bytes)Ú
|
BaseParserÚEncoderÚ_AsyncHiredisParserÚ_AsyncRESP2ParserÚ_AsyncRESP3Parseró *ó $s
|
ó
|
ó c ó e Zd Z e« Zy)Ú _SentinelN)Ú__name__Ú
|
__module__Ú __qualname__ÚobjectÚsentinel© r< õk H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/connection.pyr> r> R s ÙxHr< r> Ú DefaultParserc ó e Zd ZddZy)ÚConnectCallbackProtocolc ó y ©NrD ©ÚselfÚ
|
connections rE Ú__call__z ConnectCallbackProtocol.__call__a s r< N©rM ÚAbstractConnection©r? r@ rA rN rD r< rE rH rH ` s Ü=r< rH c ó e Zd ZddZy)Ú AsyncConnectCallbackProtocolc ó K y wrJ rD rK s rE rN z%AsyncConnectCallbackProtocol.__call__e s è ø ùó NrO rQ rD r< rE rS rS d s ÜCr< rS c . óö e Zd ZdZdZdddddedddedddd e« dddedd
|
dd d e e
|
e f d e e
|
de e de e dede eef de
|
de
|
dedee de de de e
|
de e
|
de e
|
de e
|
d e e d e e d ee d e e d e e d!e e f,d"Zefd#efd$Zd% Zd& Z e d' « Z e d( « Z d) Z!d* Z"dee d+dfd,Z#d- Z$ dUd/ed0efd1Z%d2 Z&d3 Z'e d4 « Z(e d+e
|
fd5« Z)d6e*d+e
|
fd7Z+d8 Z,dVd9Z-dWd/ed+dfd:Z.dXd;ed+dfd<Z/d= Z0d> Z1d? Z2d@e3e4 d+dfdAZ5 dWd@e e4e
|
e3e4 f d/ed+dfdBZ6dCedDed+dfdEZ7dF Z8 dYd.ddGdHedIe e dJedKe e fdLZ9dCe:d+e;e4 fdMZ<dNe3e3e: d+e;e4 fdOZ=dP Z>dQ Z?dRe@fdSZAdT ZBy)ZrP z0Manages communication to and from a Redis server)ÚdbÚusernameÚ client_nameÚlib_nameÚ lib_versionÚcredential_providerÚpasswordÚsocket_timeoutÚsocket_connect_timeoutÚredis_connect_funcÚretry_on_timeoutÚretry_on_errorÚhealth_check_intervalÚnext_health_checkÚlast_active_atÚencoderÚ ssl_contextÚprotocolÚ_readerÚ_writerÚ_parserÚ_connect_callbacksÚ_buffer_cutoffÚ_lockÚ_socket_read_sizeÚ__dict__r NFúutf-8Ústricti zredis-pyr )rW r] r^ r_ ra rb ÚencodingÚencoding_errorsÚdecode_responsesÚ parser_classÚsocket_read_sizerc rY rZ r[ rX Úretryr` Ú encoder_classr\ rh Úevent_dispatcherrW r] r^ r_ ra rb rs rt ru rv rw rc rY rZ r[ rX rx r` ry r\ rh rz c óD |s|r | t d« |t « | _ n|| _ || _ | | _ || _ || _ || _ || _ || _ || _
|
||}|| _ || _ |t u rg }|rS|j t « |j t j" « |j t$ j « || _ |s|rR|st) t+ « d« | _ nt/ j0 |« | _ | j, j3 |« nt) t+ « d« | _ | | _ d| _ |||| « | _ || _ d | _ d | _ | | _ | jC |
|
« g | _" d| _# d | _$ d| _% tM |« }|dk s|d kD r tU d
|
« || _+ y # tN $ r tP }Y .tR $ r tU d« w xY w# dk s|d kD r tU d
|
« || _+ w xY w) NzÂ'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments:
|
1. 'password' and (optional) 'username'
|
2. 'credential_provider'é r éÿÿÿÿip Fzprotocol must be an integerr r! z protocol must be either 2 or 3),r, r Ú_event_dispatcherrW rY rZ r[ r\ r] rX r^ r_ ra ÚSENTINELÚappendr/ Úsocketr# Úasynciorb r$ r% rx ÚcopyÚdeepcopyÚupdate_supported_errorsrc rd rf r` ri rj ro Ú
|
set_parserrl rm Ú_re_auth_tokenÚ_should_reconnectÚintÚ TypeErrorr& Ú
|
ValueErrorr+ rh )rL rW r] r^ r_ ra rb rs rt ru rv rw rc rY rZ r[ rX rx r` ry r\ rh rz Úps rE Ú__init__zAbstractConnection.__init__ s ñ4 Ð&9Ð&EÜð+óð ð Ð #Ü%4Ó%6DÕ "à%5DÔ "ØØ&ÔØ Ø&ÔØ#6Ô Ø Ø Ø ,ÔØ !Ð )Ø%3Ð "Ø&<Ô#Ø 0Ô Ø XÑ %Ø NÙ Ø × !Ñ !¤,Ô /Ø × !Ñ !¤&§.¡.Ô 1Ø × !Ñ !¤'×"6Ñ"6Ô 7Ø ,ÔÙ NÙÜ "¤9£;°Ó 2
|
ô "]]¨5Ó 1
|
à JJ× .Ñ .¨~Õ >ä y{¨AÓ.DJØ%:Ô"Ø(*Ô Ù$ X¨Ð@PÓQ Ø"4Ô Ø7; Ø7; Ø!1Ô Ø Ô%ØNPÔ Ø "ÔØ8<ÔØ!&Ô ð %ÜH Að 1uAÜ%Ð&FÓGÐGØ $DMøô ò %Ü$AÜò AÜ!Ð"?Ó@Ð @ð Aûð 1uAÜ%Ð&FÓGÐGØ $DMús$ Æ1 G ÇG>Ç(H Ç*G>Ç>H È H Ú _warningsc ó¾ t | dd « rA|j d| t | ¬« t j « | j « y y # t $ r Y y w xY w)Nrj zunclosed Connection )Úsource)ÚgetattrÚwarnÚResourceWarningr Úget_running_loopÚ_closeÚ RuntimeError)rL r s rE Ú__del__zAbstractConnection.__del__å sb ô 4 DÔ )Ø NNØ& t hÐ/´ Èð ô ð Ü×(Ñ(Ô*Ø ð *øô ò áð ús ª$A Á A ÁA c ón | j r)| j j « dx| _ | _ yy)zR
|
Internal method to silently close the connection without waiting
|
N)rj Úcloseri ©rL s rE r zAbstractConnection._closeõ s. ð <<Ø LL× Ñ Ô Ø*.Ð .DL4<ð r< c ó¶ dj d | j « D « « }d| j j d| j j d| dS )Nú,c 3 ó0 K | ] \ }}| d | yw)ú=NrD )Ú.0ÚkÚvs rE ú <genexpr>z.AbstractConnection.__repr__.<locals>.<genexpr>þ s è ø Ò H©T¨Q° 1 Q CjÑ Hùs ú<ú.ú(z)>)ÚjoinÚ repr_piecesÚ __class__r@ r? )rL Ú repr_argss rE Ú__repr__zAbstractConnection.__repr__ý sQ ØHHÑ H°T×5EÑ5EÓ5GÔ HÓI Ø4>>×,Ñ,Ð-¨Q¨t¯~©~×/FÑ/FÐ.GÀqÈÈ ÐSUÐVÐVr< c ó y rJ rD r s rE r§ z AbstractConnection.repr_pieces ó à r< c ó> | j d uxr | j d uS rJ )ri rj r s rE Ú is_connectedz AbstractConnection.is_connected s à|| 4Ð'ÒD¨D¯L©LÀÐ,DÐDr< c ó t j |« }|| j vr | j j |« yy)a^
|
Register a callback to be called when the connection is established either
|
initially or reconnected. This allows listeners to issue commands that
|
are ephemeral to the connection, for example pub/sub subscription or
|
key tracking. The callback must be a _method_ and will be kept as
|
a weak reference.
|
N)ÚweakrefÚ
|
WeakMethodrl r )rL ÚcallbackÚwms rE Úregister_connect_callbackz,AbstractConnection.register_connect_callback s; ô × Ñ Ó )Ø T×,Ñ,Ñ ,Ø × #Ñ #× *Ñ *¨2Õ .ð -r< c ó | j j t j |« « y# t $ r Y yw xY w)z÷
|
De-register a previously registered callback. It will no-longer receive
|
notifications on connection events. Calling this is not required when the
|
listener goes away, since the callbacks are kept as weak methods.
|
N)rl Úremover° r± r )rL r² s rE Úderegister_connect_callbackz.AbstractConnection.deregister_connect_callback s8 ð Ø × #Ñ #× *Ñ *¬7×+=Ñ+=¸hÓ+GÕ HøÜò Ù ð ús .1 ± =¼=Úreturnc ó4 || j ¬« | _ y)zË
|
Creates a new instance of parser_class with socket size:
|
_socket_read_size and assigns it to the parser for the connection
|
:param parser_class: The required parser class
|
)rw N)ro rk )rL rv s rE r z AbstractConnection.set_parser s ñ $°T×5KÑ5KÔL r< c óD K | j d¬« d{ y7 w)z5Connects to the Redis server if not already connectedT©Ú check_healthN)Úconnect_check_healthr s rE ÚconnectzAbstractConnection.connect( s è ø à×'Ñ'°TÐ'Ó:×:Ò:úó Tr¼ Úretry_socket_connectc óà K j ry |r+ j j fd fd« d { n j « d { j s j |¬« d { nIt j j « r j « d { n j « j$ D cg c] } |« s | c} _ j$ D ]4 } |« } | « }|st' j( |« s+| d { 6 y 7 ù7 â# t j
|
$ r t j t j f$ r t d« t $ r }t j |« « d }~wt $ r}t |« |d }~ww xY w7 A7 # t $ r j# « d { 7 w xY wc c}w 7 Àw)Nc ó$ j « S rJ )Ú_connectr s rE ú<lambda>z9AbstractConnection.connect_check_health.<locals>.<lambda>4 s ø DMMO r< c ó$ j « S rJ ©Ú
|
disconnect©ÚerrorrL s rE rÄ z9AbstractConnection.connect_check_health.<locals>.<lambda>4 s ø ¸4¿?¹?Ó;L r< z Timeout connecting to serverr» )r® rx Úcall_with_retryrà r ÚCancelledErrorr r# r/ ÚOSErrorr+ Ú_error_messageÚ Exceptionr` Úon_connect_check_healthÚiscoroutinefunctionr- rÇ rl ÚinspectÚ isawaitable)rL r¼ rÀ ÚeÚexcÚrefr² Útasks ` rE r½ z'AbstractConnection.connect_check_health, sÁ øè ø ð × Ò Ø ð 0Ù#Øjj×0Ñ0Û+Ó-Ló÷ ñ ð mmo×%Ð%ð Ø×*Ò*à×2Ñ2À Ð2ÓM×MÑMô
|
×2Ñ2°4×3JÑ3JÔKð ×1Ñ1°$Ó7×7Ð7à ×0Ñ0°Ó6øð 37×2IÑ2IÖ"S¨3ÉSÍU¢3Ò"SÔ Ø×*Ñ*ò CÙuHÙD>DÚ×+Ñ+¨DÕ1Ø
|
|
ñ ðEøð &ùÜ×%Ñ%ò Ø Ü¤× 4Ñ 4Ð5ò ?Ü Ð =Ó>Ð >Üò :Ü! $×"5Ñ"5°aÓ"8Ó9Ð 9ûÜò 0Ü! #Ó&¨CÐ /ûð 0úð Nùð 8úô ò à//Ó#× #Ñ #Ø ð üò #Tð
|
úsà G.'D7 ¹D3ºD7 ÁD5ÁD7 Á!G Á9F:Á:8G Â2F=Â3G ÃG.à G'Ã#G'Ã'(G.ÄG.Ä&G.Ä+G,Ä,G.Ä3D7 Ä5D7 Ä7A F7Æ FÆ F7Æ& F2Æ2F7Æ7G.Æ:G Æ=G Ç G$Ç G Ç G$Ç$ G.c ó d| _ y )NT©r r s rE Úmark_for_reconnectz%AbstractConnection.mark_for_reconnect[ s
|
Ø!%Õ r< c ó | j S rJ rØ r s rE Úshould_reconnectz#AbstractConnection.should_reconnect^ s Ø×%Ñ%Ð%r< c ó K y wrJ rD r s rE rà zAbstractConnection._connecta s è ø à ùrU c ó y rJ rD r s rE Ú _host_errorz AbstractConnection._host_errore r¬ r< Ú exceptionc ó6 t | j « |« S rJ )r rÞ )rL rß s rE rÍ z!AbstractConnection._error_messagei s Ü# D×$4Ñ$4Ó$6¸ ÓBÐBr< c ó | j S rJ )rh r s rE Ú get_protocolz AbstractConnection.get_protocoll s Ø}}Ð r< c óD K | j d¬« d{ y7 w)z=Initialize the connection, authenticate and select a databaseTr» N)rÏ r s rE Ú
|
on_connectz AbstractConnection.on_connecto s è ø à×*Ñ*¸Ð*Ó=×=Ò=úr¿ c ór K | j j | « | j }d }| j s| j s | j rF| j xs t | j | j « }|j « d { }|r&| j dvrt | j t « rK| j t « |j | j _ | j j | « t |« dk( rd|d g} | j d| j dg|¢ddi d { | j « d { }|j! d « t# | j « k7 r6|j! d
|
« t# | j « k7 rt% d « |rP | j dg|¢ddi d { | j « d { }t) |« dk7 r¼t+ d« | j dvr£t | j t « rK| j t « |j | j _ | j j | « | j d| j |¬ « d { | j « d { }| j, rV| j dd| j, |¬ « d { t) | j « d { « dk7 r t% d« | j. r(| j ddd| j. |¬ « d { | j0 r(| j ddd| j0 |¬ « d { | j2 r&| j d| j2 |¬ « d { d | j. | j0 fD « D ] } | j « d { | j2 r0t) | j « d { « dk7 r t% d« y y 7 §7 ô7 ß7 g7 Q# t& $ r= | j d|d d¬ « d { 7 | j « d { 7 }Y w xY w7 ë7 Ö7 ¦7 7 I7 7 è7 ¯# t4 $ r Y Ôw xY w7 w)N)r Ú2r| Údefaultr ÚHELLOÚAUTHr¼ Fs protoÚprotozInvalid RESP versionr} r» ÚOKz Invalid Username or PasswordÚCLIENTÚSETNAMEzError setting client nameÚSETINFOzLIB-NAMEzLIB-VERÚSELECTc 3 ó& K | ] }|s| y wrJ rD )r Úsents rE r¢ z=AbstractConnection.on_connect_check_health.<locals>.<genexpr>Õ s è ø ÒM4Ê$ÑMùs zInvalid Database)rk rä r\ rX r] r( Úget_credentials_asyncrh Ú
|
isinstancer7 r r8 ÚEXCEPTION_CLASSESÚlenÚ send_commandÚ read_responseÚgetr r+ r* r3 r) rY rZ r[ rW r. )rL r¼ ÚparserÚ auth_argsÚ cred_providerÚresponseÚ auth_responseÚ_s rE rÏ z*AbstractConnection.on_connect_check_healths sd è ø Ø × Ñ Ô%Ø à à × #Ò #¨¯ ª ¸¿ º à×(Ñ(ò TÜ5°d·m±mÀTÇ]Á]ÓSð ð ,× AÑ AÓ C×CIò ¨hÒ6Ü$,,Ô(9Ô:ØÔ 1Ô2à17×1IÑ1I Ô.Ø ×'Ñ'¨Ô-Ü9~ Ò"Ø &¨ °!© Ð 5 ð $$×#Ñ#Ø ¨ðØ1:òØINñ÷ ð ð "× /Ñ /Ó 1×1HØ||HÓ%¬¨T¯]©]Ó);Ó;ÀÇ Á ØóAäT]]Ó#óA$ô &Ð&<Ó=Ð=ñ Ø#$×#Ñ# FÐK¨YÒKÀUÑK× KÐ Kð ;Ø&*×&8Ñ&8Ó&:× : ô MÓ*¨dÒ2Ü)Ð*HÓIÐIð ]] (Ñ *Ü$,,Ô(9Ô:ØÔ 1Ô2à17×1IÑ1I Ô.Ø ×'Ñ'¨Ô-Ø×#Ñ# G¨T¯]©]È Ð#ÓV× VÐ VØ !× /Ñ /Ó 1×1Hð × Ò Ø×#Ñ#ØØØ× Ñ Ø )ð $ó ÷ ð ô $×"4Ñ"4Ó"6× 6Ó7¸4Ò?Ü%Ð&AÓBÐBð ==Ø×#Ñ#ØØØØ Ø )ð $ó ÷ ð ð × Ò Ø×#Ñ#ØØØØ× Ñ Ø )ð $ó ÷ ð ð 77Ø×#Ñ# H¨d¯g©gÀLÐ#ÓQ× QÐ Qñ N D§M¡M°4×3CÑ3CÐ#DÔMò Að Ø×(Ñ(Ó*×*Ñ*ð ð 77Ü $×"4Ñ"4Ó"6× 6Ó7¸4Ò?Ü%Ð&8Ó9Ð9ð @ð ð{ Dùð ùð 2ùð Lùð !;úÜ7ò ;ð
|
×'Ñ'¨° ¸"± ÈEÐ'ÓR×RÑRØ&*×&8Ñ&8Ó&:× :Ð : ð ;úð$ WùØ1ùð ùð 7ùð
|
ùð ùð Røð
|
+ùÜ ò Ùð úð 7úsT BR7ÂP8ÂB5R7ÅP;ÅR7Å P>Å A:R7ÇQÇR7Ç Q Ç3QÇ4Q Ç8B-R7Ê%RÊ&R7Ê=RÊ>2R7Ë0RË1 R7Ì RÌAR7ÍR Í3R7ÎR Î1R7Î9R"Î:&R7Ï!R&Ï4R$Ï5R&Ï9&R7Ð R5Ð R7Ð;R7Ð>R7ÑR7ÑQ Ñ#R Ñ*Q-Ñ+R ÒRÒR Ò R7Ò R Ò R7ÒR7ÒR7ÒR7Ò R7Ò R7Ò"R7Ò$R&Ò& R2Ò/R7Ò1R2Ò2R7Únowaitc óR K t | j « 4 d{ | j j « | j s ddd« d{ y | j
|
j « |s"| j
|
j « d{ d| _ d| _ ddd« d{ y7 7 e7 '# t $ r Y 0w xY w# d| _ d| _ w xY w7 -# 1 d{ 7 sw Y yxY w# t j $ r t d| j « dw xY ww)z!Disconnects from the Redis serverNz#Timed out closing connection after ) Ú async_timeoutr_ rk Ú on_disconnectr® rj r Ú wait_closedrÌ ri r r/ )rL rÿ s rE rÇ z AbstractConnection.disconnectß s è ø ð Ü$ T×%@Ñ%@ÓA÷ (ñ (Ø ×*Ñ*Ô,Ø×(Ò(Ø÷ (÷ (ð (ð
|
(ØLL×&Ñ&Ô(ñ "Ø "ll× 6Ñ 6Ó 8×8Ð8ð $(DLØ#'DL÷ (÷ (ñ (øð (øð 9ùÜ ò Ùðûð $(DLØ#'DLúð (ø÷ (÷ (ñ (ûô ×#Ñ#ò Ü Ø5°d×6QÑ6QÐ5RÐSóàð ð üsÍ D'C7 B8C7 ¡(C"Á C7 ÁB:ÁC7 ÁD'Á9B>ÂB<ÂB>ÂC"Â' C7 Â2C Â3C7 Â7D'Â8C7 Â:C7 Â<B>Â> C
|
ÃC Ã C
|
Ã
|
C à C à C"à C7 Ã"C4Ã(C+ Ã)C4Ã0C7 Ã3D'Ã4C7 Ã7-D$Ä$D'c ó¨ K | j dd¬« d{ t | j « d{ « dk7 r t d« y7 47 w)z Send PING, expect PONG in returnÚPINGFr» NÚPONGz#Bad response from PING health check)rö r3 r÷ r+ r s rE Ú
|
_send_pingz AbstractConnection._send_pingö sR è ø à× Ñ °UÐ Ó;×;Ð;Ü d× 0Ñ 0Ó 2×2Ó 3°vÒ =Ü!Ð"GÓHÐ Hð >ð <øØ2ús AA A¶A·AÁAc ó@ K | j « d{ y7 w)z Function to call when PING failsNrÆ ©rL rÉ s rE Ú _ping_failedz AbstractConnection._ping_failedü ó è ø àooÓ × Ò úó c óú K | j rit j « j « | j kD r9| j
|
j | j | j « d{ yyy7 w)z3Check the health of the connection with a PING/PONGN) rc r r Útimerd rx rÊ r r
|
r s rE r¼ z AbstractConnection.check_health sf è ø ð × &Ò &Ü×(Ñ(Ó*×/Ñ/Ó1°D×4JÑ4JÒJà**×,Ñ,¨T¯_©_¸d×>OÑ>OÓP× PÑ Pð Kð 'ð Qús A/A;Á1A9Á2A;Úcommandc ó K | j j |« | j j « d { y 7 wrJ )rj Ú
|
writelinesÚdrain)rL r s rE Ú_send_packed_commandz'AbstractConnection._send_packed_command s. è ø Ø × Ñ Ô(Øll× Ñ Ó"×"Ò"ús 9A»A¼Ac óÎ K | j s| j d¬« d { |r| j « d { t |t « r|j « }t |t « r|g}| j r8t j | j |« | j « d { y | j j |« | j j « d { y 7 Ô7 ¼7 G7 # t j $ r( | j d¬« d { 7 t d« d t $ r{}| j d¬« d { 7 t# |j$ « dk( rd|j$ d }}n |j$ d }|j$ d }t' d | d
|
| d « |d }~wt( $ r | j d¬« d { 7 w xY ww) NFr» T©rÿ zTimeout writing to socketr| ÚUNKNOWNr zError z while writing to socket. r¤ )r® r½ r¼ ró ÚstrÚencodeÚbytesr^ r Úwait_forr rj r r r/ rÇ rÌ rõ Úargsr+ Ú BaseException)rL r r¼ rÓ Úerr_noÚerrmsgs rE Úsend_packed_commandz&AbstractConnection.send_packed_command sµ è ø ð × Ò Ø×+Ñ+¸Ð+Ó?× ?Ð ?Ù Ø×#Ñ#Ó%× %Ð %ð Ü'¤3Ô'Ø!..Ó*Ü'¤5Ô)Ø")Ø×"Ò"Ü ×&Ñ&Ø×-Ñ-¨gÓ6¸×8KÑ8Kó÷ ñ ð ×'Ñ'¨Ô0Øll×(Ñ(Ó*×*Ñ*ð @øà %øðøð
|
+ùÜ×#Ñ#ò FØ//¨/Ó.× .Ñ .Ü Ð :Ó;ÀÐ EÜò Ø//¨/Ó.× .Ñ .Ü166{aÒ Ø!*¨A¯F©F°1©Ià Ø Ü!ØÐ :¸6¸(À!ÐDóàð ûô ò ð
|
//¨/Ó.× .Ñ .Ø ð üs "G%¤C9¥G%¾C;¿G%ÁA1D Â5C=Â6D Â:G%Â;8D Ã3C?Ã4D Ã8G%Ã;G%Ã=D Ã?D Ä(G"Ä)D,Ä*G"ÅF9ÅEÅA F9Æ9!G"ÇG ÇG"Ç"G%r Úkwargsc ó K | j | j | |j dd« ¬« d{ y7 w)z+Pack and send a command to the Redis serverr¼ Tr» N)r Ú pack_commandrø )rL r r s rE rö z AbstractConnection.send_command5 s@ è ø à×&Ñ&Ø D× Ñ tÐ $°6·:±:¸nÈdÓ3Sð 'ó
|
÷
|
ò
|
ús 4>¶<·>c ó K | j j « d{ S 7 # t $ rK}| j d¬« d{ 7 | j « }t d| d|j « d}~ww xY ww)z8Poll the socket to see if there's data that can be read.NTr úError while reading from z: )rk Úcan_read_destructiverÌ rÇ rÞ r+ r )rL rÓ Ú
|
host_errors rE r% z'AbstractConnection.can_read_destructive; su è ø ð VØ ×:Ñ:Ó<×<Ð <Ð<ùÜò VØ//¨/Ó.× .Ñ .Ø ×)Ñ)Ó+JÜ!Ð$=¸j¸\ÈÈAÏFÉFÈ8Ð"TÓUÐ Uûð Vüs< A? ( ¡&¢( ¥A?¦( ¨ A<±A7ÁA Á0A7Á7A<Á<A?)Údisconnect_on_errorÚ push_requestÚdisable_decodingr# r' r( c óÐ K ||n | j }| j « } |X| j dv rJt |« 4 d{ | j j ||¬« d{ }ddd« d{ n£|It |« 4 d{ | j j |¬« d{ }ddd« d{ nX| j dv r&| j j ||¬« d{ }n$| j j |¬« d{ }| j r6t j « j « | j z } | | _ t# t$ « r|d|S 7 57 7 # 1 d{ 7 sw Y rxY w7 7 å7 ×# 1 d{ 7 sw Y xY w7 º7 # t j $ r0 |Y y|r| j d¬« d{ 7 t d| « t $ r=}|r| j d¬« d{ 7 t d| d |j « d}~wt $ r |r| j d¬« d{ 7 w xY ww)
|
z0Read the response from a previously sent commandN)Ú3r! )r) r( )r) Tr zTimeout reading from r$ z : )r^ rÞ rh r rk r÷ r r/ rÇ rÌ r+ r r rc r r rd ró r. )
|
rL r) r# r' r( Ú read_timeoutr& rü rÓ Ú next_times
|
rE r÷ z AbstractConnection.read_responseD sj è ø ð #*Ð"5w¸4×;NÑ;N Ø×%Ñ%Ó'
|
ð% ØÐ'¨D¯M©M¸XÑ,EÜ(¨ Ó6÷ ñ Ø%)§\¡\×%?Ñ%?Ø)9È ð &@ó &÷ H÷÷ ð ð Ð)Ü(¨ Ó6÷ ñ Ø%)§\¡\×%?Ñ%?Ø)9ð &@ó &÷ H÷÷ ð ð (Ñ*Ø!%§ ¡ ×!;Ñ!;Ø%5ÀLð "<ó "÷ ð "&§ ¡ ×!;Ñ!;Ø%5ð "<ó "÷ ð. × %Ò %Ü ×0Ñ0Ó2×7Ñ7Ó9¸D×<VÑ<VÑVIØ%.DÔ "ä h¤ Ô .Ø Ð $ØðWùð ùðù÷ ÷ ñ úð
|
ùð øðø÷ ÷ ñ úð
|
øð ùô ×#Ñ#ò EØÐ"áá"Øoo¨ToÓ2×2Ñ2Ü Ð!6°z°lÐ CÓDÐ DÜò WÙ"Øoo¨ToÓ2×2Ñ2Ü!Ð$=¸j¸\ÈÈQÏVÉVÈHÐ"UÓVÐ VûÜ ò ñ #Øoo¨ToÓ2×2Ñ2Ø ð üs% !I&¤ F6 ÁE8ÁF6 Á!FÁ(E;Á)FÁ- F6 Á8E>Á9F6 ÂFÂF6 Â F Â3FÂ4F Â8 F6 ÃFÃ3F6 Ã7F2Ã8$F6 Ä F4Ä F6 Ä!AI&Å8F6 Å;FÅ>F6 ÆFÆF
|
ÆFÆF6 ÆF ÆF6 Æ F/Æ#F& Æ$F/Æ+F6 Æ4F6 Æ6I#Ç I&Ç I#Ç$G'Ç%I#È H8ÈHÈ H8È8#I#ÉI É I#É#I&c ó¬ g }t |d t « rJ t |d t « r1t |d j « j « « |dd z }n)d|d v r"t |d j « « |dd z }t j t t t |« « j « t f« }| j }t | j j |« D ]Ï }t |« }t |« |kD s||kD st |t « rat j |t t |« j « t f« }|j! |« |j! |« t }t j |t t |« j « t |t f« }Ñ |j! |« |S )z2Pack a series of arguments into the Redis protocolr r| Nó )ró Úfloatr Útupler ÚsplitÚ SYM_EMPTYr¦ ÚSYM_STARrõ ÚSYM_CRLFrm Úmaprf Ú
|
memoryviewÚ
|
SYM_DOLLARr )rL r ÚoutputÚbuffÚ buffer_cutoffÚargÚ
|
arg_lengths rE r" z AbstractConnection.pack_command~ s àô d 1g¤uÔ-Ð-Ð-Ü d1gsÔ #Üa Ó)×/Ñ/Ó1Ó2°T¸!¸"°XÑ=DØ T!W_Üa Ó)¨D°°¨HÑ4Dä~~x¬¬S°«Y« ×)>Ñ)>Ó)@Ä(Ð KÓLà ×+Ñ+ Üt||×*Ñ*¨DÓ1ò Cô SJäD MÒ)Ø Ò-Ü c¤:Ô.ä ~~Ø:¤s¨:£×'=Ñ'=Ó'?ÄÐJóð dÔ#Ø cÔ"Ü ä ~~à Ü"ÜJ×.Ñ.Ó0Ü ØÜ ð ó ð! ð4 dÔØ r< Úcommandsc óÄ g }g }d}| j }|D ]¢ } | j | D ] }t |« }||kD s||kD st |t « r*|r$|j t j |« « d}g }||kD st |t « r|j |« y|j |« ||z } ¤ |r$|j t j |« « |S )z.Pack multiple commands into the Redis protocolr )rm r" rõ ró r7 r r3 r¦ ) rL r> r9 ÚpiecesÚ buffer_lengthr; ÚcmdÚchunkÚchunklens rE Ú pack_commandsz AbstractConnection.pack_commands¬ sÞ à Ø Ø Ø ×+Ñ+ àò .CØ*×*Ñ*¨CÐ0ò .Ü u:à! MÒ1Ø -Ò/Ü! %¬Ô4á Ø ¤i§n¡n°VÓ&<Ô=Ø$%MØ FàmÒ+¬z¸%ÄÔ/LØMM %Õ(àMM %Ô(Ø! XÑ-Mñ! .ð .ñ& Ø MM)..¨Ó0Ô 1Ø r< c óF t | j j « dk( S )z Check if the socket is emptyr )rõ ri Ú_bufferr s rE Ú_socket_is_emptyz#AbstractConnection._socket_is_emptyÊ s ä4<<×'Ñ'Ó(¨AÑ-Ð-r< c ó K | j « s,| j d¬« d { | j « s+y y 7 w)NT)r( )rH r÷ r s rE Ú process_invalidation_messagesz0AbstractConnection.process_invalidation_messagesÎ s: è ø Ø×'Ñ'Ô)Ø×$Ñ$°$Ð$Ó7× 7Ð 7ð ×'Ñ'×)Ø 7ús &A¨A ©A¾AÚtokenc ó || _ y rJ )r )rL rK s rE Úset_re_auth_tokenz$AbstractConnection.set_re_auth_tokenÒ s
|
Ø #Õr< c ó K | j l| j d| j j d« | j j « « d { | j « d { d | _ y y 7 %7 w©Nré Úoid)r rö Útry_getÚ get_valuer÷ r s rE Úre_authzAbstractConnection.re_authÕ s è ø Ø × Ñ Ð *Ø×#Ñ#ØØ×#Ñ#×+Ñ+¨EÓ2Ø×#Ñ#×-Ñ-Ó/ó÷ ð ð
|
×$Ñ$Ó&× &Ð &Ø"&DÕ ð +ð øð
|
'ús$ AB ÁA<ÁB Á.A>Á/B Á>B )TT©r¸ N©T)F)FN)Cr? r@ rA Ú__doc__Ú __slots__r rF r2 r5 r r r r r0 ÚboolÚlistr> r r4 r$ ÚConnectCallbackTr' r r Úwarningsr r r rª r r§ Úpropertyr® 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÷ r0 r r" rE rH rJ r rM rS rD r< rE rP rP k sÆ Ù:ðIð@ Ø"&Ø*.Ø26Ø!&Ø19Ø Ø 'Ø!&Ø)6Ø %Ø'(Ø%)Ø",Ù%4Ó%6Ø"&Ø!%Ø9=Ø'.Ø<@Ø"#Ø6:ò1X%ð #s(OðX%ð 3-ð X%ð
|
! ð X%ð !)¨¡ð X%ð ðX%ð d IoÑ.ðX%ð ðX%ð ðX%ð ðX%ð :Ñ&ðX%ð ðX%ð %ð X%ð c]ð X%ð 3-ð!X%ð" c]ð#X%ð$ 3-ð%X%ð& ð'X%ð( %Ð%5Ñ 6ð)X%ð* G}ð+X%ð, &Ð&8Ñ 9ð-X%ð. 3-ð/X%ð0 # ?Ñ3ó1X%ðt (0ñ ó ò /òWð ñ ó ð ð ñEó ðEò
|
/ò ðM t¨JÑ'7ð M¸Dó Mò;ð
|
GKñ-Ø ð-Ø?Có-ò^&ò&ð ñ ó ð ð ð Sò ó ð ðC¨ ð C¸#ó Cò ó>ñj:¸$ð j:È$ó j:ñX tð ¸ó ò.Iò òQð#°(¸5±/ð #Àdó #ð
|
QUñ'Ø U C¨°%© Ð 8Ñ9ð'ØIMð'à ó'ðR
|
¨ð
|
°sð
|
¸tó
|
ò Vð "'Ø#'ð8ð
|
%)Ø',ò 8à ð8ð % ð8ð
|
"ð 8ð tnó 8ðt, *ð ,°°e±ó ,ð\ h¨x¸
|
Ñ/CÑ&Dð ÈÈeÉó ò<.ò8ð$ ~ó $ó'r< rP c ó e Zd ZdZddddddded eeef d
|
ed ee eeee
|
f f d ef
|
fd Z d Z de fdZ d ZdefdZ xZS )Ú
|
Connectionz4Manages TCP communication to and from a Redis serverÚ localhostië FNr )ÚhostÚportÚsocket_keepaliveÚsocket_keepalive_optionsÚ socket_typer` ra rb rc rd c ó || _ t |« | _ || _ |xs i | _ || _ t | di |¤ y ©NrD )r` r ra rb rc rd Úsuperr )rL r` ra rb rc rd r r¨ s rE r zConnection.__init__ã sD ø ð ÜI Ø 0Ô Ø(@Ò(FÀBÔ%Ø&ÔÜ ÑÑ"6Ó"r< c óª d| j fd| j fd| j fg}| j r |j d| j f« |S )Nr` ra rW rY )r` ra rW rY r ©rL r@ s rE r§ zConnection.repr_piecesô sM Ø499Ð%¨°· ± Ð':¸TÀ4Ç7Á7¸OÐLØ × Ò Ø MM=¨$×*:Ñ*:Ð;Ô <Ø r< r¸ c ó4 | j | j dS )N©r` ra rk r s rE Ú_connection_argumentsz Connection._connection_argumentsú s Ø ¨4¯9©9Ñ5Ð5r< c óú K t | j « 4 d{ t j di | j « ¤ d{ \ }}ddd« d{ | _ | _ |j j d« }|r°|j t j t j d« | j rs|j t j t j d« | j j# « D ]& \ }}|j t j$ ||« ( yyy7 7 ö7 å# 1 d{ 7 sw Y õxY w# t& t( f$ r |j+ « w xY ww)z Create a TCP socket connectionNr r| rD )r r_ r Úopen_connectionrl ri rj Ú transportÚget_extra_infoÚ
|
setsockoptr Ú IPPROTO_TCPÚ TCP_NODELAYrb Ú
|
SOL_SOCKETÚ SO_KEEPALIVErc ÚitemsÚSOL_TCPrÌ r r )rL ÚreaderÚwriterÚsockr r¡ s rE rà zConnection._connectý sE è ø ä ×!<Ñ!<Ó=÷ ñ Ü#*×#:Ñ#:ñ $Ø×,Ñ,Ó.ñ$÷ NFF÷ ÷ ð Ø Ø× Ñ ×.Ñ.¨xÓ8Ù Ø OOF× .Ñ .´×0BÑ0BÀAÔ Fð à×(Ò(ØOO¤F×$5Ñ$5´v×7JÑ7JÈAÔNØ $× =Ñ =× CÑ CÓ Eò >1Ø ¬¯©¸¸1Õ=ñ>ð )ð ð ùð øð ø÷ ÷ ñ ûô YÐ'ò ð Øð üsp E;D;E; 'EÁD>ÁEÁ E;ÁE ÁA E;Â:A>E Ä8E;Ä>EÅ E;ÅEÅE Å EÅE;Å!E8Å8E;c ó8 | j d| j S )Nú:rk r s rE rÞ zConnection._host_error s Ø))Adii[Ð)Ð)r< )r? r@ rA rV r r r rX r r
|
r r r§ rl rà rÞ Ú __classcell__©r¨ s @rE r^ r^ à s ø Ù:ð
|
Ø $Ø!&ØNRØ ò#ð ð#ð CHoð #ð
|
ð #ð #+¨7°3¸¸cÀ5¸jÑ8IÐ3IÑ+JÑ"Kð #ð õ#ò"ð 6 wó 6òð0*S÷ *r< r^ c ó\ e Zd ZdZ ddee dee deeej f dee d dee d dee d ee d
|
e
|
d ee d ee f fd Z de f fd Zed « Zed « Zed « Zed « Zed « Zed « Zed « Zed « Zed « Z xZS )Ú SSLConnectionzåManages SSL connections to and from the Redis server(s).
|
This class extends the Connection class, adding SSL functionality, and making
|
use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext)
|
Ú ssl_keyfileÚ ssl_certfileÚ ssl_cert_reqsÚssl_include_verify_flagsússl.VerifyFlagsÚssl_exclude_verify_flagsÚ ssl_ca_certsÚ ssl_ca_dataÚssl_check_hostnameÚssl_min_versionÚ ssl_ciphersc óz t s t d« t ||||||||| |
|
¬«
|
| _ t | di | ¤ y )Nú$Python wasn't built with SSL support)
|
ÚkeyfileÚcertfileÚ cert_reqsÚinclude_verify_flagsÚexclude_verify_flagsÚca_certsÚca_dataÚcheck_hostnameÚ min_versionÚciphersrD )r r- ÚRedisSSLContextrg rg r ) rL r r r r r r r r r r r r¨ s rE r zSSLConnection.__init__ sQ ø õ Ü Ð CÓDÐ Dä,;Ø Ø!Ø#Ø!9Ø!9Ø!Ø Ø-Ø'Ø ô -
|
Ôô ÑÑ"6Ó"r< r¸ c ó^ t | « }| j j « |d< |S )NÚssl)rg rl rg rø )rL r r¨ s rE rl z#SSLConnection._connection_arguments> s- ø ÜÑ.Ó0Ø ×(Ñ(×,Ñ,Ó.u Ø r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.keyfileC ó à× Ñ ×'Ñ'Ð'r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.certfileG ó à× Ñ ×(Ñ(Ð(r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.cert_reqsK s à× Ñ ×)Ñ)Ð)r< c ó. | j j S rJ )rg r r s rE r z"SSLConnection.include_verify_flagsO ó à× Ñ ×4Ñ4Ð4r< c ó. | j j S rJ )rg r r s rE r z"SSLConnection.exclude_verify_flagsS r¡ r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.ca_certsW r r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.ca_data[ r r< c ó. | j j S rJ )rg r r s rE r z SSLConnection.check_hostname_ s à× Ñ ×.Ñ.Ð.r< c ó. | j j S rJ )rg r r s rE r zSSLConnection.min_versionc s à× Ñ ×+Ñ+Ð+r< )
|
NNÚrequiredNNNNTNN)r? r@ rA rV r r r r Ú
|
VerifyModer rX r r r
|
rl r\ r r r r r r r r r r} r~ s @rE r r s ø ñð &*Ø&*Ø4>ØFJØFJØ&*Ø%)Ø#'Ø04Ø%)ñ #à c]ð #ð smð #ð S #§.¡.Ð 0Ñ1ð #ð
|
#+¨4Ð0AÑ+BÑ"Cð #ð #+¨4Ð0AÑ+BÑ"Cð #ð smð #ð c]ð #ð !ð #ð " *Ñ-ð #ð c]õ #ð> wõ ð
|
ñ(ó ð(ð ñ)ó ð)ð ñ*ó ð*ð ñ5ó ð5ð ñ5ó ð5ð ñ)ó ð)ð ñ(ó ð(ð ñ/ó ð/ð ñ,ó ô,r< r c óÂ e Zd ZdZ ddee dee deeeej f dee d dee d d ee d
|
ee d e
|
d ee d ee fdZ de fdZy)r ) r r r r r r r Úcontextr r r Nr r r r r
r r r r r r c óÒ t s t d« || _ || _ |t j
|
}nWt |t « rGt j
|
t j t j d} || vrt d| « | | }|| _
|
|| _ || _ || _ || _ | j t j
|
k7 r|nd| _ | | _ |
|
| _ d | _ y )Nr )ÚnoneÚoptionalr§ z+Invalid SSL Certificate Requirements Flag: F)r r- r r r Ú CERT_NONEró r Ú CERT_OPTIONALÚ CERT_REQUIREDr r r r r r r r rª ) rL r r r r r r r r r r Ú CERT_REQSs rE r zRedisSSLContext.__init__w sà õ Ü Ð CÓDÐ Dà Ø Ø Ð Ü IÜ ¤3Ô 'ä Ü × -Ñ -Ü × -Ñ -ñIð
|
Ñ)Ü ØAÀ)ÀÐMóð ð " )Ñ,IØ"Ø$8Ô!Ø$8Ô!Ø Ø à "nn´· ± Ò =NÀ5ð Ôð 'ÔØ Ø-1 r< r¸ c óü | j sdt j « }| j |_ | j |_ | j r&| j D ] }|xj |z c_ | j r'| j D ] }|xj | z c_ | j r3| j r'|j | j | j ¬« | j s | j r'|j | j | j ¬« | j | j |_ | j" |j% | j" « || _ | j S )N)r r )ÚcafileÚcadata)rª r Úcreate_default_contextr r Ú verify_moder Ú verify_flagsr r r Úload_cert_chainr r Úload_verify_locationsr Úminimum_versionr Ú set_ciphers)rL rª Úflags rE rø zRedisSSLContext.get¢ s( Ø||Ü×0Ñ0Ó2GØ%)×%8Ñ%8GÔ "Ø"&§.¡.GÔ Ø×(Ò(Ø × 5Ñ 5ò 1DØ×(Ò(¨DÑ0Ö(ð1à×(Ò(Ø × 5Ñ 5ò 2DØ×(Ò(¨T¨EÑ1Ö(ð2à}} § ¢ Ø×'Ñ'°· ± ÈÏ É Ð'ÔUØ}} § ¢ Ø×-Ñ-°T·]±]È4Ï<É<Ð-ÔXØ× Ñ Ð+Ø*.×*:Ñ*:Ô'Ø||Ð'Ø×#Ñ# D§L¡LÔ1Ø"DLØ||Ðr< )
|
NNNNNNNFNN)r? r@ rA rW r r r r r¨ r rX r r r rø rD r< rE r r h sß ð Ið "&Ø"&Ø:>ØBFØBFØ"&Ø!%Ø $Ø,0Ø!%ñ)2à# ð)2ð 3-ð)2ð E # s§~¡~Ð"5Ñ 6Ñ7ð )2ð
|
' tÐ,=Ñ'>Ñ ?ð )2ð ' tÐ,=Ñ'>Ñ ?ð )2ð 3-ð)2ð # ð)2ð ð)2ð jÑ)ð)2ð # ó)2ðV Zô r< r c óf e Zd ZdZdddef fdZdeeeeee f f fdZ
|
d Z defd Z xZ S )
|
ÚUnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverÚ ©ÚpathrÁ c ó2 || _ t | di |¤ y rf )rÁ rg r )rL rÁ r r¨ s rE r z#UnixDomainSocketConnection.__init__¼ s ø Ø Ü ÑÑ"6Ó"r< r¸ c ó d| j fd| j fg}| j r |j d| j f« |S )NrÁ rW rY )rÁ rW rY r ri s rE r§ z&UnixDomainSocketConnection.repr_piecesÀ sB Ø499Ð%¨¨d¯g©g Ð7Ø × Ò Ø MM=¨$×*:Ñ*:Ð;Ô <Ø r< c óD K t | j « 4 d { t j | j ¬« d { \ }}d d d « d { | _ | _ | j « d { y 7 f7 @7 /# 1 d { 7 sw Y ?xY w7 w)NrÀ )r r_ r Úopen_unix_connectionrÁ ri rj rä )rL rx ry s rE rà z#UnixDomainSocketConnection._connectÆ s è ø Ü ×!<Ñ!<Ó=÷ Pñ PÜ#*×#?Ñ#?ÀTÇYÁYÔ#O× ONFF÷ P÷ Pà Ø ØooÓ × Ñ ð PøØ Oøð Pø÷ P÷ Pñ Púð úsb B BB $B ÁBÁB Á B ÁBÁ%B Á=B Á>B ÂB ÂB  BÂB ÂBÂB c ó | j S rJ rÀ r s rE rÞ z&UnixDomainSocketConnection._host_errorÍ s ØyyÐr< )r? r@ rA rV r r r r r r r§ rà rÞ r} r~ s @rE r¾ r¾ ¹ sI ø Ù:à&(ò # õ #ðX e¨C°°s¸C°x± Ð,@Ñ&AÑ Bó ò ðS÷ r< r¾ )Ú0ÚFÚFALSEÚNÚNOr¸ c óv | | dk( ry t | t « r| j « t v ryt | « S )Nr¿ F)ró r ÚupperÚ FALSE_STRINGSrX )Úvalues rE Úto_boolrÐ Ô s4 Ø } ØÜ%Ô %§+¡+£-´=Ñ"@ØÜ ;Ðr< c ó | j dd« j dd« }g }|j d« D ]O }|j « }t t |« st d| « |j t t |« « Q |S )Nú[r¿ ú]r zInvalid ssl verify flag: )Úreplacer2 ÚstripÚhasattrr r r r )rÏ Úverify_flags_strr· r¼ s rE Úparse_ssl_verify_flagsrØ Ü s ð }} S¨"Ó-×5Ñ5°c¸2Ó>ÐàLØ ×&Ñ& sÓ+ò 8Øzz|Ü{ DÔ)Ü Ð 8¸¸Ð ?Ó@Ð @Ø×ÑG¤K°Ó 6Õ7ð 8ð
|
Ðr< ) rW r^ r_ rb ra Úmax_connectionsrc r r r r# .ÚURL_QUERY_ARGUMENT_PARSERSc óZ e Zd ZU eed< eed< ee ed< eed< eed< eed< eed< y) Ú ConnectKwargsrX r] Úconnection_classr` ra rW rÁ N)r? r@ rA r Ú__annotations__r rP r rD r< rE rÜ rÜ û s,
ØMØMØÐ-Ñ.Ó.Ø
|
IØ
|
IØ GØ
|
Ir< rÜ F)ÚtotalÚurlc ó t | « }i }t |j « j « D ]N \ }}|s t |« dkD st |d « }t j |« }|r ||« ||< J|||< P |j rt |j « |d< |j rt |j « |d< |j dk( r/|j rt |j « |d< t |d< |S |j d v r¤|j rt |j « |d
|
< |j rt# |j « |d < |j r6d |vr2 t# t |j « j% d d« « |d < |j dk( r t( |d< |S d}t d| d« # t t f$ r t d| d« w xY w# t& t f$ r Y ^w xY w)Nr zInvalid value for 'z' in connection URL.rX r] ÚunixrÁ rÝ )ÚredisÚredissr` ra rW ú/r¿ rä z redis://, rediss://, unix://z5Redis URL must specify one of the following schemes (ú))r r Úqueryrv rõ r rÚ rø r r rX r] ÚschemerÁ r¾ Úhostnamera r rÔ ÚAttributeErrorr )rà Úparsedr ÚnameÚ
|
value_listrÏ rù Ú valid_schemess rE Ú parse_urlrï sô Ü" 3-FØ Fä $ V§\¡\Ó 2× 8Ñ 8Ó :ò
|
%ÑjÚ #j/¨AÓ-ÜJ qMÓ*EÜ/×3Ñ3°DÓ9FÙðWÙ#)¨%£=F4Lð %t ð
|
%ð Ü $ V§_¡_Ó 5zÑØ Ü $ V§_¡_Ó 5zÑð }}Ò Ø ;;Ü $ V§[¡[Ó 1F6NÜ%?Ð!Ñ"ð2 Mð/
|
Ð-Ñ -Ø ??Ü $ V§_¡_Ó 5F6NØ ;;Ü §¡Ó -F6Nð ;;4 vÑ-ð Ü "¤7¨6¯;©;Ó#7×#?Ñ#?ÀÀRÓ#HÓ It ð ==HÒ $Ü)6FÐ%Ñ &ð Mð 7 ÜØCÀMÀ?ÐRSÐ Tó
|
ð
|
øôG "¤:Ð.ò WÜ$Ð':¸4¸&Ð@TÐ%UÓVÐVðWûô6 #¤JÐ/ò Ùð ús Á/ G Å/1G- Ç G*Ç-G?Ç>G?Ú_CPÚConnectionPool)Úboundc óú e Zd ZdZedee dedefd« Ze dfdee
|
de e fd Z d
|
Zd Zdefd Z ed gdd¬« d!d« Zd Zd Zd Zde
|
fdZde
|
fdZd"defdZd Zd#dZd$d Z d e fd Z d e fd Z y)%rñ aù
|
Create a connection pool. ``If max_connections`` is set, then this
|
object raises :py:class:`~redis.ConnectionError` when the pool's
|
limit is reached.
|
|
By default, TCP connections are created unless ``connection_class``
|
is specified. Use :py:class:`~redis.UnixDomainSocketConnection` for
|
unix sockets.
|
:py:class:`~redis.SSLConnection` can be used for SSL enabled connections.
|
|
Any additional keyword arguments are passed to the constructor of
|
``connection_class``.
|
Úclsrà r¸ c óJ t |« }|j |« | di |¤S )a
|
Return a connection pool configured from the given URL.
|
|
For example::
|
|
redis://[[username]:[password]]@localhost:6379/0
|
rediss://[[username]:[password]]@localhost:6379/0
|
unix://[username@]/path/to/socket.sock?db=0[&password=password]
|
|
Three URL schemes are supported:
|
|
- `redis://` creates a TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/redis>
|
- `rediss://` creates a SSL wrapped TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/rediss>
|
- ``unix://``: creates a Unix Domain Socket connection.
|
|
The username, password, hostname, path and all querystring values
|
are passed through urllib.parse.unquote in order to replace any
|
percent-encoded values with their corresponding characters.
|
|
There are several ways to specify a database number. The first value
|
found will be used:
|
|
1. A ``db`` querystring option, e.g. redis://localhost?db=0
|
|
2. If using the redis:// or rediss:// schemes, the path argument
|
of the url, e.g. redis://localhost/0
|
|
3. A ``db`` keyword argument to this function.
|
|
If none of these options are specified, the default db=0 is used.
|
|
All querystring options are cast to their appropriate Python types.
|
Boolean arguments can be specified with string values "True"/"False"
|
or "Yes"/"No". Values that cannot be properly cast cause a
|
``ValueError`` to be raised. Once parsed, the querystring arguments
|
and keyword arguments are passed to the ``ConnectionPool``'s
|
class initializer. In the case of conflicting arguments, querystring
|
arguments always win.
|
rD )rï Úupdate)rô rà r Ú url_optionss rE Úfrom_urlzConnectionPool.from_urlL s& ôV n Ø kÔ"Ù}V}Ð r< NrÝ rÙ c ó |xs d}t |t « r|dk r t d« || _ || _ || _ g | _ t « | _ | j j dt « | _ t j « | _ | j j dd « | _ | j t! « | _ y y )Nl r z,"max_connections" must be a positive integerry rz )ró r r rÝ Úconnection_kwargsrÙ Ú_available_connectionsÚsetÚ_in_use_connectionsrø r5 ry r ÚLockrn r~ r )rL rÝ rÙ rú s rE r zConnectionPool.__init__{ s¶ ð *Ò2¨UÜ/¬3Ô/°?ÀQÒ3FÜ Ð KÓLÐ Là 0Ô Ø!2Ô Ø .Ô à@BÔ#Ü<?»EÔ Ø !× 3Ñ 3× 7Ñ 7¸ÌÓ QÔÜ \\^
|
Ø!%×!7Ñ!7×!;Ñ!;Ð<NÐPTÓ!UÔ Ø × !Ñ !Ð )Ü%4Ó%6DÕ "ð *r< c óT dj | j j « D cg c] \ }}| d| c}}« }d| j j d| j j
|
d| j j d| j j
|
d| d S c c}}w )Nr r r£ r¤ z(<r¥ z)>)>)r¦ rú rv r¨ r@ r? rÝ )rL r r¡ Ú conn_kwargss rE rª zConnectionPool.__repr__ s Øhh°t×7MÑ7M×7SÑ7SÓ7U× V©t¨q°! 1 # Q q c¢
|
Ó VÓW à×)Ñ)Ð*¨!¨D¯N©N×,CÑ,CÐ+DØ×&Ñ&×1Ñ1Ð2°!°D×4IÑ4I×4RÑ4RÐ3SØ }Dð "ð
|
ùó Ws ©B$
|
c óD g | _ t j « | _ y rJ )rû r° ÚWeakSetrý r s rE ÚresetzConnectionPool.reset s Ø&(Ô#Ü#*§?¡?Ó#4Õ r< c ób | j xs" t | j « | j k S )z;Return True if a connection can be retrieved from the pool.)rû rõ rý rÙ r s rE Úcan_get_connectionz!ConnectionPool.can_get_connection s1 ð × 'Ñ 'ò DÜ4×+Ñ+Ó,¨t×/CÑ/CÑCð
|
r< Ú*ú)Use get_connection() without args insteadú5.3.0©Ú args_to_warnÚreasonÚversionc ó6 K | j 4 d { | j « } | j |« d { d d d « d { |S 7 A7 # t $ r | j |« d { 7 w xY w7 2# 1 d { 7 sw Y S xY wwrJ )rn Úget_available_connectionÚensure_connectionr Úrelease)rL Ú command_nameÚkeysÚoptionsrM s rE Úget_connectionz ConnectionPool.get_connection¤ s¡ è ø ð ::÷ ñ Ø :Ø ×6Ñ6Ó8Jð Ø×,Ñ,¨ZÓ8×8Ð8÷ ÷ ð Ðð øð 9ùÜ ò Øll :Ó.×.Ñ.Øð úð ø÷ ÷ ð ð Ðüsq BABBªA¾A¿AÁ BÁBÁBÁAÁ A>Á6A9Á7A>Á>BÂBÂB B Â
|
BÂBc ó | j j « }| j j |« |S # t $ rA t | j « | j
|
k\ r t d« d| j « }Y fw xY w)zCGet a connection from the pool, without making sure it is connectedzToo many connectionsN) rû ÚpopÚ
|
IndexErrorrõ rý rÙ r+ Úmake_connectionÚaddrK s rE r z'ConnectionPool.get_available_connectionµ s} ð 0Ø ×4Ñ4×8Ñ8Ó:Jð
|
× Ñ ×$Ñ$ ZÔ0ØÐøô ò 0Ü4×+Ñ+Ó,°×0DÑ0DÒDÜ%Ð&<Ó=À4ÐGØ ×-Ñ-Ó/Jð 0ús 9 ¹ABÂBc ó¢ | j }| j |j dd« |j dd« |j dd« ¬« S )z,Return an encoder based on encoding settingsrs rq rt rr ru F)rs rt ru )rú ry rø )rL r s rE Ú get_encoderzConnectionPool.get_encoderÀ sQ à×'Ñ'Ø×!Ñ!ØZZ
|
¨GÓ4Ø "JJÐ'8¸(Ó CØ #ZZÐ(:¸EÓ Bð "ó
|
ð
|
r< c ó: | j di | j ¤S )z=Create a new connection. Can be overridden by child classes.rD )rÝ rú r s rE r z ConnectionPool.make_connectionÉ s à$t×$Ñ$Ñ> t×'=Ñ'=Ñ>Ð>r< rM c óp K |j « d{ |j « d{ r t d« dy7 *7 # t t t f$ rZ |j « d{ 7 |j « d{ 7 |j « d{ 7 r t d« dY yw xY ww)z8Ensure that the connection object is connected and validNzConnection has datazConnection not ready)r¾ r% r+ r/ rÌ rÇ rK s rE r z ConnectionPool.ensure_connectionÍ s® è ø à× Ñ Ó"×"Ð"ð
|
HØ ×4Ñ4Ó6×6Ð6Ü%Ð&;Ó<À$ÐFð 7ð #øð 7ùä ¤ ¬wÐ7ò HØ ×'Ñ'Ó)× )Ñ )Ø ×$Ñ$Ó&× &Ñ &Ø ×4Ñ4Ó6×6Ñ6Ü%Ð&<Ó=À4ÐGñ 7ð Hüsf B6AB6A ¯A°A Á B6ÁA Á'B3Á,A/Á-B3ÂBÂB3 B! B3Â0B6Â2B3Â3B6c ó( K | j j |« |j « r|j « d{ | j j |« | j j t |« « d{ y7 L7 w)z(Releases the connection back to the poolN) rý r¶ rÛ rÇ rû r r~ Údispatch_asyncr rK s rE r zConnectionPool.releaseÝ s è ø ð × Ñ ×'Ñ'¨
|
Ô3Ø × &Ñ &Ô (Ø ×'Ñ'Ó)× )Ð )à ×#Ñ#×*Ñ*¨:Ô6Ø×$Ñ$×3Ñ3Ü -¨jÓ 9ó
|
÷
|
ñ
|
ð *øð
|
ús$ ?BÁBÁABÂBÂ BÂBÚinuse_connectionsc óä K |r!t | j | j « }n | j }t j d |D « ddi d{ }t d |D « d« }|r|y7 w)zý
|
Disconnects connections in the pool
|
|
If ``inuse_connections`` is True, disconnect connections that are
|
current in use, potentially by other tasks. Otherwise only disconnect
|
connections that are idle in the pool.
|
c 3 ó< K | ] }|j « y wrJ rÆ )r rM s rE r¢ z,ConnectionPool.disconnect.<locals>.<genexpr>ù s è ø Ò D¨*j×#Ñ#×%Ñ Dùs Úreturn_exceptionsTNc 3 óB K | ] }t |t « s| y wrJ )ró r )r Úrs rE r¢ z,ConnectionPool.disconnect.<locals>.<genexpr>ü s è ø ÒD!¤z°!´]Õ'CAÑDùs )r rû rý r ÚgatherÚnext)rL r Ú connectionsÚresprÔ s rE rÇ zConnectionPool.disconnectê s| è ø ñ Ü8=Ø×+Ñ+¨T×-EÑ-Eó9Kð ×5Ñ5KÜ ^^Ù D¸ Ô Dð
|
à "ñ
|
÷
|
ô ÑDtÔDÀdÓKÙ ØIð ð
|
ús AA0ÁA.Á A0c óÊ K | j 4 d{ | j D ] }|j « ddd« d{ y7 67 # 1 d{ 7 sw Y yxY ww)z<
|
Mark all active connections for reconnect.
|
N)rn rý rÙ )rL Úconns rE Ú'update_active_connections_for_reconnectz6ConnectionPool.update_active_connections_for_reconnect s_ è ø ð ::÷ *ñ *Ø ×0Ñ0ò *Ø×'Ñ'Õ)ð *÷ *÷ *ñ *øð *ø÷ *÷ *ñ *üsC A#A
|
A#"A¹ A#ÁA ÁA#Á A#ÁA ÁA ÁA Á A#c ó@ K | j « d{ y7 w)z-Close the pool, disconnecting all connectionsNrÆ r s rE ÚaclosezConnectionPool.aclose r r c ód | j D ] }||_ | j D ] }||_ y rJ )rû rx rý )rL rx r+ s rE Ú set_retryzConnectionPool.set_retry s: Ø×/Ñ/ò DØ DJð à×,Ñ,ò DØ DJñ r< rK c ó¦ K j 4 d { j D ]W j j fd fd« d { j j fd fd« d { Y j D ] j « d d d « d { y 7 7 e7 =7 # 1 d { 7 sw Y y xY ww)Nc ód j dj d« j « « S rO )rö rQ rR )r+ rK s rE rÄ z1ConnectionPool.re_auth_callback.<locals>.<lambda> s) ø D× -Ñ -Ø § ¡ ¨eÓ 4°e·o±oÓ6Gó r< c ó& j | « S rJ ©Ú_mockrÈ s rE rÄ z1ConnectionPool.re_auth_callback.<locals>.<lambda> s ø $§*¡*¨UÓ"3 r< c ó$ j « S rJ )r÷ )r+ s rE rÄ z1ConnectionPool.re_auth_callback.<locals>.<lambda> s ø D× .Ñ .Ó 0 r< c ó& j | « S rJ r4 rÈ s rE rÄ z1ConnectionPool.re_auth_callback.<locals>.<lambda> s ø ÀÇ
|
Á
|
È5Ó@Q r< )rn rû rx rÊ rý rM )rL rK r+ s ``@rE Úre_auth_callbackz ConnectionPool.re_auth_callback sÍ úè ø Ø::÷ .ñ .Ø ×3Ñ3ò Øjj×0Ñ0ôó 4ó ÷ ð ð jj×0Ñ0Û0Ó2Qó÷ ñ ð ð ×0Ñ0ò .Ø×&Ñ& uÕ-ð .÷ .÷ .ñ .øðøð øð .ø÷ .÷ .ñ .üsh
CB4C6B<ÁB6Á)B<Á:B8Á;(B<Â# CÂ.B:Â/CÂ6B<Â8B<Â:CÂ<CÃC ÃCÃ
|
CrÉ c ó K yw)z
|
Dummy functions, needs to be passed as error callback to retry object.
|
:param error:
|
:return:
|
NrD r s rE r5 zConnectionPool._mock! s è ø ð ùrU rJ rU rT )rx r$ r¸ N)!r? r@ rA rV Ú classmethodr rð r rø r^ rP r r r rª r rX r r r r r r r r rÇ r, r. r0 r r8 r- r5 rD r< rE rñ rñ = s÷ ñ ð ð, d3ið , cð , ¸ò , ó ð, ð` 6@Ø)-ñ7à Ð 1Ñ2ð7ð " # ó7ò,
|
ò5ð
|
Dó
|
ñ ØUØ:Øôò
|
|
ó ð
|
|
ò ò
|
ò?ðHÐ2Dó Hð
|
Ð(:ó
|
ñ°$ó ò,*ó ó ð .¨Nó .ð ô r< c
|
ó² e Zd ZdZddeej fdedee de
|
e de
|
ej f fd Z ed gd
|
d ¬ « d fd « Zde f fd Z xZS )ÚBlockingConnectionPoola
|
A blocking connection pool::
|
|
>>> from redis.asyncio import Redis, BlockingConnectionPool
|
>>> client = Redis.from_pool(BlockingConnectionPool())
|
|
It performs the same function as the default
|
:py:class:`~redis.asyncio.ConnectionPool` implementation, in that,
|
it maintains a pool of reusable connections that can be shared by
|
multiple async redis clients.
|
|
The difference is that, in the event that a client tries to get a
|
connection from the pool when all of connections are in use, rather than
|
raising a :py:class:`~redis.ConnectionError` (as the default
|
:py:class:`~redis.asyncio.ConnectionPool` implementation does), it
|
blocks the current `Task` for a specified number of seconds until
|
a connection becomes available.
|
|
Use ``max_connections`` to increase / decrease the pool size::
|
|
>>> pool = BlockingConnectionPool(max_connections=10)
|
|
Use ``timeout`` to tell it either how many seconds to wait for a connection
|
to become available, or to block forever:
|
|
>>> # Block forever.
|
>>> pool = BlockingConnectionPool(timeout=None)
|
|
>>> # Raise a ``ConnectionError`` after five seconds if a connection is
|
>>> # not available.
|
>>> pool = BlockingConnectionPool(timeout=5)
|
é2 é rÙ r# rÝ Ú queue_classc ój t | d||d|¤ t j « | _ || _ y )N)rÝ rÙ rD )rg r r Ú ConditionÚ
|
_conditionr# )rL rÙ r# rÝ r? rú r¨ s rE r z BlockingConnectionPool.__init__L s@ ø ô Ñð
|
Ø -Ø +ñ
|
ð ò
|
ô
|
"×+Ñ+Ó-Ø r< r r r r c ól K | j 4 d{ t | j « 4 d{ | j j | j « d{ t
|
| « }ddd« d{ ddd« d{ | j « d{ |S 7 7 }7 R7 6# 1 d{ 7 sw Y FxY w7 =# 1 d{ 7 sw Y MxY w# t j $ r}t d« |d}~ww xY w7 a# t $ r | j « d{ 7 w xY ww)z@Gets a connection from the pool, blocking until one is availableNzNo connection available.) rB r r# r r rg r r r/ r+ r r r )rL r r r rM Úerrr¨ s rE r z%BlockingConnectionPool.get_connection\ s/ øè ø ð GØ÷ Dñ DÜ(¨¯ © Ó6÷ Dñ DØ //×2Ñ2°4×3JÑ3JÓK×KÐKÜ!&¡Ñ!AÓ!CJ÷D÷ D÷ D÷ Dð Ø×(Ñ(¨Ó4× 4Ð 4Ø Ð ð DøðDøØKøðDø÷ D÷ Dñ Dúð Dø÷ D÷ Dñ Dûô ×#Ñ#ò GÜ!Ð"<Ó=À3Ð Fûð Gúð
|
5ùä ò Ø,,zÓ*× *Ñ *Ø ð üsô D4
C# B/C# C³B1´C·)B7Á B3Á!B7Á3 CÁ>B5Á?CÂ C# ÂC ÂC# ÂD Â(D
|
Â)D Â.D4Â/C# Â1CÂ3B7Â5CÂ7C Â=C Â>C ÃCÃ C# ÃC ÃC ÃC Ã C# Ã#DÃ6 DÄDÄD4Ä
|
D Ä D1Ä)D,Ä*D1Ä1D4rM c óð K | j 4 d{ t | |« d{ | j j « ddd« d{ y7 F7 17 # 1 d{ 7 sw Y yxY ww)z)Releases the connection back to the pool.N)rB rg r Únotify)rL rM r¨ s rE r z BlockingConnectionPool.releases sc øè ø à??÷ %ñ %Ü'/ *Ó-× -Ð -Ø OO× "Ñ "Ô $÷ %÷ %ñ %øØ -øð %ø÷ %÷ %ñ %üsT A6AA6A!«A ¬ A!Á
|
A6ÁA ÁA6Á A!Á A6Á!A3Á'A* Á(A3Á/A6rJ )r? r@ rA rV r^ r Ú LifoQueuer r r0 r rP ÚQueuer r r r r} r~ s @rE r< r< * s ø ñ ðF "Ø#%Ø5?Ø+2×+<Ñ+<ñ à ð ð % ð ð Ð 1Ñ2ð ð
|
'--Ñ(õ ñ ØUØ:Øôô
|
ó ð
|
ð$%Ð(:÷ %ñ %r< r< )or r ÚenumrÑ r Úsysr[ r° Úabcr Ú itertoolsr Útypesr Útypingr r r r r
|
r r r r r r r r Ú urllib.parser r r r Úutilsr r r r r Ú
|
auth.tokenr Úeventr r r r Ú version_infor# r Úredis.asyncio.retryr$ Ú redis.backoffr% Úredis.connectionr& Úredis.credentialsr' r( Úredis.exceptionsr) r* r+ r, r- r. r/ Ú redis.typingr0 Ú redis.utilsr1 r2 r3 Ú_parsersr4 r5 r6 r7 r8 r4 r8 r5 ÚSYM_LFr3 ÚEnumr> rC r rÞ rF rH rS rZ rP r^ r r r¾ rÎ rX rÐ rØ r r0 rÚ r rB rÜ rï rð rñ r< rD r< rE ú<module>r^ s@ ðÜ Û Û Û Û Û
|
Û Û Ý Ý Ý "÷÷ ÷ õ ÷ BÓ Aå !áÛß7Ò7à
|
CØJØJØKå 'ß Fß 9ð ×ÑzÒ!Þ0å6å %Ý #Ý 1ß T÷÷ ñ õ $ß HÑ H÷õ ð Ø
|
Ø Ø Ø ô ô ð × Ñ ð EÐ+Ð->Ð@SÐSÑTÑUÓ UÙØ'Mà%Mô>hô >ôD 8ô Dð Ð0Ð2NÐNÑOÐ ÷r 'ñ r 'ôj6*Ð#ô 6*ôrL,Jô L,÷^N ñ N ôbÐ!3ô ð0 / ðhtnó ò ñ CSàØ Ø"'Ø #Ø #Ø Ø!$Ø %Ø$:Ø$:Øñ óCÐ G C¨°#°v°+Ñ)>Ð$>Ñ ?ó ô"I Uõ ð23ð 2=ó 2ñj eÐ+Ô,÷j ñ j ôZM%^õ M%r<
|
