Ë
|
|
çúh@. ã ó2 d dl mZmZ d dlmZmZ d dlmZmZmZm Z d dl
|
m Z m Z m Z d dlmZmZ d dlmZ d dlmZ d dlmZmZmZ d d lmZm Z m Z m Z d d
|
l m Z m!Z!m"Z"m#Z#m$Z$ d d l%m&Z& d d l'm(Z( G d de« Z) G d de)« Z* G d de)« Z+ G d de+e*« Z,y)é )ÚABCÚabstractmethod)ÚdatetimeÚ timedelta)ÚAnyÚCallableÚListÚOptional)ÚPipelineÚPubSubÚPubSubWorkerThread)ÚEventDispatcherInterfaceÚOnCommandsFailEvent)ÚState)Ú DEFAULT_AUTO_FALLBACK_INTERVAL)ÚDatabaseÚ DatabasesÚ SyncDatabase)ÚActiveDatabaseChangedÚ&CloseConnectionOnActiveDatabaseChangedÚRegisterCommandFailureÚ"ResubscribeOnActiveDatabaseChanged)ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYÚ DefaultFailoverStrategyExecutorÚFailoverStrategyÚFailoverStrategyExecutor)ÚFailureDetector)ÚRetryc ód e Zd Zeedefd« « Zej ededdfd« « Zy)ÚCommandExecutorÚreturnc ó y)z Returns auto-fallback interval.N© ©Úselfs õq H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/command_executor.pyÚauto_fallback_intervalz&CommandExecutor.auto_fallback_interval ó ð ó r( Nc ó y)z Sets auto-fallback interval.Nr$ ©r& r( s r' r( z&CommandExecutor.auto_fallback_interval" r) r* )Ú__name__Ú
|
__module__Ú __qualname__Úpropertyr Úfloatr( Úsetterr$ r* r' r! r! sS Ø Øð ¨ò ó ó ð ð ×"Ñ"Øð ¸Uð Àtò ó ó #ñ r* r! c óh e Zd ZefdefdZedefd« Zej de ddfd« ZddZ
|
y) ÚBaseCommandExecutorr( c ó || _ | y ©N©Ú_auto_fallback_intervalr, s r' Ú__init__z BaseCommandExecutor.__init__* s ð (>Ô$Ú r* r" c ó | j S r6 r7 r% s r' r( z*BaseCommandExecutor.auto_fallback_interval1 s à×+Ñ+Ð+r* Nc ó || _ y r6 r7 r, s r' r( z*BaseCommandExecutor.auto_fallback_interval5 s
|
à'=Õ$r* c ó | j t k( ry t j « t | j ¬« z | _ y )N)Úseconds)r8 r r Únowr Ú_next_fallback_attemptr% s r' Ú_schedule_next_fallbackz+BaseCommandExecutor._schedule_next_fallback9 s7 Ø × 'Ñ 'Ô+IÒ IØ ä&.§l¡l£n´yØ×0Ñ0ô8
|
ñ '
|
Õ#r* )r" N) r- r. r/ r r1 r9 r0 r( r2 Úintr@ r$ r* r' r4 r4 ) s] ð )Gñ.à %ó.ð ð,¨ò ,ó ð,ð ×"Ñ"ð>¸Sð >ÀTò >ó #ð>ô
|
r* r4 c óð e Zd Zeedefd« « Zeedee fd« « Z ededdfd« Z
|
eede e fd« « Z e j ededdfd « « Z eede e fd
|
« « Zej ed eddfd « « Zeedefd « « Zeedefd« « Zed « Zed « Zedefd« Zedeegdf fd« Z ede fd« Z ede de fd« Z!y)ÚSyncCommandExecutorr" c ó y)z Returns a list of databases.Nr$ r% s r' Ú databasesz SyncCommandExecutor.databasesC r) r* c ó y)z$Returns a list of failure detectors.Nr$ r% s r' Úfailure_detectorsz%SyncCommandExecutor.failure_detectorsI r) r* Úfailure_detectorNc ó y)z=Adds a new failure detector to the list of failure detectors.Nr$ ©r& rH s r' Úadd_failure_detectorz(SyncCommandExecutor.add_failure_detectorO ó ð r* c ó y)z"Returns currently active database.Nr$ r% s r' Úactive_databasez#SyncCommandExecutor.active_databaseT r) r* Údatabasec ó y)z#Sets the currently active database.Nr$ )r& rO s r' rN z#SyncCommandExecutor.active_databaseZ r) r* c ó y)z Returns currently active pubsub.Nr$ r% s r' Ú active_pubsubz!SyncCommandExecutor.active_pubsub` r) r* Úpubsubc ó y)z Sets currently active pubsub.Nr$ ©r& rS s r' rR z!SyncCommandExecutor.active_pubsubf r) r* c ó y)z#Returns failover strategy executor.Nr$ r% s r' Úfailover_strategy_executorz.SyncCommandExecutor.failover_strategy_executorl r) r* c ó y)z Returns command retry object.Nr$ r% s r' Ú command_retryz!SyncCommandExecutor.command_retryr r) r* c ó y)z:Initializes a PubSub object on a currently active databaseNr$ )r& Úkwargss r' rS zSyncCommandExecutor.pubsubx rL r* c ó y)z*Executes a command and returns the result.Nr$ )r& ÚargsÚoptionss r' Úexecute_commandz#SyncCommandExecutor.execute_command} rL r* Ú command_stackc ó y)z)Executes a stack of commands in pipeline.Nr$ )r& r` s r' Úexecute_pipelinez$SyncCommandExecutor.execute_pipeline rL r* Ú transactionc ó y)z1Executes a transaction block wrapped in callback.Nr$ )r& rc Úwatchesr^ s r' Úexecute_transactionz'SyncCommandExecutor.execute_transaction s ð
|
r* Ú method_namec ó y)z*Executes a given method on active pub/sub.Nr$ )r& rg r] r[ s r' Úexecute_pubsub_methodz)SyncCommandExecutor.execute_pubsub_method rL r* Ú
|
sleep_timec ó y)z!Executes pub/sub run in a thread.Nr$ )r& rj r[ s r' Úexecute_pubsub_runz&SyncCommandExecutor.execute_pubsub_run rL r* )"r- r. r/ r0 r r rE r r rG rK r
|
r rN r2 r r rR r rW r rY rS r_ Útuplerb r r rf Ústrri r1 r rl r$ r* r' rC rC B s Ø Øð 9ò ó ó ð ð Øð 4¨Ñ#8ò ó ó ð ð ð °_ð Èò ó ð ð Øð ¨(Ñ!3ò ó ó ð ð ×ÑØð ¨ ð ¸ò ó ó ð ð Øð x¨Ñ /ò ó ó ð ð ×ÑØð Fð ¨tò ó ó ð ð Øð Ð,Dò ó ó ð ð Øð uò ó ó ð ð ñ ó ð ð ñ ó ð ð ð ¨eò ó ð ð ð Ø# X J°Ð$4Ñ5ò ó ð ð ð °ò ó ð ð ð ¨Uð Àò ó ñ r* rC c óÄ e Zd Zeeefdee dede de
|
de de de de f fd Zed
|
efd « Zed
|
ee fd « Zd ed
|
dfdZed
|
e fd« Zed
|
ee fd« Zej. ded
|
dfd« Zed
|
ee fd« Zej. ded
|
dfd« Zed
|
efd« Zd Z de fdZ de e gdf fd Z!d Z"d e#fd Z$d)d Z%d*d!e d"e fd#Z&d$ Z'd% Z(d&e fd'Z)d( Z* xZ+S )+ÚDefaultCommandExecutorrG rE rY Úfailover_strategyÚevent_dispatcherÚfailover_attemptsÚfailover_delayr( c ó 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)Úsuperr9 Úset_command_executorÚ
|
_databasesÚ_failure_detectorsÚ_command_retryr Ú_failover_strategy_executorÚ_event_dispatcherÚ_active_databaseÚ_active_pubsubÚ_active_pubsub_kwargsÚ_setup_event_dispatcherr@ ) r& rG rE rY rq rr rs rt r( ÚfdÚ __class__s r' r9 z DefaultCommandExecutor.__init__ s ø ô0 ÑÐ/Ô0à#ò ;BØ × #Ñ #°TÐ #Õ :ð ;ð $Ø"3Ô Ø +ÔÜ+JØ Ð 0°.ó,
|
Ô(ð "2Ô Ø48Ô Ø04ÔØ%'Ô"Ø ×$Ñ$Ô&Ø ×$Ñ$Õ&r* r" c ó | j S r6 )ry r% s r' rE z DefaultCommandExecutor.databasesÄ s àÐ r* c ó | j S r6 )rz r% s r' rG z(DefaultCommandExecutor.failure_detectorsÈ s à×&Ñ&Ð&r* rH Nc ó: | j j |« y r6 )rz ÚappendrJ s r' rK z+DefaultCommandExecutor.add_failure_detectorÌ s Ø × Ñ ×&Ñ&Ð'7Õ8r* c ó | j S r6 )r{ r% s r' rY z$DefaultCommandExecutor.command_retryÏ ó à×"Ñ"Ð"r* c ó | j S r6 )r~ r% s r' rN z&DefaultCommandExecutor.active_databaseÓ s à×$Ñ$Ð$r* rO c ó° | j }|| _ |A||ur<| j j t || j | fi | j ¤« y y y r6 )r~ r} Údispatchr r )r& rO Ú
|
old_actives r' rN z&DefaultCommandExecutor.active_database× sf à×*Ñ*
|
Ø (Ô à Ð ! j¸Ñ&@Ø × "Ñ "× +Ñ +Ü%Ø Ø×)Ñ)Øñð ×0Ñ0ñ õ ð 'AÐ !r* c ó | j S r6 ©r r% s r' rR z$DefaultCommandExecutor.active_pubsubæ r r* rS c ó || _ y r6 r rU s r' rR z$DefaultCommandExecutor.active_pubsubê s
|
à $Õr* c ó | j S r6 )r| r% s r' rW z1DefaultCommandExecutor.failover_strategy_executorî s à×/Ñ/Ð/r* c ó: fd} j |« S )Nc óv j j j i ¤} j « | S r6 )r~ Úclientr_ Ú_register_command_execution)Úresponser] r^ r& s r' Úcallbackz8DefaultCommandExecutor.execute_command.<locals>.callbackó s9 ø ØCt×,Ñ,×3Ñ3×CÑCÀTÐUÈWÑUHØ × ,Ñ ,¨TÔ 2ØOr* ©Ú _execute_with_failure_detection)r& r] r^ r s ``` r' r_ z&DefaultCommandExecutor.execute_commandò s ú ö ð
|
×3Ñ3°H¸dÓCÐCr* r` c ó6 fd} j |« S )Nc óö j j j « 5 } D ] \ }} | j |i |¤ | j « }j « |cd d d « S # 1 sw Y y xY wr6 )r~ r Úpipeliner_ Úexecuter )ÚpipeÚcommandr^ r r` r& s r' r z9DefaultCommandExecutor.execute_pipeline.<locals>.callbackû sy ø Ø×&Ñ&×-Ñ-×6Ñ6Ó8ð ¸DØ(5ò >Ñ$GWØ(D×(Ñ(¨'Ð=°WÓ=ð>ð <<>Ø×0Ñ0° Ô?Ø ÷ ÷ ò ús ¦?A/Á/A8r )r& r` r s `` r' rb z'DefaultCommandExecutor.execute_pipelineú s ù õ ð ×3Ñ3°H¸mÓLÐLr* rc c ó< fd} j |« S )Nc ó~ j j j g¢i ¤} j d« | S ©Nr$ )r~ r rc r )r r^ r& rc re s r' r z<DefaultCommandExecutor.execute_transaction.<locals>.callback sI ø Ø?t×,Ñ,×3Ñ3×?Ñ?ØðØ %òØ)0ñHð × ,Ñ ,¨RÔ 0ØOr* r )r& rc re r^ r s ```` r' rf z*DefaultCommandExecutor.execute_transaction s û ÷ ð ×3Ñ3°HÓ=Ð=r* c ó4 fd} j |« S )Nc ó j 2 j j j di ¤_ _ y r¢ )r r~ r rS r )r[ r& s r' r z/DefaultCommandExecutor.pubsub.<locals>.callback s> ø Ø×"Ñ"Ð*Ø&I d×&;Ñ&;×&BÑ&B×&IÑ&IÑ&SÈFÑ&SÔ#Ø-3Ô*Ør* r )r& r[ r s `` r' rS z DefaultCommandExecutor.pubsub s ù õ ð ×3Ñ3°HÓ=Ð=r* rg c ó@ fd} j |g¢ S )Nc óf t j « } | i ¤}j « |S r6 )ÚgetattrrR r )Úmethodr r] r[ rg r& s r' r z>DefaultCommandExecutor.execute_pubsub_method.<locals>.callback s7 ø Ü T× /Ñ /°Ó=FÙ tÐ. vÑ.HØ × ,Ñ ,¨TÔ 2ØOr* r )r& rg r] r[ r s ```` r' ri z,DefaultCommandExecutor.execute_pubsub_method s" û ÷ ð 4t×3Ñ3°HÐD¸tÒDÐDr* c ó8 fd} j |« S )Nc ó> j j fi ¤S r6 )r Ú run_in_thread)r[ r& rj s r' r z;DefaultCommandExecutor.execute_pubsub_run.<locals>.callback% s! ø Ø44×&Ñ&×4Ñ4°ZÑJÀ6ÑJÐ Jr* r )r& rj r[ r s ``` r' rl z)DefaultCommandExecutor.execute_pubsub_run$ s ú ö Kð ×3Ñ3°HÓ=Ð=r* r Úcmdsc ó\ fd j j fd fd« S )zO
|
Execute a commands execution callback with failure detection.
|
c ó2 j « « S r6 )Ú_check_active_database)r r& s r' ÚwrapperzGDefaultCommandExecutor._execute_with_failure_detection.<locals>.wrapper/ s ø à × 'Ñ 'Ô )Ù:Ð r* c ó « S r6 r$ )r° s r' ú<lambda>zHDefaultCommandExecutor._execute_with_failure_detection.<locals>.<lambda>5 s ø GI r* c ó* j | g¢ S r6 )Ú_on_command_fail)Úerrorr¬ r& s r' r² zHDefaultCommandExecutor._execute_with_failure_detection.<locals>.<lambda>6 s ø Ð/$×/Ñ/°Ð=¸Ò= r* )r{ Úcall_with_retry)r& r r¬ r° s ```@r' r z6DefaultCommandExecutor._execute_with_failure_detection* s) û õ
|
ð
|
×"Ñ"×2Ñ2Û Ü =ó
|
ð
|
r* c óN | j j t ||« « y r6 )r} r r )r& rµ r] s r' r´ z'DefaultCommandExecutor._on_command_fail9 s Ø × Ñ ×'Ñ'Ô(;¸DÀ%Ó(HÕIr* c óH | j e| j j j t j k7 s4| j
|
t k7 rR| j t j « k r0| j j « | _ | j « yyy)zB
|
Checks if active a database needs to be updated.
|
N)r~ ÚcircuitÚstateÚCBStateÚCLOSEDr8 r r? r r> r| r rN r@ r% s r' r¯ z-DefaultCommandExecutor._check_active_database< s ð
|
× !Ñ !Ð )Ø×$Ñ$×,Ñ,×2Ñ2´g·n±nÒDà×,Ñ,Ô0NÒNØ×/Ñ/´8·<±<³>ÒAð $(×#CÑ#C×#KÑ#KÓ#MDÔ Ø × (Ñ (Õ *ð Bð Or* Úcmdc óH | j D ] }|j |« y r6 )rz Úregister_command_execution)r& r½ Údetectors r' r z2DefaultCommandExecutor._register_command_executionK s% Ø ×/Ñ/ò 5HØ × /Ñ /°Õ 4ñ 5r* c óª t | j « }t « }t « }| j j t |gt ||gi« y)z0
|
Registers necessary listeners.
|
N)r rz r r r} Úregister_listenersr r )r& Úfailure_listenerÚresubscribe_listenerÚclose_connection_listeners r' r z.DefaultCommandExecutor._setup_event_dispatcherO sW ô 2°$×2IÑ2IÓJÐÜ AÓ CÐ Ü$JÓ$LÐ!Ø × Ñ ×1Ñ1ä#Ð&6Ð%7Ü%Ø-Ø(ð(ð õ
|
r* )r" r )r$ ),r- r. r/ r r r r r r r r r rA r1 r9 r0 rE rG rK rY r
|
r rN r2 r rR r rW r_ rm rb r r rf rS rn ri rl r r´ r¯ r r Ú __classcell__)r s @r' rp rp sð ø ð ";Ø 6Ø(Fñ('à Ñ0ð('ð ð('ð ð ('ð
|
,ð ('ð 3ð ('ð ð('ð ð('ð !&õ('ðT ð 9ò ó ð ð ð' 4¨Ñ#8ò 'ó ð'ð9°_ð 9Èó 9ð ð#uò #ó ð#ð ð% ¨,Ñ!7ò %ó ð%ð ×Ñð ¨ ð ¸ò ó ð ð ð#x¨Ñ /ò #ó ð#ð ×Ñð% Fð %¨tò %ó ð%ð ð0Ð,Dò 0ó ð0òDð
|
M¨eó
|
Mð
|
>Ø# X J°Ð$4Ñ5ó
|
>ò>ðE°ó Eó>ñ
|
¸ð
|
Èó
|
ò Jò +ð 5¨uó 5ö
|
r* rp N)-Úabcr r r r Útypingr r r r
|
Ú redis.clientr r r Ú redis.eventr r Úredis.multidb.circuitr r» Úredis.multidb.configr Úredis.multidb.databaser r r Úredis.multidb.eventr r r r Úredis.multidb.failoverr r r r r Ú redis.multidb.failure_detectorr Ú redis.retryr r! r4 rC rp r$ r* r' ú<module>rÒ s{ ðß #ß (ß 0Ó 0ç =Ñ =ß EÝ 2Ý ?ß DÑ D÷ó ÷ õ õ ;Ý ô cô ô
|
/ô
|
ô2T /ô T ônE
|
Ð 0Ð2Eõ E
|
r*
|
