Ë
|
|
çúhÌ? ã ó& U d dl Z d dlZd dlmZ d dlmZmZmZ d dlm Z m
|
Z
|
m Z m Z m Z mZ d dlmZmZmZmZmZmZ ej, j. dk\ r ej, j0 dk\ rd dlmZ nd dlmZ d d
|
lm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. d d lm/Z/ d d l0m1Z1 d dl2m3Z3m4Z4 dZ5dZ6dZ7dZ8e e dZ9de$iZ: e jv e<« Z= G d de« Z> G d de>« Z? G d de>« Z@ G d d « ZAd ZBd ZCd ZDd ZEd!ZFd"ZGeDeEeFeGfZHeDeeAj feEeeAj feFeeAj feGeeAj feCeeAj fiZLeMeNeOePe e
|
f f eQd#< G d$ d%e « ZR G d& d'e « ZS G d( d)e@« ZTy)*é N)ÚABC)ÚIncompleteReadErrorÚ StreamReaderÚ TimeoutError)Ú AwaitableÚCallableÚListÚOptionalÚProtocolÚUnion)ÚMaintenanceNotificationÚNodeFailedOverNotificationÚNodeFailingOverNotificationÚNodeMigratedNotificationÚNodeMigratingNotificationÚNodeMovingNotificationé é )Útimeouté )ÚAskErrorÚAuthenticationErrorÚ$AuthenticationWrongNumberOfArgsErrorÚBusyLoadingErrorÚClusterCrossSlotErrorÚClusterDownErrorÚConnectionErrorÚExecAbortErrorÚExternalAuthProviderErrorÚMasterDownErrorÚ ModuleErrorÚ
|
MovedErrorÚNoPermissionErrorÚ NoScriptErrorÚOutOfMemoryErrorÚ ReadOnlyErrorÚ
|
RedisErrorÚ ResponseErrorÚ TryAgainError)Ú
|
EncodableTé )ÚEncoder)Ú SERVER_CLOSED_CONNECTION_ERRORÚ SocketBufferz:Error loading the extension. Please check the server logs.z5Error unloading module: no such module with that namez/Error unloading module: operation not possible.z[Error unloading module: the module exports one or more module-side data types, can't unload)zxAUTH <password> called without any password configured for the default user. Are you sure your configuration is correct?z(Client sent AUTH, but no password is setzproblem with LDAP servicec ót e Zd Zdedededeeeeee ee
|
eie ¥e ¥e eeeeeeeeeeeeedZed « Zd Z d Z y )
|
Ú
|
BaseParserz max number of clients reachedzinvalid passwordz,wrong number of arguments for 'auth' commandz,wrong number of arguments for 'AUTH' command)ÚERRÚOOMÚ WRONGPASSÚ EXECABORTÚLOADINGÚNOSCRIPTÚREADONLYÚNOAUTHÚNOPERMÚASKÚTRYAGAINÚMOVEDÚ CLUSTERDOWNÚ CROSSSLOTÚ
|
MASTERDOWNc óø |j d« d }|| j v rN|t |« dz d }| j | }t |t « r|j |t « } ||« S t |« S )zParse an error responseú r r+ N)ÚsplitÚEXCEPTION_CLASSESÚlenÚ
|
isinstanceÚdictÚgetr( )ÚclsÚresponseÚ
|
error_codeÚexception_classs õf H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/_parsers/base.pyÚ parse_errorzBaseParser.parse_errork s} ð ^^ CÓ(¨Ñ+
|
Ø ×.Ñ.Ñ .Ø ¤ J£°!Ñ 3Ð 5Ð6HØ !× 3Ñ 3°JÑ ?OÜ/¬4Ô0Ø"1×"5Ñ"5°hÄ Ó"NÙ" 8Ó,Ð ,Ü XÓ&Ð&ó c ó t « ©N©ÚNotImplementedError©Úselfs rL Ú on_disconnectzBaseParser.on_disconnectw ó Ü!Ó#Ð#rN c ó t « rP rQ ©rT Ú
|
connections rL Ú
|
on_connectzBaseParser.on_connectz rV rN N) Ú__name__Ú
|
__module__Ú __qualname__r r r ÚMODULE_LOAD_ERRORr! Ú MODULE_EXPORTS_DATA_TYPES_ERRORÚNO_SUCH_MODULE_ERRORÚ MODULE_UNLOAD_NOT_POSSIBLE_ERRORÚNO_AUTH_SET_ERRORÚ EXTERNAL_AUTH_PROVIDER_ERRORr% r r r$ r& r# r r) r" r r r rC Ú classmethodrM rU rZ © rN rL r0 r0 G s ð ,¨_Ø Ð 3ð !Ø"Fð !Ø"FØ {Ø +¨[Ø +Ø ,¨kð
|
ð ð
|
ð +ð!
|
ð$ Ø(Ø#Ø#Ø!Ø!Ø%Ø#ØØ!ØØ'Ø*Ø%ñA!ÐðF ñ 'ó ð 'ò$ó$rN r0 c ó. e Zd ZdZd Zd Zd Zd Zd Zy)Ú _RESPBasez&Base class for sync-based resp parsingc ó< || _ d | _ d | _ d | _ y rP )Úsocket_read_sizeÚencoderÚ_sockÚ_buffer©rT ri s rL Ú__init__z_RESPBase.__init__ s Ø 0Ô Ø Ø
|
Ø rN c óD | j « y # t $ r Y y w xY wrP )rU Ú ExceptionrS s rL Ú__del__z_RESPBase.__del__ s% ð Ø × Ñ Õ øÜò Ù ð ús c ó¨ |j | _ t | j | j |j « | _ |j
|
| _ y)z Called when the socket connectsN)rk r. ri Úsocket_timeoutrl rj rX s rL rZ z_RESPBase.on_connect sA à ×%Ñ%
|
Ü#Ø JJ×-Ñ-¨z×/HÑ/Hó
|
ð "×)Ñ) rN c óz d| _ | j !| j j « d| _ d| _ y)z"Called when the socket disconnectsN)rk rl Úcloserj rS s rL rU z_RESPBase.on_disconnect s1 à
|
Ø <<Ð #Ø LL× Ñ Ô Ø DLØ rN c óT | j xr | j j |« S rP )rl Úcan_read)rT r s rL rw z_RESPBase.can_read s Ø||Ò> § ¡ × 5Ñ 5°gÓ >Ð>rN N) r[ r\ r] Ú__doc__rn rq rZ rU rw re rN rL rg rg ~ s Ù0ò ò ò *ò ó?rN rg c
|
óT e Zd ZdZdZdefdZdefdZ d
|
dede e
|
e de e
|
f fd Z y) ÚAsyncBaseParserz5Base parsing class for the python-backed async parser©Ú_streamÚ
|
_read_sizeri c ó d | _ || _ y rP r{ rm s rL rn zAsyncBaseParser.__init__¦ s Ø/3 Ø*rN Úreturnc ó K t « wrP rQ rS s rL Úcan_read_destructivez$AsyncBaseParser.can_read_destructiveª s è ø Ü!Ó#Ð#ùó Údisable_decodingNc ó K t « wrP rQ )rT r s rL Ú read_responsez AsyncBaseParser.read_response s è ø ô "Ó#Ð#ùr )F)r[ r\ r] rx Ú __slots__Úintrn Úboolr r r* r( r r
re rN rL rz rz ¡ sO Ù?à'Ið+¨ó +ð$¨Dó $ð (-ñ$Ø $ð$à z=¨$°°ZÑ0@Ð@Ñ Aô$rN rz c ó@ e Zd ZdZed « Zed « Zed « Zy)Ú MaintenanceNotificationsParserzEProtocol defining maintenance push notification parsing functionalityc ó( | d }| d } |||« S )Nr+ r re )rI Únotification_typeÚidÚttls rL Úparse_maintenance_start_msgz:MaintenanceNotificationsParser.parse_maintenance_start_msg¶ s# ð a[ØqkÙ SÓ)Ð)rN c ó | d } ||« S )Nr+ re )rI r r s rL Ú parse_maintenance_completed_msgz>MaintenanceNotificationsParser.parse_maintenance_completed_msg½ s ð a[Ù Ó$Ð$rN c óØ | d }| d }| d d\ }}nH| d }t |t « r|j « }|j d« \ }}| t |« nd }t ||||« S )Nr+ r r )NNú:)rE ÚbytesÚdecoderB r r )rI r r ÚhostÚportÚvalues rL Úparse_moving_msgz/MaintenanceNotificationsParser.parse_moving_msgà sz ð a[ØqkØ A;Ð Ø#JD$à QKEÜ%¤Ô'Ø Ø SÓ)JD$Ø $Ð 03t9°dDä% b¨$°°cÓ:Ð:rN N)r[ r\ r] rx Ú staticmethodr r r re rN rL r r ³ s? ÙOàñ*ó ð*ð ñ%ó ð%ð
|
ñ ;ó ñ ;rN r Ú
|
invalidateÚMOVINGÚ MIGRATINGÚMIGRATEDÚ FAILING_OVERÚ FAILED_OVERÚ-MSG_TYPE_TO_MAINT_NOTIFICATION_PARSER_MAPPINGc ó| e Zd ZU dZeed< dZee ed< dZee ed< dZ ee ed< d Z
|
d Z d Z d
|
Z d Zd Zy) ÚPushNotificationsParserz6Protocol defining RESP3-specific parsing functionalityÚpubsub_push_handler_funcNÚ invalidation_push_handler_funcÚ node_moving_push_handler_funcÚ maintenance_push_handler_funcc ó t « )z Handle pubsub push responsesrQ ©rT rI s rL Úhandle_pubsub_push_responsez3PushNotificationsParser.handle_pubsub_push_response s ä!Ó#Ð#rN c óf |d }t |t « r|j « }|t gt ¢t
|
vr| j |« S |t k( r | j r| j |« S |t
|
k( r1| j r%t | d } ||« }| j |« S |t v r@| j r4t | d }t | d } |||« }|| j |« S y # t $ r0}t j dj |||« « Y d }~y d }~ww xY w)Nr r+ ú"Error handling {} message ({}): {}©rE r r Ú_INVALIDATION_MESSAGEÚ_MAINTENANCE_MESSAGESÚ_MOVING_MESSAGEr¤ r¥ r¦ r¡ r§ rp ÚloggerÚerrorÚformat©rT rI ÚkwargsÚmsg_typeÚparser_functionÚ notificationr Úes rL Úhandle_push_responsez,PushNotificationsParser.handle_push_response se ØA;Ü h¤Ô &Ø Ó(Hà Ü !ð
|
ä "ð
|
ô ñ
|
ñ
|
ð
|
×0Ñ0°Ó:Ð :ð àÔ 1Ò1Ø×7Ò7à×:Ñ:¸8ÓDÐDà?Ò*¨t×/QÒ/QÜ"OØ ñ#àñ#ñ /¨xÓ 8 Ø×9Ñ9¸,ÓGÐGàÔ0Ñ0°T×5WÒ5WÜ"OØ ñ#àñ#ô %RØ ñ%àñ%Ð!ñ /¨xÐ9JÓ K à Ð+Ø ×=Ñ=¸lÓKÐKð øô ò Ü LLØ4×;Ñ;¸HÀhÐPQÓR÷ ð ð ûð ús% Á%C7 Á49C7 Â.AC7 Ã7 D0Ä &D+Ä+D0c ó || _ y rP ©r¤ ©rT r¤ s rL Úset_pubsub_push_handlerz/PushNotificationsParser.set_pubsub_push_handler5 s
|
Ø(@Õ%rN c ó || _ y rP ©r¥ ©rT r¥ s rL Ú set_invalidation_push_handlerz5PushNotificationsParser.set_invalidation_push_handler8 s
|
Ø.LÕ+rN c ó || _ y rP ©r¦ ©rT r¦ s rL Ú set_node_moving_push_handlerz4PushNotificationsParser.set_node_moving_push_handler; ó
|
Ø-JÕ*rN c ó || _ y rP ©r§ ©rT r§ s rL Ú set_maintenance_push_handlerz4PushNotificationsParser.set_maintenance_push_handler> rÇ rN )r[ r\ r] rx r Ú__annotations__r¥ r
|
r¦ r§ rª rº r¾ r rÆ rË re rN rL r£ r£ ü s^
Ù@à &Ó&Ø9=Ð" H¨XÑ$6Ó=Ø8<Ð! 8¨HÑ#5Ó<Ø8<Ð! 8¨HÑ#5Ó<ò$ò+òZAòMòKóKrN r£ c ó e Zd ZU dZeed< dZee ed< dZeede d f ed< dZ
|
eede d f ed< d Z d Z d
|
Z d Zd Zd Zy)Ú AsyncPushNotificationsParserz<Protocol defining async RESP3-specific parsing functionalityr¤ Nr¥ .r¦ r§ c ó K t « w)z+Handle pubsub push responses asynchronouslyrQ r© s rL rª z8AsyncPushNotificationsParser.handle_pubsub_push_responseJ s è ø ä!Ó#Ð#ùr c óþ K |d }t |t « r|j « }|t gt ¢t
|
vr| j |« d{ S |t k( r%| j r| j |« d{ S t |t « r|j « }|t
|
k( r9| j r-t | d } ||« }| j |« d{ S |t v rH| j r<t | d }t | d } |||« }|| j |« d{ S y7 æ7 ¹7 Y7 # t $ r0}t j dj |||« « Y d}~yd}~ww xY ww)z$Handle push responses asynchronouslyr Nr+ r¬ r r´ s rL rº z1AsyncPushNotificationsParser.handle_push_responseN s¦ è ø ð A;Ü h¤Ô &Ø Ó(Hà Ü !ð
|
ä "ð
|
ô ñ
|
ñ
|
ð
|
×6Ñ6°xÓ@×@Ð @ð àÔ 1Ò1Ø×7Ò7à !× @Ñ @ÀÓ J×JÐJä(¤EÔ*Ø#??Ó,à?Ò*¨t×/QÒ/QÜ"OØ ñ#àñ#ñ /¨xÓ 8 Ø !× ?Ñ ?À Ó M×MÐMàÔ0Ñ0°T×5WÒ5WÜ"OØ ñ#àñ#ô %RØ ñ%àñ%Ð!ñ /¨xÐ9JÓ K à Ð+Ø!%×!CÑ!CÀLÓ!Q×QÐQð ðG Aøð Køð Nøð RùÜò Ü LLØ4×;Ñ;¸HÀhÐPQÓR÷ ð ð ûð üs AE=ÁD9ÁE=Á)E ÂD;ÂE ÂE=ÂA E Ã#D=Ã$E Ã'E=Ã(A E Ä3D?Ä4E Ä7E=Ä;E Ä=E Ä?E Å E:Å
|
&E5Å0E=Å5E:Å:E=c ó || _ y)z$Set the pubsub push handler functionNr¼ r½ s rL r¾ z4AsyncPushNotificationsParser.set_pubsub_push_handler s
|
à(@Õ%rN c ó || _ y)z*Set the invalidation push handler functionNrÀ rÁ s rL r z:AsyncPushNotificationsParser.set_invalidation_push_handler s
|
à.LÕ+rN c ó || _ y rP rÄ rÅ s rL rÆ z9AsyncPushNotificationsParser.set_node_moving_push_handler rÇ rN c ó || _ y rP rÉ rÊ s rL rË z9AsyncPushNotificationsParser.set_maintenance_push_handler rÇ rN )r[ r\ r] rx r rÌ r¥ r
|
r¦ r r§ rª rº r¾ r rÆ rË re rN rL rÎ rÎ B sz
ÙFà &Ó&Ø9=Ð" H¨XÑ$6Ó=ØNRÐ! 8¨H°S¸)ÀD¹/Ð5IÑ,JÑ#KÓRØNRÐ! 8¨H°S¸)ÀD¹/Ð5IÑ,JÑ#KÓRò$ò/òbAòMòKóKrN rÎ c ó e Zd ZdZej
|
dz Zdef fd Zd Zd Z d Z
|
de fd Z d
|
ede fd Zde fd Z xZS ) Ú_AsyncRESPBasez!Base class for async resp parsing)rj rl Ú_posÚ_chunksri c ó\ t | |« d | _ d| _ g | _ d| _ y )NrN r )Úsuperrn rj rl rØ r× )rT ri Ú __class__s rL rn z_AsyncRESPBase.__init__ s- ø Ü ÑÐ)Ô*Ø*. Ø Ø Ø rN c óF d| _ | j j « y )NrN )rl rØ ÚclearrS s rL Ú_clearz_AsyncRESPBase._clear s Ø Ø ×ÑÕ rN c ó¤ |j | _ | j t d« |j | _ | j « d| _ y)z Called when the stream connectsNúBuffer is closed.T)Ú_readerr| r' rj rÞ Ú
|
_connectedrX s rL rZ z_AsyncRESPBase.on_connect sB à!×)Ñ) Ø <<Ð Ü Ð 0Ó1Ð 1Ø!×)Ñ) Ø Ø rN c ó d| _ y)z"Called when the stream disconnectsFN)râ rS s rL rU z _AsyncRESPBase.on_disconnect§ s à rN r c ó" K | j s t d« | j ry t d« 4 d { | j j « cd d d « d { S 7 /7 # 1 d { 7 sw Y y xY w# t $ r Y yw xY ww)Nrà Tr F)râ r' rl Ú async_timeoutr| Úat_eofr rS s rL r z#_AsyncRESPBase.can_read_destructive« s è ø ØÜ Ð 0Ó1Ð 1Ø <<Øð Ü$ QÓ'÷ -ñ -Ø||×*Ñ*Ó,÷ -÷ -ò -øð -ø÷ -÷ -ñ -ûäò Ùð üsy %B¨B ·A'¸B »A+Á B Á!A)Á"B Á&BÁ'B Á)B Á+A=Á1A4 Á2A=Á9B Á<BÁ=B Â B Â BÂ B Â BÚlengthc óè K |dz }| j |z }t | j « |k\ r | j | j |dz
|
}nl| j | j d } | j j |t |« z
|
« d{ }||z dd }| j j |« | xj |z c_ |S 7 ># t
|
$ r}t t « |d}~ww xY ww)z
|
Read `length` bytes of data. These are assumed to be followed
|
by a '
|
' terminator which is subsequently discarded.
|
r Néþÿÿÿ)
|
r× rD rl r| Ú readexactlyr r r- rØ Úappend)rT rç ÚwantÚendÚresultÚtailÚdatar² s rL Ú_readz_AsyncRESPBase._read¶ sÞ è ø ð
|
zØii$Ñ Ü t||Ó Ò #Ø\\ $§)¡)¨c°A©gÐ6Fà<< § ¡ Ð,Dð QØ !\\× 5Ñ 5°d¼SÀ»YÑ6FÓ G×Gð Tk 3 BÐ'FØ LL× Ñ Ô %Ø TÑ Ø ð HùÜ&ò QÜ%Ô&DÓEÈ5ÐPûð Qüs< A#C2Á&*C ÂCÂC Â:C2ÃC à C/ÃC*Ã*C/Ã/C2c óÚ K | j j d| j « }|dk\ r| j | j | }n~| j | j d }| j j « d{ }|j d« st t « ||z dd }| j j |« | xj t |« dz z c_ |S 7 jw)zq
|
read an unknown number of bytes up to the next '
|
'
|
line separator, which is discarded.
|
s
|
r Nré r ) rl Úfindr× r| ÚreadlineÚendswithr r- rØ rë rD )rT Úfoundrî rï rð s rL Ú _readlinez_AsyncRESPBase._readlineÊ sÀ è ø ð
|
×!Ñ! '¨4¯9©9Ó5Ø A:Ø\\ $§)¡)¨eÐ4Fà<< § ¡ Ð,DØ ×.Ñ.Ó0×0DØ== Ô)Ü%Ô&DÓEÐEØTk 3 BÐ'FØ LL× Ñ Ô %Ø S[ 1_Ñ$ Ø ð 1ús A<C+Á>C)Á?A+C+)r[ r\ r] rx rz r r rn rÞ rZ rU r r r rñ r÷ Ú __classcell__)rÛ s @rL rÖ rÖ s] ø Ù+à ×)Ñ)Ð,UÑUIð¨õ ò ò ò ð ¨Dó ð #ð ¨%ó ð( ÷ rN rÖ )UÚloggingÚsysÚabcr Úasyncior r r Útypingr r r r
|
r r Úredis.maint_notificationsr r r r r r Ú version_infoÚmajorÚminorr rå Ú
|
exceptionsr r r r r r r r r r r! r" r# r$ r% r& r' r( r) r* Úencodersr, Úsocketr- r. r^ r` ra r_ rb rc Ú getLoggerr[ r± r0 rg rz r r® r° Ú_MIGRATING_MESSAGEÚ_MIGRATED_MESSAGEÚ_FAILING_OVER_MESSAGEÚ_FAILED_OVER_MESSAGEr¯ r r r r¡ rF ÚstrÚtupleÚtyperÌ r£ rÎ rÖ re rN rL ú<module>r s ðÜ Û
|
Ý ß CÑ Cß G× G÷÷ ð ×Ñ×ÑQÒ 3×#3Ñ#3×#9Ñ#9¸RÒ#?Þ0å6÷÷ ÷ ÷ ÷ ñ õ* Ý ß @àPÐ ØNÐ Ø#TÐ ðð ð ':à0Cñ Ð ð Ð!:ð Ð ð
|
× Ñ 8Ó $ô4$ô 4$ôn ?
|
ô ?ôF$jô $÷$ ;ñ ;ðB %Ð ØØ Ð Ø Ð Ø&Ð Ø$Ð ð ØØØð Ð ð Ø!Ø&×BÑBðð Ø Ø&×FÑFðð Ø#Ø&×BÑBð ð Ø"Ø&×FÑFðð Ø Ø&×7Ñ7ðð#ð .¨tØtÐ+Ñ,¨hÐ6Ñ 7Ð7ñ0ó ô4CKhô CKôLIK 8ô IKôXL_õ LrN
|
