Ë
|
|
çúh,+ ã ó d dl mZmZmZmZmZmZ d dlmZm Z d dl
|
m Z erd dl m Z G d d« Z G d de« Z G d d
|
e« Zy ) é )Ú TYPE_CHECKINGÚAnyÚDictÚOptionalÚTupleÚUnion)Ú
|
RedisErrorÚ ResponseError)Ú str_if_bytes)Ú ClusterNodec ó e Zd Zd Zd Zy)ÚAbstractCommandsParserc ó
|
t |« dk ry|D cg c] }t |« }}|d j « }d}|dk( r |d j « }|dv r|dd }|S |dv rt |dd « }|S |dv r|d g}|S c c}w ) zé
|
Get the keys from pubsub command.
|
Although PubSub commands have predetermined key locations, they are not
|
supported in the 'COMMAND's output, so the key positions are hardcoded
|
in this method
|
é Nr ÚPUBSUBé )ÚCHANNELSÚNUMSUBÚ SHARDCHANNELSÚ SHARDNUMSUB)Ú SUBSCRIBEÚ
|
PSUBSCRIBEÚ UNSUBSCRIBEÚ PUNSUBSCRIBE)ÚPUBLISHÚSPUBLISH)Úlenr ÚupperÚlist)ÚselfÚargsÚargÚcommandÚkeysÚ pubsub_types õj H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/_parsers/commands.pyÚ_get_pubsub_keysz'AbstractCommandsParser._get_pubsub_keys s· ô t9q=àØ-1Ö2 c SÕ!Ð2Ð2Øq'--/ØØ hÒ ð q'--/KØÐ TÑTØABxð ð ÐRÑ Rô QR>Dð
|
ð Ð/Ñ /ð G9DØ ùò# 3s B c ó i }t |d « }||d< t |d « |d< |d D cg c] }t |« c}|d< |d |d< |d |d
|
< |d |d < t |« d kD r|d |d< |d |d< |d |d< |S c c}w )Nr Únamer Úarityr Úflagsé Ú first_key_posé Ú last_key_posé Ú
|
step_counté Útipsé Úkey_specificationsé Ú subcommands)r Úintr )r r# ÚoptionsÚcmd_dictÚcmd_nameÚflags r& Úparse_subcommandz'AbstractCommandsParser.parse_subcommand( s» ØÜ ¨¡
|
Ó+Ø#ÑÜ ¨¡
|
OÑØ<CÀA¹JÖ G°D\¨$Õ /Ò GÑØ$+¨A¡J Ñ!Ø#*¨1¡: Ñ Ø!(¨¡ Ñ Ü w<!Ò Ø & qzHVÑ Ø-4°Q©ZHÐ)Ñ *Ø&-¨a¡jH]Ñ #Øùò Hs ®BN)Ú__name__Ú
|
__module__Ú __qualname__r' r= © ó r& r r
|
s òó: rB r c ó( e Zd ZdZd Zd Zd Zd Zy)ÚCommandsParsera
|
Parses Redis commands to get command keys.
|
COMMAND output is used to determine key locations.
|
Commands that do not have a predefined key location are flagged with
|
'movablekeys', and these commands' keys are determined by the command
|
'COMMAND GETKEYS'.
|
c ó4 i | _ | j |« y ©N)ÚcommandsÚ
|
initialize)r Úredis_connections r& Ú__init__zCommandsParser.__init__A s Ø Ø Ð(Õ)rB c óÞ |j « }g }|D ]& }t d |D « « s|j |« ( |D ]$ }|j |« ||j « < & || _ y )Nc 3 ó< K | ] }|j « y wrF )Úisupper)Ú.0Úxs r& ú <genexpr>z,CommandsParser.initialize.<locals>.<genexpr>I s è ø Ò, 1199;Ñ,ùs )r# ÚanyÚappendÚpopÚlowerrG )r ÚrrG Úuppercase_commandsÚcmds r& rH zCommandsParser.initializeE so Ø99;Ø ÐØò /CÜÑ,¨Ô,Õ,Ø"×)Ñ)¨#Õ.ð /ð &ò 6CØ$,§L¡L°Ó$5HSYY[Ò !ð 6à rB c ór t |« dk ry|d j « }|| j vrp|j « }|d }|| j v r|t |dd « z }n;| j |« || j vr t |j « d« | j j |« }d|d v r | j |g|¢ }|S d|d v s|d dk( r | j | }|S |d
|
dk( r`|d dk( rX|d dk( rPd }d|v rG| d|d j « }|d D ]' } t | d « |k( s| j | « }d}) |sy|d }
|
|
|
dk rt |« t |
|
« z
|
}
|
t t |d |
|
dz |d
|
« « } | D cg c] } || }} |S c c} w ©ap
|
Get the keys from the passed command.
|
|
NOTE: Due to a bug in redis<7.0, this function does not work properly
|
for EVAL or EVALSHA when the `numkeys` arg is 0.
|
- issue: https://github.com/redis/redis/issues/9493
|
- fix: https://github.com/redis/redis/pull/9733
|
|
So, don't use this function with EVAL or EVALSHA.
|
r Nr r z( command doesn't exist in Redis commandsÚ movablekeysr+ Úpubsubr) r1 r- r/ Fr7 ú|T©r rT rG Úsplitr rH r r ÚgetÚ_get_moveable_keysr' r r= ÚabsÚrange) r Ú
|
redis_connr! r; Úcmd_name_splitr# r$ Ú is_subcmdÚ subcmd_nameÚsubcmdr/ Úkeys_posÚposs r& Úget_keyszCommandsParser.get_keysR s ô t9q=àà7==?Ø 4==Ñ (ð &^^Ó -NØ% aÑ(HØ4==Ñ(à%¬¨T°!°"¨X«Ñ6ð
|
Ô+Ø 4§=¡=Ñ0Ü$Ø#>>Ó+Ð,Ð,TÐUóð ð --×#Ñ# HÓ-Ø G GÑ ,Ñ ,Ø*4×*Ñ*¨:Ð=¸Ò=Dð8 ð7 Ñ)Ñ )¨W°V©_ÀÒ-HØ(4×(Ñ(¨$Ð/Dð4 ð/ Ñ%¨Ò*ØOÑ,°Ò1ØNÑ+¨qÒ0à ! Ø GÑ+Ø%- J¨a°°Q±· ± ³Ð/@Ð"AKØ")¨-Ñ"8ò -Ü'¨¨q© Ó2°kÓAØ&*×&;Ñ&;¸FÓ&CGØ(,Ið-ñ !Ø Ø" >Ñ2LØaÒ Ü " 4y¬3¨|Ó+<Ñ < ÜÜgoÑ.° ¸qÑ0@À'È,ÑBWÓXóHð *2Ö2 #DIÐ2DÐ2à ùò 3s Æ$ F4c óÒ |d j « t |dd « z } |j dg|¢ }|S # t $ r$}|j « }d|v sd|v rY d}~y|d}~ww xY w)aA
|
NOTE: Due to a bug in redis<7.0, this function does not work properly
|
for EVAL or EVALSHA when the `numkeys` arg is 0.
|
- issue: https://github.com/redis/redis/issues/9493
|
- fix: https://github.com/redis/redis/pull/9733
|
|
So, don't use this function with EVAL or EVALSHA.
|
r r NúCOMMAND GETKEYSúInvalid argumentsú The command has no key arguments)r^ r Úexecute_commandr
|
Ú__str__)r rc r! Úpiecesr$ ÚeÚmessages r& r` z!CommandsParser._get_moveable_keys s{ ð a ¤4¨¨Q¨R¨£>Ñ1ð
|
Ø-:×-Ñ-Ð.?ÐIÀ&ÒIDð øô ò ØiikGà# wÑ.Ø5¸Ñ@äàûð ús ¤9 ¹ A&ÁA!Á A!Á!A&N)r> r? r@ Ú__doc__rJ rH rj r` rA rB r& rD rD 8 s ñò*ò!ò?óBrB rD c ót e Zd ZdZdZd dZdded ddfdZd edee e
|
d
|
f fd Z d edee e
|
d
|
f fd Z y)ÚAsyncCommandsParsera%
|
Parses Redis commands to get command keys.
|
|
COMMAND output is used to determine key locations.
|
Commands that do not have a predefined key location are flagged with 'movablekeys',
|
and these commands' keys are determined by the command 'COMMAND GETKEYS'.
|
|
NOTE: Due to a bug in redis<7.0, this does not work properly
|
for EVAL or EVALSHA when the `numkeys` arg is 0.
|
- issue: https://github.com/redis/redis/issues/9493
|
- fix: https://github.com/redis/redis/pull/9733
|
|
So, don't use this with EVAL or EVALSHA.
|
)rG ÚnodeÚreturnNc ó i | _ y rF )rG )r s r& rJ z AsyncCommandsParser.__init__¿ s Ø?A rB rw r c óâ K |r|| _ | j j d« d { }|j « D ci c] \ }}|j « | c}}| _ y 7 <c c}}w w)NÚCOMMAND)rw ro ÚitemsrT rG )r rw rG rW r# s r& rH z AsyncCommandsParser.initialize sW è ø Ù Ø DIà ×2Ñ2°9Ó=×=ØBJÇ.Á.ÓBR×S±,°#°w gÑ-ÓS ð >úÛSùs! (A/ªA'«A/ÁA)Á A/Á)A/r! .c ó K t |« dk ry|d j « }|| j vrw|j « }|d }|| j v r|t |dd « z }nB| j « d{ || j vr t |j « d« | j j |« }d|d v r | j | d{ }|S d|d v s|d dk( r | j | }|S |d
|
dk( r`|d dk( rX|d dk( rPd }d|v rG| d|d j « }|d D ]' }t |d « |k( s| j |« }d}) |sy|d } | dk rt |« t | « z
|
} t t |d | dz |d
|
« « }
|
|
|
D cg c] } || }} |S 7 F7 åc c} w wrY r] ) r r! r; rd r# r$ re rf rg r/ rh ri s r& rj z AsyncCommandsParser.get_keysÌ s% è ø ô t9q=àà7==?Ø 4==Ñ (ð &^^Ó -NØ% aÑ(HØ4==Ñ(à%¬¨T°!°"¨X«Ñ6ð ooÓ'×'Ð'Ø 4§=¡=Ñ0Ü$Ø#>>Ó+Ð,Ð,TÐUóð ð --×#Ñ# HÓ-Ø G GÑ ,Ñ ,Ø0×0Ñ0°$Ð7×7Dð8 ð7 Ñ)Ñ )¨W°V©_ÀÒ-HØ(4×(Ñ(¨$Ð/Dð4 ð/ Ñ%¨Ò*ØOÑ,°Ò1ØNÑ+¨qÒ0à ! Ø GÑ+Ø%- J¨a°°Q±· ± ³Ð/@Ð"AKØ")¨-Ñ"8ò -Ü'¨¨q© Ó2°kÓAØ&*×&;Ñ&;¸FÓ&CGØ(,Ið-ñ !Ø Ø" >Ñ2LØaÒ Ü " 4y¬3¨|Ó+<Ñ < ÜÜgoÑ.° ¸qÑ0@À'È,ÑBWÓXóHð *2Ö2 #DIÐ2DÐ2à ðI (ùð 8úò4 3ùs? A9G Á;GÁ<A"G à Gà A5G ÅA G Æ1 GÆ=G ÇG ÇG c ó¾ K | j j dg|¢ d { }|S 7 # t $ r$}|j « }d|v sd|v rY d }~y |d }~ww xY ww)Nrl rm rn )rw ro r
|
rp )r r! r$ rr rs s r& r` z&AsyncCommandsParser._get_moveable_keys si è ø ð
|
Ø2×2Ñ2Ð3DÐLÀtÒL×LDð ð MùÜ ò ØiikGà# wÑ.Ø5¸Ñ@äàûð üs< A - ¤+¥- ©A «- A¶AÁA ÁAÁAÁA )rx NrF ) r> r? r@ rt Ú __slots__rJ r rH r r Ústrrj r` rA rB r& rv rv sp ñ ð %IóBñT X¨mÑ%<ð TÈó Tð? Cð ?¨H°U¸3À¸8±_Ñ,Eó ?ðB ¨cð °h¸uÀSÈ#ÀX¹Ñ6Oô rB rv N)Útypingr r r r r r Úredis.exceptionsr r
|
Ú redis.utilsr Úredis.asyncio.clusterr r rD rv rA rB r& ú<module>r
sA ðß C× Cç 6Ý $áÝ1÷+ñ +ô\rÐ+ô rôjlÐ0õ lrB
|
