Ë
|
|
çúhbH ã ón d dl Z d dlZd dlmZmZmZmZmZmZm Z d dl
|
m Z d dl m Z d dlmZmZ d dlmZmZ d dlmZ d dlmZmZ d d lmZ d d
|
lm Z m Z d d l m Z d d l m Z! d d l"m#Z#m$Z$ d dl%m&Z&m'Z'm(Z( d dl)m*Z* ejV e,« Z-e* G d de e « « Z.de fdZ/ G d de e « Z0 G d d« Z1y)é N)ÚAnyÚ AwaitableÚCallableÚ CoroutineÚListÚOptionalÚUnion)Ú PubSubHandler)ÚDefaultCommandExecutor)ÚDEFAULT_GRACE_PERIODÚ MultiDbConfig)Ú AsyncDatabaseÚ Databases)ÚAsyncFailureDetector)Ú HealthCheckÚHealthCheckPolicy)ÚBackgroundScheduler)ÚAsyncCoreCommandsÚAsyncRedisModuleCommands)ÚCircuitBreaker)ÚState)ÚNoValidDatabaseExceptionÚUnhealthyDatabaseException)ÚChannelTÚ
|
EncodableTÚKeyT)Ú experimentalc óT e Zd ZdZdefdZd+dZd Zd Zde fdZ
|
d e dd
|
fd Z d e fd Z d e de fdZd e fdZd e defdZdefdZdefdZd Zd Zd
|
dd
|
dded geeee f f d e d e e d e d e e f
|
d!Z d" Z! d,d#e ee"ge#eed
|
f f fd$Z$d e de fd%Z%d&e&d'e'd(e'fd)Z(d* Z)y
|
)-Ú MultiDBClientzx
|
Client that operates on multiple logical Redis databases.
|
Should be used in Active-Active database setups.
|
Úconfigc
|
ó |j « | _ |j « | _ |j %| j j |j « |j | _ |j j |j |j « | _ |j « | _ |j %| j j |j « |j |j# « n |j | _ | j$ j' | j « |j( | _ |j, | _ |j0 | _ | j2 j5 t6 g« t9 | j | j | j2 | j$ |j: |j< | j. | j* ¬« | _ d| _ tC jD « | _# tI « | _% || _& d | _' g | _( d | _) y )N)Úfailure_detectorsÚ databasesÚ command_retryÚfailover_strategyÚfailover_attemptsÚfailover_delayÚevent_dispatcherÚauto_fallback_intervalF)*r# Ú
|
_databasesÚdefault_health_checksÚ_health_checksÚ health_checksÚextendÚhealth_check_intervalÚ_health_check_intervalÚhealth_check_policyÚvalueÚhealth_check_probesÚhealth_check_delayÚ_health_check_policyÚdefault_failure_detectorsÚ_failure_detectorsr" r% Údefault_failover_strategyÚ_failover_strategyÚ set_databasesr) Ú_auto_fallback_intervalr( Ú_event_dispatcherr$ Ú_command_retryÚupdate_supported_errorsÚConnectionRefusedErrorr r& r' Úcommand_executorÚ initializedÚasyncioÚLockÚ_hc_lockr Ú _bg_schedulerÚ_configÚ_recurring_hc_taskÚ _hc_tasksÚ_half_open_state_task)Úselfr s õo H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/client.pyÚ__init__zMultiDBClient.__init__ sÖ Ø ×*Ñ*Ó,Ø $× :Ñ :Ó <Ôà × Ñ Ð +Ø × Ñ × &Ñ & v×';Ñ';Ô <à&,×&BÑ&BÔ#Ø7=×7QÑ7Q×7WÑ7WØ × &Ñ &¨×(AÑ(Aó8
|
Ô!ð #)×"BÑ"BÓ"DÔ à × #Ñ #Ð /Ø × #Ñ #× *Ñ *¨6×+CÑ+CÔ Dð ×'Ñ'Ð/ð × ,Ñ ,Ô .à×)Ñ)ð Ô ð
|
× Ñ ×-Ñ-¨d¯o©oÔ>Ø'-×'DÑ'DÔ$Ø!'×!8Ñ!8Ô Ø $× 2Ñ 2ÔØ ×Ñ×3Ñ3Ô5KÐ4LÔMÜ 6Ø "× 5Ñ 5ØooØ ×-Ñ-Ø "× 5Ñ 5Ø $× 6Ñ 6Ø!×0Ñ0Ø !× 3Ñ 3Ø#'×#?Ñ#?ô !
|
Ô ð !ÔÜ Ü 0Ó 2ÔØ Ø"&Ô ØØ%)Õ"ó Úreturnc óZ K | j s| j « d { | S 7 w©N)rA Ú
|
initialize©rJ s rK Ú
|
__aenter__zMultiDBClient.__aenter__I s) è ø Ø× Ò Ø//Ó#× #Ð #Ø ð $ús +¢)£+c óæ K | j r| j j « | j r| j j « | j D ] }|j « y wrP )rG ÚcancelrI rH )rJ Úexc_typeÚ exc_valueÚ tracebackÚhc_tasks rK Ú __aexit__zMultiDBClient.__aexit__N sY è ø Ø × "Ò "Ø × #Ñ #× *Ñ *Ô ,Ø × %Ò %Ø × &Ñ &× -Ñ -Ô /Ø~~ò GØ NNÕ ñ ùs A/A1c ó K d }| j |¬« d{ t j | j j | j
|
| j « « | _ d}| j D ]z \ }}|j j | j « |j j t j k( sS|rV| j j |« d{ d}| |s t! d« d| _ y7 ì7 w)zT
|
Perform initialization of databases to define their initial state.
|
c ó K | wrP © )Úerrors rK Ú raise_exception_on_failed_hcz>MultiDBClient.initialize.<locals>.raise_exception_on_failed_hc[ s è ø ØKùó )Úon_errorNFTz4Initial connection failed - no active database found)Ú_check_databases_healthrB Ú create_taskrE Úrun_recurring_asyncr0 rG r* ÚcircuitÚon_state_changedÚ!_on_circuit_state_change_callbackÚstateÚCBStateÚCLOSEDr@ Úset_active_databaser rA )rJ r_ Úis_active_db_foundÚdatabaseÚweights rK rQ zMultiDBClient.initializeV s è ø ò
|
ð ×*Ñ*Ð4PÐ*ÓQ×QÐQô #*×"5Ñ"5Ø × Ñ × 2Ñ 2Ø×+Ñ+Ø×,Ñ,ó ó#
|
Ô ð #Ðà $§¡ò *Ñ Hfà × Ñ × -Ñ -¨d×.TÑ.TÔ Uð × Ñ ×%Ñ%¬¯ © Ó7Ò@RØ×+Ñ+×?Ñ?ÀÓI×IÐIØ%)Ñ"ð *ñ "Ü*ØFóð ð Õð5 Røð$ Jús. D DB,D à D à D Ã*D
|
Ã+ D Ä
|
D c ó | j S )zE
|
Returns a sorted (by weight) list of all databases.
|
)r* rR s rK Ú get_databaseszMultiDBClient.get_databases{ s ð Ð rM rm Nc ó K d}| j D ] \ }}||k( s d} n |s t d« | j |« d{ |j j t
|
j k( rE| j j d« d \ }}| j j |« d{ yt d« 7 {7 w)zL
|
Promote one of the existing databases to become an active.
|
NTú/Given database is not a member of database listé r z1Cannot set active database, database is unhealthy) r* Ú
|
ValueErrorÚ_check_db_healthre rh ri rj Ú get_top_nr@ rk r )rJ rm ÚexistsÚ existing_dbÚ_Úhighest_weighted_dbs rK rk z!MultiDBClient.set_active_database sÉ è ø ð à "ooò NKØhÓ&Ø Ùð ñ
|
Ü Ð NÓOÐ Oà×#Ñ# HÓ-×-Ð-à × Ñ × !Ñ !¤W§^¡^Ò 3Ø%)§_¡_×%>Ñ%>¸qÓ%AÀ!Ñ%DÑ "Ð Ø×'Ñ'×;Ñ;¸HÓE× EÐ EØ ä&Ø ?ó
|
ð
|
ð .øð Fús) C&CÁB?ÁA*CÂ.CÂ/CÃCc óP K | j D ] \ }}||k( s t d« | j |« d{ | j j d« d \ }}| j j ||j
|
« | j ||« d{ y7 f7 w)z;
|
Adds a new database to the database list.
|
z Given database already existsNrs r )r* rt ru rv Úaddrn Ú_change_active_database)rJ rm rx ry rz Úhighest_weights rK Ú add_databasezMultiDBClient.add_database s¥ è ø ð #ooò BNKØhÓ&Ü Ð!@ÓAÐAð Bð ×#Ñ# HÓ-×-Ð-à.2¯o©o×.GÑ.GÈÓ.JÈ1Ñ.MÑ+Ð^Ø ×ÑH h§o¡oÔ6Ø×*Ñ*¨8Ð5HÓI×IÑIð .øð Jús' B& B&»B"¼A B& B$ B&Â$B&Ú new_databaseÚhighest_weight_databasec óÚ K |j |j kD rL|j j t j k( r$| j
|
j |« d { y y y 7 wrP )rn re rh ri rj r@ rk )rJ r r s rK r} z%MultiDBClient._change_active_database¨ s` è ø ð × Ñ Ð"9×"@Ñ"@Ò @Ø ×$Ñ$×*Ñ*¬g¯n©nÒ<à×'Ñ'×;Ñ;¸LÓI× IÑ Ið =ð Að Jús A A+Á!A)Á"A+c ó* K | j j |« }| j j d« d \ }}||k rL|j j t
|
j k( r$| j j |« d{ yyy7 w)z<
|
Removes a database from the database list.
|
rs r N) r* Úremoverv re rh ri rj r@ rk )rJ rm rn rz r~ s rK Úremove_databasez MultiDBClient.remove_database± s è ø ð ×'Ñ'¨Ó1Ø.2¯o©o×.GÑ.GÈÓ.JÈ1Ñ.MÑ+Ð^ð fÒ $Ø#×+Ñ+×1Ñ1´W·^±^ÒCà×'Ñ'×;Ñ;Ð<OÓP× PÑ Pð Dð %ð Qús BBÂ BÂ
|
Brn c ó$ K d}| j D ] \ }}||k( s d} n |s t d« | j j d« d \ }}| j j ||« ||_ | j ||« d{ y7 w)z<
|
Updates a database from the database list.
|
NTrr rs r )r* rt rv Ú update_weightrn r} )rJ rm rn rw rx ry rz r~ s rK Úupdate_database_weightz$MultiDBClient.update_database_weight¾ s è ø ð à "ooò NKØhÓ&Ø Ùð ñ
|
Ü Ð NÓOÐ Oà.2¯o©o×.GÑ.GÈÓ.JÈ1Ñ.MÑ+Ð^Ø ×%Ñ% h°Ô7Ø Ø×*Ñ*¨8Ð5HÓI×IÒIús BA+BÂB BÚfailure_detectorc ó: | j j |« y)z>
|
Adds a new failure detector to the database.
|
N)r7 Úappend)rJ r s rK Úadd_failure_detectorz"MultiDBClient.add_failure_detectorÑ s ð × Ñ ×&Ñ&Ð'7Õ8rM Ú healthcheckc ó¾ K | j 4 d{ | j j |« ddd« d{ y7 07 # 1 d{ 7 sw Y yxY ww)z:
|
Adds a new health check to the database.
|
N)rD r, r )rJ r s rK Úadd_health_checkz MultiDBClient.add_health_check× sR è ø ð ==÷ 4ñ 4Ø × Ñ × &Ñ & {Ô 3÷ 4÷ 4ñ 4øð 4ø÷ 4÷ 4ñ 4üsA A AA A³ A ¾A¿A ÁA ÁAÁA ÁAÁA c ó¢ K | j s| j « d{ | j j |i |¤ d{ S 7 (7 w)zB
|
Executes a single command and return its result.
|
N)rA rQ r@ Úexecute_command©rJ ÚargsÚoptionss rK r z MultiDBClient.execute_commandÞ sK è ø ð × Ò Ø//Ó#× #Ð #à:T×*Ñ*×:Ñ:¸DÐLÀGÑL×LÐLð $øàLús! A¢A £#AÁA ÁAÁ Ac ó t | « S )z:
|
Enters into pipeline mode of the client.
|
)ÚPipelinerR s rK ÚpipelinezMultiDBClient.pipelineç s ô ~Ð rM F©Ú
|
shard_hintÚvalue_from_callableÚ watch_delayÚfuncr Úwatchesr r r c ó® K | j s| j « d{ | j j |g|¢|||d d{ S 7 .7 w)z3
|
Executes callable as transaction.
|
Nr )rA rQ r@ Úexecute_transaction)rJ r r r r r s rK Ú transactionzMultiDBClient.transactioní sg è ø ð × Ò Ø//Ó#× #Ð #à>T×*Ñ*×>Ñ>Ø ð
|
à ñ
|
ð "Ø 3Ø#ò
|
÷
|
ð
|
ð $øð
|
ús! A¢A£)AÁ AÁ AÁAc ón K | j s| j « d{ t | fi |¤S 7 w)z¨
|
Return a Publish/Subscribe object. With this object, you can
|
subscribe to channels and listen for messages that get published to
|
them.
|
N)rA rQ ÚPubSub)rJ Úkwargss rK ÚpubsubzMultiDBClient.pubsub s6 è ø ð × Ò Ø//Ó#× #Ð #ädÑ%fÑ%Ð%ð $ús 5¢3£5ra c ó K | j D cg c]) \ }}t j | j |« « + c}}| _ t j
|
t j | j ddi| j ¬« d{ }|D ]t }t |t « s|j }t j |j _ t j# d|j$ ¬« |sc ||j$ « v yc c}}w 7 # t j $ r t j d« w xY ww)zk
|
Runs health checks as a recurring task.
|
Runs health checks against all databases.
|
Úreturn_exceptionsT)ÚtimeoutNz4Health check execution exceeds health_check_intervalz%Health check failed, due to exception)Úexc_info)r* rB rc ru rH Úwait_forÚgatherr0 Ú TimeoutErrorÚ
|
isinstancer rm ri ÚOPENre rh ÚloggerÚ exceptionÚoriginal_exception)rJ ra rm ry ÚresultsÚresultÚ unhealthy_dbs rK rb z%MultiDBClient._check_databases_health s! è ø ð ð $(§?¡?÷ á Haô ×#Ñ# D×$9Ñ$9¸(Ó$CÕDó DNô $× ,Ñ ,ÜØ^^ðà&*ñð ×3Ñ3ô ÷ Gð ò 8FÜ&Ô"<Õ=Ø % Ü-4¯\©\ ×$Ñ$Ô*ä× Ñ Ø;Ø #× 6Ñ 6ð !ô ò
|
Ù V× 6Ñ 6Õ7ñ 8ùó! ðùô ×#Ñ#ò Ü×&Ñ&ØFóð ð üsG D>D .D
|
ÁA
|
D Â DÂ D ÂD>Â&AD>Ã5D>Ä
|
D Ä)D;Ä;D>c ó K | j j | j |« d{ }|sH|j j t
|
j k7 r t
|
j |j _ |S |rF|j j t
|
j k7 r t
|
j |j _ |S 7 w)zO
|
Runs health checks on the given database until first failure.
|
N)r5 Úexecuter, re rh ri r rj )rJ rm Ú
|
is_healthys rK ru z MultiDBClient._check_db_health4 s è ø ð
|
×4Ñ4×<Ñ<Ø × Ñ ó
|
÷
|
|
ñ Ø× Ñ ×%Ñ%¬¯ © Ò5Ü)0¯ © × Ñ Ô&Ø Ð Ù H× ,Ñ ,× 2Ñ 2´g·n±nÒ DÜ%,§^¡^H× Ñ Ô "àÐð
|
ús *C¬CBCre Ú old_stateÚ new_statec ó@ t j « }|t j k( r4t j | j |j « « | _ y |t j k( r0|t j k( r |j t t |« y y y rP ) rB Úget_running_loopri Ú HALF_OPENrc ru rm rI rj r Ú
|
call_laterr Ú_half_open_circuit)rJ re r· r¸ Úloops rK rg z/MultiDBClient._on_circuit_state_change_callbackF s~ ô ×'Ñ'Ó)à ×)Ñ)Ò )Ü)0×)<Ñ)<Ø×%Ñ% g×&6Ñ&6Ó7ó*DÔ &ð à Ò &¨9¼¿ ¹ Ò+DØ OOÔ 0Ô2DÀgÕ Nð ,EÐ &rM c óª K | j j r7| j j j j « d { y y 7 wrP )r@ Úactive_databaseÚclientÚacloserR s rK r zMultiDBClient.acloseT sA è ø Ø × Ñ × 0Ò 0Ø×'Ñ'×7Ñ7×>Ñ>×EÑEÓG× GÑ Gð 1Ø Gús AAÁ
|
AÁ A)rJ r rN r rP )*Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r rL rS rZ rQ r rp r rk r r} r
Úfloatr r r r r r r r r r r r r ÚstrÚboolr r¤ Ú Exceptionr rb ru r ri rg r r] rM rK r r s ñð
|
**}ó **óXò
|
ò# ðJ yó ð
|
°-ð
|
ÀDó
|
ð2 J¨=ó Jð JØ )ðJØDQóJð Q¨mó QðJ°]ð JÈEó Jð&9Ð5Ió 9ð 4°+ó 4òMò ð %)Ø$)Ø'+ò
|
à
|
| U¨3° ¸#±Ð+>Ñ%?Ð?Ñ@ð
|
ð ð
|
ð SMð
|
ð
|
"ð
|
ð e_ó
|
ò, &ð PTñ$8à8 Y K°¸3ÀÀT¸>Ñ1JÐ$JÑKÑLó$8ðL¨}ð Àó ð$ OØ%ð OØ29ð OØFMó Oó HrM r re c ó. t j | _ y rP )ri r» rh )re s rK r½ r½ Y s Ü×%Ñ%G
MrM c ó~ e Zd ZdZdefdZddZd Zd Zd Z de
|
fd Z de fd
|
Z dd Zdd ZddZd Zdee fdZy )r zG
|
Pipeline implementation for multiple logical Redis databases.
|
rÁ c ó g | _ || _ y rP )Ú_command_stackÚ_client)rJ rÁ s rK rL zPipeline.__init__b s Ø ÔØ rM rN c ó K | S wrP r] rR s rK rS zPipeline.__aenter__f ó è ø Ø ùr` c ó K | j « d { | j j |||« d { y 7 *7 wrP )ÚresetrÏ rZ ©rJ rV rW rX s rK rZ zPipeline.__aexit__i s: è ø Øjjl×ÐØll×$Ñ$ X¨y¸)ÓD×DÑDð øØDús AA$A»A¼AÁAc ó> | j « j « S rP )Ú _async_selfÚ __await__rR s rK r× zPipeline.__await__m s Ø× Ñ Ó!×+Ñ+Ó-Ð-rM c ó K | S wrP r] rR s rK rÖ zPipeline._async_selfp rÑ r` c ó, t | j « S rP )ÚlenrÎ rR s rK Ú__len__zPipeline.__len__s s Ü4×&Ñ&Ó'Ð'rM c ó y)z1Pipeline instances should always evaluate to TrueTr] rR s rK Ú__bool__zPipeline.__bool__v s àrM Nc ó K g | _ y wrP )rÎ rR s rK rÓ zPipeline.resetz s è ø Ø Õùs c ó@ K | j « d{ y7 w)zClose the pipelineN)rÓ rR s rK r zPipeline.aclose} s è ø àjjl×Òúó c ó@ | j j ||f« | S )ar
|
Stage a command to be executed when execute() is next called
|
|
Returns the current Pipeline object back so commands can be
|
chained together, such as:
|
|
pipe = pipe.set('foo', 'bar').incr('baz').decr('bang')
|
|
At some other point, you can then run: pipe.execute(),
|
which will execute all commands queued in the pipe.
|
)rÎ r r s rK Úpipeline_execute_commandz!Pipeline.pipeline_execute_command s! ð ×Ñ×"Ñ" D¨' ?Ô3Ø rM c ó& | j |i |¤S )zAdds a command to the stack)râ ©rJ r r£ s rK r zPipeline.execute_command s à,t×,Ñ,¨dÐ=°fÑ=Ð=rM c ót K | j j s"| j j « d{ | j j j t | j « « d{ | j « d{ S 7 ]7 7 # | j « d{ 7 w xY ww)z0Execute all the commands in the current pipelineN)rÏ rA rQ r@ Úexecute_pipelineÚtuplerÎ rÓ rR s rK rµ zPipeline.execute s è ø à||×'Ò'Ø,,×)Ñ)Ó+× +Ð +ð Ø ×6Ñ6×GÑGÜd×)Ñ)Ó*ó÷ ð **,× Ñ ð ,øðøð ù$**,× Ò üsV 4B8¶B·B8¼;B Á7BÁ8B Á;B8ÂBÂB8ÂB ÂB8ÂB5Â.B1Â/B5Â5B8)rJ r rN r ©rN N)rN r )rà rÄ rÅ rÆ r rL rS rZ r× rÖ ÚintrÛ rÉ rÝ rÓ r râ r r r rµ r] rM rK r r ] sd ñð }ó óòEò.òð(ó (ð$ó ó!óó ò >ð
|
t Cyô
|
rM r c ó¸ e Zd ZdZdefdZddZddZd Ze de
|
fd « Z d
|
e fd Z d
|
ed efd Zd
|
efdZd
|
ed efdZd Z dde
|
dee fdZddddeddfdZy)r¢ z2
|
PubSub object for multi database client.
|
rÁ c ó^ || _ | j j j di |¤ y)zýInitialize the PubSub object for a multi-database client.
|
|
Args:
|
client: MultiDBClient instance to use for pub/sub operations
|
**kwargs: Additional keyword arguments to pass to the underlying pubsub implementation
|
Nr] )rÏ r@ r¤ )rJ rÁ r£ s rK rL zPubSub.__init__¦ s( ð Ø, ×%Ñ%×,Ñ,Ñ6¨vÓ6rM rN c ó K | S wrP r] rR s rK rS zPubSub.__aenter__± rÑ r` Nc ó@ K | j « d { y 7 wrP )r rÔ s rK rZ zPubSub.__aexit__´ s è ø Økkm×Òúrà c óh K | j j j d« d { S 7 w)Nr ©rÏ r@ Úexecute_pubsub_methodrR s rK r z PubSub.aclose· s' è ø Ø\\×2Ñ2×HÑHÈÓR×RÐRÐRús )2«0¬2c óV | j j j j S rP )rÏ r@ Ú active_pubsubÚ
|
subscribedrR s rK ró zPubSub.subscribedº s à||×,Ñ,×:Ñ:×EÑEÐErM r c ól K | j j j dg|¢ d { S 7 w)Nr rï ©rJ r s rK r zPubSub.execute_command¾ s: è ø ØHT\\×2Ñ2×HÑHØ ð
|
Ø $ò
|
÷
|
ð
|
ð
|
úó +42®4r£ c ór K | j j j dg|¢i |¤ d{ S 7 w)aE
|
Subscribe to channel patterns. Patterns supplied as keyword arguments
|
expect a pattern name as the key and a callable as the value. A
|
pattern's callable will be invoked automatically when a message is
|
received on that pattern rather than producing a message via
|
``listen()``.
|
Ú
|
psubscribeNrï rä s rK rø zPubSub.psubscribeà sE è ø ð IT\\×2Ñ2×HÑHØ ð
|
Ø ò
|
Ø#)ñ
|
÷
|
ð
|
ð
|
úó .7°5±7c ól K | j j j dg|¢ d{ S 7 w)zj
|
Unsubscribe from the supplied patterns. If empty, unsubscribe from
|
all patterns.
|
Ú punsubscribeNrï rõ s rK rû zPubSub.punsubscribeÏ s= è ø ð
|
IT\\×2Ñ2×HÑHØ ð
|
Ø !ò
|
÷
|
ð
|
ð
|
úrö c ór K | j j j dg|¢i |¤ d{ S 7 w)aR
|
Subscribe to channels. Channels supplied as keyword arguments expect
|
a channel name as the key and a callable as the value. A channel's
|
callable will be invoked automatically when a message is received on
|
that channel rather than producing a message via ``listen()`` or
|
``get_message()``.
|
Ú subscribeNrï rä s rK rý zPubSub.subscribeØ sE è ø ð IT\\×2Ñ2×HÑHØ ð
|
Ø ò
|
Ø"(ñ
|
÷
|
ð
|
ð
|
úrù c ól K | j j j dg|¢ d{ S 7 w)zi
|
Unsubscribe from the supplied channels. If empty, unsubscribe from
|
all channels
|
Ú unsubscribeNrï rõ s rK rÿ zPubSub.unsubscribeä s= è ø ð
|
IT\\×2Ñ2×HÑHØ ð
|
Ø ò
|
÷
|
ð
|
ð
|
úrö Úignore_subscribe_messagesr§ c ón K | j j j d||¬« d{ S 7 w)a
|
Get the next message if one is available, otherwise None.
|
|
If timeout is specified, the system will wait for `timeout` seconds
|
before returning. Timeout should be specified as a floating point
|
number or None to wait indefinitely.
|
Ú get_message)r r§ Nrï )rJ r r§ s rK r zPubSub.get_messageí s> è ø ð \\×2Ñ2×HÑHØ Ø&?Øð Ió
|
÷
|
ð
|
ð
|
úó ,5®3¯5g ð?)Úexception_handlerÚ poll_timeoutr c ón K | j j j ||| ¬« d{ S 7 w)a Process pub/sub messages using registered callbacks.
|
|
This is the equivalent of :py:meth:`redis.PubSub.run_in_thread` in
|
redis-py, but it is a coroutine. To launch it as a separate task, use
|
``asyncio.create_task``:
|
|
>>> task = asyncio.create_task(pubsub.run())
|
|
To shut it down, use asyncio cancellation:
|
|
>>> task.cancel()
|
>>> await task
|
)Ú
|
sleep_timer r¤ N)rÏ r@ Úexecute_pubsub_run)rJ r r s rK Úrunz
|
PubSub.runý s> è ø ð& \\×2Ñ2×EÑEØ#Ð7HÐQUð Fó
|
÷
|
ð
|
ð
|
úr )rN r¢ rè )Fg )rà rÄ rÅ rÆ r rL rS rZ r ÚpropertyrÉ ró r r r r
|
rø rû r rý rÿ r rÇ r r r] rM rK r¢ r¢ ¡ sÅ ñð 7}ó 7óó òSð ðFDò Fó ðFð
|
¨:ó
|
ð
|
|
|
hð
|
|
¸-ó
|
|
ð
|
¨ó
|
ð
|
|
Xð
|
|
¸ó
|
|
ò
|
ð SVñ
|
Ø)-ð
|
Ø@HÈÁó
|
ð& Ø !ò
|
ð ð
|
ð
|
|
ô
|
rM r¢ )2rB ÚloggingÚtypingr r r r r r r Úredis.asyncio.clientr
|
Ú&redis.asyncio.multidb.command_executorr Ú redis.asyncio.multidb.configr r Ú redis.asyncio.multidb.databaser r Ú&redis.asyncio.multidb.failure_detectorr Ú!redis.asyncio.multidb.healthcheckr r Úredis.backgroundr Úredis.commandsr r Úredis.multidb.circuitr r ri Úredis.multidb.exceptionr r Ú redis.typingr r r Ú redis.utilsr Ú getLoggerrà r® r r½ r r¢ r] rM rK ú<module>r s¡ ðÛ Û ß M× MÑ Må .Ý Iß Lß CÝ Gß LÝ 0ß FÝ 0Ý 2ß Xß 3Ñ 3Ý $à × Ñ 8Ó $ð ôHÐ,Ð.?ó Hó ðHðD
|
& ó &ôA Ð'Ð):ô A ÷Hq
|
ò q
|
rM
|
