Ë
|
|
çúhn. ã ó6 d dl mZ d dlmZ d dlmZ d dlmZmZmZm Z m
|
Z
|
m Z d dl m Z d dlmZmZ d dlmZmZmZ d dlmZmZmZmZ d d lmZm Z m Z m Z m Z d d
|
l m!Z! d d l"m#Z# d d l$m%Z%m&Z& d d l'm(Z) d dl*m+Z+m,Z, d dl-m.Z. d dl/m0Z0 G d de,« Z1 G d de+e1« Z2y)é )Úabstractmethod)Úiscoroutinefunction)Údatetime)ÚAnyÚ AwaitableÚCallableÚListÚOptionalÚUnion)Ú RedisCluster)ÚPipelineÚPubSub)Ú AsyncDatabaseÚDatabaseÚ Databases)ÚAsyncActiveDatabaseChangedÚ&CloseConnectionOnActiveDatabaseChangedÚRegisterCommandFailureÚ"ResubscribeOnActiveDatabaseChanged)ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYÚAsyncFailoverStrategyÚ DefaultFailoverStrategyExecutorÚFailoverStrategyExecutor)ÚAsyncFailureDetector)ÚRetry)ÚAsyncOnCommandsFailEventÚEventDispatcherInterface)ÚState)ÚBaseCommandExecutorÚCommandExecutor)Ú DEFAULT_AUTO_FALLBACK_INTERVAL)ÚKeyTc óÒ e Zd Zeedefd« « Zeedee fd« « Z ededdfd« Z
|
eede e fd« « Z ede ddfd « Zeede e fd
|
« « Zej" ed eddfd « « Zeedefd « « Zeedefd« « Zed « Zed « Zedefd« Zedeegdf fd« Z ede fd« Z ede de fd« Z!y)ÚAsyncCommandExecutorÚreturnc ó y)z Returns a list of databases.N© ©Úselfs õy H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/command_executor.pyÚ databasesz AsyncCommandExecutor.databases ó ð ó c ó y)z$Returns a list of failure detectors.Nr( r) s r+ Úfailure_detectorsz&AsyncCommandExecutor.failure_detectors& r- r. Úfailure_detectorNc ó y)z=Adds a new failure detector to the list of failure detectors.Nr( ©r* r1 s r+ Úadd_failure_detectorz)AsyncCommandExecutor.add_failure_detector, s ð r. c ó y)z"Returns currently active database.Nr( r) s r+ Úactive_databasez$AsyncCommandExecutor.active_database1 r- r. Údatabasec ó K yw)z#Sets the currently active database.Nr( )r* r7 s r+ Úset_active_databasez(AsyncCommandExecutor.set_active_database7 ó è ø ð ùó c ó y)z Returns currently active pubsub.Nr( r) s r+ Ú active_pubsubz"AsyncCommandExecutor.active_pubsub< r- r. Úpubsubc ó y)z Sets currently active pubsub.Nr( ©r* r> s r+ r= z"AsyncCommandExecutor.active_pubsubB r- r. c ó y)z#Returns failover strategy executor.Nr( r) s r+ Úfailover_strategy_executorz/AsyncCommandExecutor.failover_strategy_executorH r- r. c ó y)z Returns command retry object.Nr( r) s r+ Ú command_retryz"AsyncCommandExecutor.command_retryN r- r. c ó K yw)z:Initializes a PubSub object on a currently active databaseNr( ©r* Úkwargss r+ r> zAsyncCommandExecutor.pubsubT r: r; c ó K yw)z*Executes a command and returns the result.Nr( )r* ÚargsÚoptionss r+ Úexecute_commandz$AsyncCommandExecutor.execute_commandY r: r; Ú command_stackc ó K yw)z)Executes a stack of commands in pipeline.Nr( )r* rL s r+ Úexecute_pipelinez%AsyncCommandExecutor.execute_pipeline^ r: r; Ú transactionc ó K yw)z1Executes a transaction block wrapped in callback.Nr( )r* rO ÚwatchesrJ s r+ Úexecute_transactionz(AsyncCommandExecutor.execute_transactionc s è ø ð
|
ùr; Ú method_namec ó K yw)z*Executes a given method on active pub/sub.Nr( )r* rS rI rG s r+ Úexecute_pubsub_methodz*AsyncCommandExecutor.execute_pubsub_methodj r: r; Ú
|
sleep_timec ó K yw)z!Executes pub/sub run in a thread.Nr( )r* rV rG s r+ Úexecute_pubsub_runz'AsyncCommandExecutor.execute_pubsub_runo r: r; )"Ú__name__Ú
|
__module__Ú __qualname__Úpropertyr r r, r r r0 r4 r
|
r r6 r9 r r= Úsetterr rB r rD r> rK ÚtuplerN r r rR ÚstrrU Úfloatr rX r( r. r+ r% r% s Ø Øð 9ò ó ó ð ð Øð 4Ð(<Ñ#=ò ó ó ð ð ð Ð5Ið Èdò ó ð ð Øð ¨-Ñ!8ò ó ó ð ð ð °-ð ÀDò ó ð ð Øð x¨Ñ /ò ó ó ð ð ×ÑØð Fð ¨tò ó ó ð ð Øð Ð,Dò ó ó ð ð Øð uò ó ó ð ð ñ ó ð ð ñ ó ð ð ð °Eò ó ð ð ð Ø# X J°Ð$4Ñ5ò ó ð ð ð °sò ó ð ð ð °5ð Àsò ó ñ r. r% c óê e Zd Zeeefdee dede de
|
de de de de f fd Zed
|
efd « Zed
|
ee fd « Zd ed
|
dfdZed
|
ee fd« Zded
|
dfdZed
|
ee fd« Zej2 ded
|
dfd« Zed
|
efd« Zed
|
e fd« Z d Z d Z de fdZ dd dd d e!d ge"e#e$e# f f d e%d!ee& d"e'd#ee f
|
d$Z(d%e&fd&Z) d1d'e d
|
e#fd(Z* d2d)e!d*e fd+Z+d, Z,d- Z-d.e fd/Z.d0 Z/ xZ0S )3ÚDefaultCommandExecutorr0 r, rD Úfailover_strategyÚevent_dispatcherÚfailover_attemptsÚfailover_delayÚauto_fallback_intervalc ó t
|
| |« |D ] } | j | ¬« || _ || _ || _ t |||« | _ || _ d| _ d| _
|
i | _ | j « | j « y)a°
|
Initialize the DefaultCommandExecutor instance.
|
|
Args:
|
failure_detectors: List of failure detector instances to monitor database health
|
databases: Collection of available databases to execute commands on
|
command_retry: Retry policy for failed command execution
|
failover_strategy: Strategy for handling database failover
|
event_dispatcher: Interface for dispatching events
|
failover_attempts: Number of failover attempts
|
failover_delay: Delay between failover attempts
|
auto_fallback_interval: Time interval in seconds between attempts to fall back to a primary database
|
)Úcommand_executorN)ÚsuperÚ__init__Úset_command_executorÚ
|
_databasesÚ_failure_detectorsÚ_command_retryr Ú_failover_strategy_executorÚ_event_dispatcherÚ_active_databaseÚ_active_pubsubÚ_active_pubsub_kwargsÚ_setup_event_dispatcherÚ_schedule_next_fallback) r* r0 r, rD rc rd re rf rg ÚfdÚ __class__s r+ rk z DefaultCommandExecutor.__init__v s ø ô0 ÑÐ/Ô0à#ò ;BØ × #Ñ #°TÐ #Õ :ð ;ð $Ø"3Ô Ø +ÔÜ+JØ Ð 0°.ó,
|
Ô(ð "2Ô Ø48Ô Ø04ÔØ%'Ô"Ø ×$Ñ$Ô&Ø ×$Ñ$Õ&r. r& c ó | j S ©N)rm r) s r+ r, z DefaultCommandExecutor.databases s àÐ r. c ó | j S rz )rn r) s r+ r0 z(DefaultCommandExecutor.failure_detectors¤ s à×&Ñ&Ð&r. r1 Nc ó: | j j |« y rz )rn Úappendr3 s r+ r4 z+DefaultCommandExecutor.add_failure_detector¨ s Ø × Ñ ×&Ñ&Ð'7Õ8r. c ó | j S rz )rr r) s r+ r6 z&DefaultCommandExecutor.active_database« s à×$Ñ$Ð$r. r7 c óÌ K | j }|| _ |I||urD| j j t || j | fi | j ¤« d { y y y 7 wrz )rr rq Údispatch_asyncr rt )r* r7 Ú
|
old_actives r+ r9 z*DefaultCommandExecutor.set_active_database¯ sy è ø Ø×*Ñ*
|
Ø (Ô à Ð ! j¸Ñ&@Ø×(Ñ(×7Ñ7Ü*Ø Ø×)Ñ)Øñð ×0Ñ0ñ ó÷ ñ ð 'AÐ !ð ús AA$ÁA"ÁA$c ó | j S rz ©rs r) s r+ r= z$DefaultCommandExecutor.active_pubsub½ ó à×"Ñ"Ð"r. r> c ó || _ y rz r r@ s r+ r= z$DefaultCommandExecutor.active_pubsubÁ s
|
à $Õr. c ó | j S rz )rp r) s r+ rB z1DefaultCommandExecutor.failover_strategy_executorÅ s à×/Ñ/Ð/r. c ó | j S rz )ro r) s r+ rD z$DefaultCommandExecutor.command_retryÉ r r. c óà | j bt | j j t « r t d« | j j j di |¤| _ || _ y y )Nz(PubSub is not supported for RedisClusterr( )rs Ú
|
isinstancerr Úclientr Ú
|
ValueErrorr> rt rF s r+ r> z DefaultCommandExecutor.pubsubÍ sa Ø × Ñ Ð &Ü$×/Ñ/×6Ñ6¼ ÔEÜ Ð!KÓLÐLà"E $×"7Ñ"7×">Ñ">×"EÑ"EÑ"OÈÑ"ODÔ Ø)/DÕ &ð 'r. c óV K fd} j |« d { S 7 w)Nc ó¦ K j j j i ¤ d { } j « d { | S 7 7 wrz )rr r rK Ú_register_command_execution)ÚresponserI rJ r* s r+ Úcallbackz8DefaultCommandExecutor.execute_command.<locals>.callbackÖ s[ øè ø Ø IT× 2Ñ 2× 9Ñ 9× IÑ IØð Ø ñ ÷ Hð ×2Ñ2°4Ó8× 8Ð 8ØOð øð 9ús! *AA ®AÁAÁAÁA©Ú _execute_with_failure_detection)r* rI rJ r s ``` r+ rK z&DefaultCommandExecutor.execute_commandÕ s' úè ø ö ð ×9Ñ9¸(ÀDÓI×IÐIÐIús
)¢'£)rL c óR K fd} j |« d { S 7 w)Nc ó` K j j j « 4 d { } D ] \ }} | j |i |¤ | j « d { }j « d { |cd d d « d { S 7 d7 27 7 # 1 d { 7 sw Y y xY wwrz )rr r ÚpipelinerK Úexecuter )ÚpipeÚcommandrJ r rL r* s r+ r z9DefaultCommandExecutor.execute_pipeline.<locals>.callbackà sª øè ø Ø×,Ñ,×3Ñ3×<Ñ<Ó>÷ ð À$Ø(5ò >Ñ$GWØ(D×(Ñ(¨'Ð=°WÓ=ð>ð "&§ ¡ £ ×/Ø×6Ñ6°}ÓE×EÐEØ ÷ ÷ ò øð 0øØEøð ø÷ ÷ ñ üsh )B.¬BB.°0BÁ BÁ!BÁ9BÁ:BÁ? B. B B.ÂBÂBÂB.ÂB+ B"  B+Â'B.r )r* rL r s `` r+ rN z'DefaultCommandExecutor.execute_pipelineß s' ùè ø õ ð ×9Ñ9¸(ÀMÓR×RÐRÐRús ' %¡'F©Ú
|
shard_hintÚvalue_from_callableÚ watch_delayÚfuncr rQ r r r c ó` K fd} j |« d { S 7 w)Nc ó² K j j j g¢d d { } j d« d { | S 7 7 w)Nr r( )rr r rO r )r r r* r r r rQ s r+ r z<DefaultCommandExecutor.execute_transaction.<locals>.callbackó sk øè ø Ø ET× 2Ñ 2× 9Ñ 9× EÑ EØð àñ ð &Ø$7Ø 'ò ÷ Hð ×2Ñ2°2Ó6× 6Ð 6ØOðøð 7ús! 0A³A´AÁ AÁ AÁAr )r* r r r r rQ r s `````` r+ rR z*DefaultCommandExecutor.execute_transactionë s* ýè ø ÷ ñ ð ×9Ñ9¸(ÓC×CÐCÐCús .§,¨.rS c ó\ K fd} j |g¢ d { S 7 w)Nc ó¾ K t j « } t | « r | i ¤ d { }n | i ¤}j « d { |S 7 (7 wrz )Úgetattrr= r r )Úmethodr rI rG rS r* s r+ r z>DefaultCommandExecutor.execute_pubsub_method.<locals>.callback sf øè ø Ü T× /Ñ /°Ó=FÜ" 6Ô*Ù!'¨Ð!8°Ñ!8×8á! 4Ð2¨6Ñ2à×2Ñ2°4Ó8× 8Ð 8ØOð 9øð 9ús! -A °A±!A ÁAÁA ÁA r )r* rS rI rG r s ```` r+ rU z,DefaultCommandExecutor.execute_pubsub_method s, ûè ø ÷ ð :T×9Ñ9¸(ÐJÀTÒJ×JÐJÐJús ,¥*¦,rV c óX K fd} j |« d { S 7 w)Nc ó\ K j j ¬« d { S 7 w)N)Ú poll_timeoutÚexception_handlerr> )rs Úrun)r§ r> r* rV s r+ r z;DefaultCommandExecutor.execute_pubsub_run.<locals>.callback s8 øè ø Ø ×,Ñ,×0Ñ0Ø 'Ø"3Ø ð 1ó ÷ ð ð ús ",¥*¦,r )r* rV r§ r> r s ```` r+ rX z)DefaultCommandExecutor.execute_pubsub_run s% ûè ø ÷ ð ×9Ñ9¸(ÓC×CÐCÐCús *£(¤*r Úcmdsc óx K fd j j fd fd« d{ S 7 w)zO
|
Execute a commands execution callback with failure detection.
|
c ób K j « d { « d { S 7 7 wrz )Ú_check_active_database)r r* s r+ ÚwrapperzGDefaultCommandExecutor._execute_with_failure_detection.<locals>.wrapper s- øè ø à×-Ñ-Ó/× /Ð /Ù!×#Ð #ð 0øØ#ús /+/¦-§//c ó « S rz r( )r s r+ ú<lambda>zHDefaultCommandExecutor._execute_with_failure_detection.<locals>.<lambda>& s ø GI r. c ó* j | g¢ S rz )Ú_on_command_fail)Úerrorr© r* s r+ r¯ zHDefaultCommandExecutor._execute_with_failure_detection.<locals>.<lambda>' s ø Ð/$×/Ñ/°Ð=¸Ò= r. N)ro Úcall_with_retry)r* r r© r s ```@r+ r z6DefaultCommandExecutor._execute_with_failure_detection s7 ûè ø õ $ð
|
×(Ñ(×8Ñ8Û Ü =ó
|
÷
|
ð
|
ð
|
ús -:³8´:c ó K | j e| j j j t j k7 s4| j
|
t k7 rl| j t j « k rJ| j | j j « d{ « d{ | j « yyy7 #7 w)zB
|
Checks if active a database needs to be updated.
|
N)rr ÚcircuitÚstateÚCBStateÚCLOSEDÚ_auto_fallback_intervalr" Ú_next_fallback_attemptr Únowr9 rp r rv r) s r+ r¬ z-DefaultCommandExecutor._check_active_database* sª è ø ð
|
× !Ñ !Ð )Ø×$Ñ$×,Ñ,×2Ñ2´g·n±nÒDà×,Ñ,Ô0NÒNØ×/Ñ/´8·<±<³>ÒAð ×*Ñ*Ø×6Ñ6×>Ñ>Ó@×@ó÷ ð ð × (Ñ (Õ *ð Bð Oð
|
Aøð ús$ BC C  CÂ(CÂ)CÃCc ój K | j j t ||« « d { y 7 wrz )rq r r )r* r² rI s r+ r± z'DefaultCommandExecutor._on_command_fail; s. è ø Ø×$Ñ$×3Ñ3Ü $ T¨5Ó 1ó
|
÷
|
ò
|
ús )3«1¬3Úcmdc ód K | j D ] }|j |« d { y 7 wrz )rn Úregister_command_execution)r* r½ Údetectors r+ r z2DefaultCommandExecutor._register_command_execution@ s2 è ø Ø ×/Ñ/ò ;HØ×5Ñ5°cÓ:× :Ñ :ñ ;Ø :ús $0¦.§0c óª t | j « }t « }t « }| j j t |gt ||gi« y)z0
|
Registers necessary listeners.
|
N)r rn r r rq Úregister_listenersr r )r* Úfailure_listenerÚresubscribe_listenerÚclose_connection_listeners r+ ru z.DefaultCommandExecutor._setup_event_dispatcherD sW ô 2°$×2IÑ2IÓJÐÜ AÓ CÐ Ü$JÓ$LÐ!Ø × Ñ ×1Ñ1ä(Ð+;Ð*<Ü*Ø-Ø(ð-ð õ
|
r. )NN)r( )1rY rZ r[ r r r" r r r r r r Úintr` rk r\ r, r0 r4 r
|
r r6 r9 r r= r] r rB rD r> rK r^ rN r r r r r# r_ ÚboolrR rU rX r r¬ r± r ru Ú __classcell__)rx s @r+ rb rb u sM ø ð ";Ø 6Ø(Fñ('à Ð 4Ñ5ð('ð ð('ð ð ('ð
|
1ð ('ð 3ð ('ð ð('ð ð('ð !&õ('ðT ð 9ò ó ð ð ð' 4Ð(<Ñ#=ò 'ó ð'ð9Ð5Ið 9Èdó 9ð ð% ¨-Ñ!8ò %ó ð%ð °-ð ÀDó ð ð#x¨Ñ /ò #ó ð#ð ×Ñð% Fð %¨tò %ó ð%ð ð0Ð,Dò 0ó ð0ð ð#uò #ó ð#ò0òJð
|
S°Eó
|
Sð %)Ø$)Ø'+ò Dà
|
| U¨3° ¸#±Ð+>Ñ%?Ð?Ñ@ðDð ðDð SMð Dð
|
"ð Dð e_ó Dð* K°só Kð AEñ
|
DØ ð
|
Dà ó
|
Dð 13ñ
|
Ø ð
|
Ø(-ó
|
ò"+ò"
|
ð
|
;°Uó ;ö
|
r. rb N)3Úabcr Úasyncior r Útypingr r r r r
|
r Ú redis.asyncior Úredis.asyncio.clientr r Ú redis.asyncio.multidb.databaser r r Úredis.asyncio.multidb.eventr r r r Ú redis.asyncio.multidb.failoverr r r r r Ú&redis.asyncio.multidb.failure_detectorr Úredis.asyncio.retryr Ú redis.eventr r Úredis.multidb.circuitr r· Ú redis.multidb.command_executorr r! Úredis.multidb.configr" Ú redis.typingr# r% rb r( r. r+ ú<module>rØ sm ðÝ Ý 'Ý ß B× Bå &ß 1ß MÑ M÷ó ÷ õ õ HÝ %ß JÝ 2ß OÝ ?Ý ôS ?ô S ôl^
|
Ð 0Ð2Fõ ^
|
r.
|
