jN ddlZddlmZmZmZmZmZmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZmZddlmZmZmZmZmZmZmZddlmZddlm 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-dd l.m/Z/dd l0m1Z1m2Z2erdd l3m4Z4e5gd Z6Gd deZ7Gdde7Z8Gdde*Z9Gdde9e$Z:Gdde'Z;Gdde;e"Z<Gdde7e9e e,e;e-e(e+e2 Z=Gdde8e:e!ey)N) TYPE_CHECKINGAny AsyncIterator AwaitableDictIterableIteratorListLiteralMappingNoReturnOptionalSequenceUnion)key_slot)RedisClusterException RedisError)AnyKeyTClusterCommandsProtocol EncodableTKeysTKeyTPatternT ResponseT)deprecated_function) ACLCommandsAsyncACLCommandsAsyncDataAccessCommandsAsyncFunctionCommandsAsyncManagementCommandsAsyncModuleCommandsAsyncScriptCommandsDataAccessCommandsFunctionCommandsHotkeysMetricsTypesManagementCommandsModuleCommandsPubSubCommandsScriptCommands) list_or_args)AsyncRedisModuleCommandsRedisModuleCommands) TargetNodesT)]BITCOUNT BITFIELD_ROBITPOSEVAL_RO EVALSHA_ROFCALL_RODBSIZEDIGESTDUMPEXISTS EXPIRETIME PEXPIRETIMEKEYSSCANPTTL RANDOMKEYTTLTYPEGETGETBITGETRANGEMGETSTRLENLCSGEODISTGEOHASHGEOPOS GEOSEARCHHEXISTSHGETHGETALLHKEYSHLENHMGETHSTRLENHVALS HRANDFIELD HEXPIRETIME HPEXPIRETIMEHTTLHPTTLHSCANLINDEXLPOSLLENLRANGESCARDSDIFFSINTER SINTERCARD SISMEMBER SMISMEMBERSMEMBERS SRANDMEMBERSUNIONSSCANZCARDZCOUNTZDIFFZINTER ZINTERCARD ZLEXCOUNTZMSCORE ZRANDMEMBERZRANGE ZRANGEBYLEX ZRANGEBYSCOREZRANK ZREVRANGEZREVRANGEBYLEXZREVRANGEBYSCOREZREVRANKZSCANZSCOREZUNIONXLENXPENDINGXRANGEXREAD XREVRANGEz JSON.ARRINDEXz JSON.ARRLENzJSON.GETz JSON.MGETz JSON.OBJKEYSz JSON.OBJLENz JSON.RESPz JSON.STRLENz JSON.TYPEz FT.EXPLAINzFT.INFOz FT.PROFILEz FT.SEARCHc XeZdZdZdeedeeeeffdZ de e e fdeeee ffdZ dede eee fdeefd Zdeede eee fd eedeefd Zded edeeefd Zde e e fdeefdZdededefdZdedefdZdedefdZdedefdZdedefdZy)ClusterMultiKeyCommandsC A class containing commands that handle more than one key keysreturnci}|D]G}t|jj|}|j|gj |I|S)z@Split keys into a dictionary that maps a slot to a list of keys.)rencoderencode setdefaultappend)selfr slots_to_keyskeyslots `/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/redis/commands/cluster.py_partition_keys_by_slotz/ClusterMultiKeyCommands._partition_keys_by_slotsO CDLL//45D  $ $T2 . 5 5c :mappingci}|jD]J}t|jj|d}|j |gj |L|S)zBSplit pairs into a dictionary that maps a slot to a list of pairs.r)itemsrrrrextend)rrslots_to_pairspairrs r_partition_pairs_by_slotz0ClusterMultiKeyCommands._partition_pairs_by_slotsY MMODDLL//Q89D  % %dB / 6 6t <$rcommand slots_to_argsc |jxr|tv}|j}|jDcgc]6\}}|j|g|d|j j ||gi8c}}|jScc}}wN target_nodes)read_from_replicas READ_COMMANDSpipelinerexecute_command nodes_managerget_node_from_slotexecuterrrrpiper slot_argss r_execute_pipeline_by_slotz1ClusterMultiKeyCommands._execute_pipeline_by_slots"44QM9Q}}$1#6#6#8 $9i !D   &&99$@RS $9 ||~ s;B  responsesc t|j|Dcic]\}}t||D]\}}|| }}}}}|D cgc]} ||  c} Scc}}}}wcc} wN)zipvalues) rrrr slot_valuesresponsekvresultsrs r_reorder_keys_by_commandz0ClusterMultiKeyCommands._reorder_keys_by_commandsz*-]-A-A-CY)O )O% XK21 qD2 )O  )-- --  .s !A A!argsct||}|j|}|jd|}|j|||S)A Splits the keys into different slots and then calls MGET for the keys of every slot. This operation will not be atomic if keys belong to more than one slot. Returns a list of values ordered identically to ``keys`` For more information see https://redis.io/commands/mget rDr+rrrrrrrress rmget_nonatomicz&ClusterMultiKeyCommands.mget_nonatomicsMD$'44T: ,,V]C,,T=#FFrcH|j|}|jd|S) Sets key/values based on a mapping. Mapping is a dictionary of key/value pairs. Both keys and values should be strings or types that can be cast to a string via str(). Splits the keys into different slots and then calls MSET for the keys of every slot. This operation will not be atomic if keys belong to more than one slot. For more information see https://redis.io/commands/mset MSETrrrrrs rmset_nonatomicz&ClusterMultiKeyCommands.mset_nonatomics)66w?--fnEErcZ|j|}t|j||S)v Runs the given command once for the keys of each slot. Returns the sum of the return values. rsumrrrrrs r_split_command_across_slotsz3ClusterMultiKeyCommands._split_command_across_slots s.44T: 411'=IJJrc(|jdg|S)z Returns the number of ``names`` that exist in the whole cluster. The keys are first split up into slots and then an EXISTS command is sent for every slot For more information see https://redis.io/commands/exists r8rrrs rexistszClusterMultiKeyCommands.existss0t//@4@@rc(|jdg|S)a< Deletes the given keys in the cluster. The keys are first split up into slots and then an DEL command is sent for every slot Non-existent keys are ignored. Returns the number of keys that were deleted. For more information see https://redis.io/commands/del DELrrs rdeletezClusterMultiKeyCommands.delete s0t//===rc(|jdg|S)aa Updates the last access time of given keys across the cluster. The keys are first split up into slots and then an TOUCH command is sent for every slot Non-existent keys are ignored. Returns the number of keys that were touched. For more information see https://redis.io/commands/touch TOUCHrrs rtouchzClusterMultiKeyCommands.touch-s0t//?$??rc(|jdg|S)aM Remove the specified keys in a different thread. The keys are first split up into slots and then an TOUCH command is sent for every slot Non-existent keys are ignored. Returns the number of keys that were unlinked. For more information see https://redis.io/commands/unlink UNLINKrrs runlinkzClusterMultiKeyCommands.unlink<s0t//@4@@rN)__name__ __module__ __qualname____doc__rrrintr rr rrrstrrrrrrrboolrrrrrrrrrrrsHTNtCdO?T w 23  c4 ## $ +238L3L+M c" .tn .sHZ$889 .C= . c .G5GG$x}:MG.Fggz.A&BFtDzF& K3 Kt K KADAYA >D >Y > @4 @I @ AD AY ArrceZdZdZdededeeefdZ de e e fdee fdZdededefd Zded e eee fdeefd Zy ) AsyncClusterMultiKeyCommandsrrrrcKt||}|j|}|jd|d{}|j|||S7w)rrDNrrs rrz+AsyncClusterMultiKeyCommands.mget_nonatomicPsZD$'44T: 226=II,,T=#FFJs3AA ArcdK|j|}|jd|d{S7w)rrNrrs rrz+AsyncClusterMultiKeyCommands.mset_nonatomicgs366w?33FNKKKKs '0.0rcvK|j|}t|j||d{S7w)rNrrs rrz8AsyncClusterMultiKeyCommands._split_command_across_slotszs844T: 77OOPPOs ,97 9rc K|jr|jd{|jxr|tv}|j }|j Dcgc]6\}}|j |g|d|jj||gi8c}}|jd{S7cc}}w7 wr) _initialize initializerrrrrrrrrs rrz6AsyncClusterMultiKeyCommands._execute_pipeline_by_slots   //# # #!44QM9Q}}$1#6#6#8 $9i !D   &&99$@RS $9 \\^## $ $s- CB7=C ;B9C2B?3C9CN)rrrrrrr rrrr rrrrrrrrrrrrrrKsGGtGXc]@SG.LGGZ4G,HLTRVZL& Q QT Qc Q$$+238L3L+M$ c$rrceZdZdZdefdZdefdZdefdZdddefdZ ddd e defd Z ddd e defd Z d e defd ZdedefdZd e deefdZd e defdZ dGdddeedefdZdGdeddefdZdedefdZ dGdede deddefdZdefdZdddedefdZ dHdededdefdZ dGdeddefd Zd!e d"e defd#Z dGd$e deddefd%Zddded e d&edef d'Z d e defd(Z! dGdededdefd)Z"dGdeddefd*Z#dGd+Z$dGd,Z%dddefd-Z&dGdedddfd.Z'dGdedddfd/Z(dGdeddefd0Z)dGdeddefd1Z*e+d2d34dgd5d5d5d5d6fd7ee d8e,e-d9ed:ed;edZ/ dId?ee0d@ee dAee dBee d eee de1ee2ff dCZ3de1ee2ffdDZ4de1ee2ffdEZ5de6e7e1ee2fe8ffdFZ9y)JClusterManagementCommands A class for Redis Cluster management commands The class inherits from Redis's core ManagementCommands class and do the required adjustments to work with cluster mode rctd)z Make the server a replica of another instance, or promote it as master. For more information see https://redis.io/commands/slaveof z(SLAVEOF is not supported in cluster moderrrkwargss rslaveofz!ClusterManagementCommands.slaveofs $$NOOrctd)z Make the server a replica of another instance, or promote it as master. For more information see https://redis.io/commands/replicaof z*REPLICAOF is not supported in cluster moderrs r replicaofz#ClusterManagementCommands.replicaofs $$PQQrctd)zo Swaps two Redis databases. For more information see https://redis.io/commands/swapdb z'SWAPDB is not supported in cluster moderrs rswapdbz ClusterManagementCommands.swapdbs $$MNNr target_noder.c(|jd|S)z Returns the node's id. :target_node: 'ClusterNode' The node to execute the command on For more information check https://redis.io/commands/cluster-myid/ z CLUSTER MYIDrrrrs r cluster_myidz&ClusterManagementCommands.cluster_myids##N#MMrslotsc.|jdg|d|iS)z Assign new hash slots to receiving node. Sends to specified node. :target_node: 'ClusterNode' The node to execute the command on For more information see https://redis.io/commands/cluster-addslots zCLUSTER ADDSLOTSrrrrrs rcluster_addslotsz*ClusterManagementCommands.cluster_addslotss,$t##  !& 5@  rc.|jdg|d|iS)a Similar to the CLUSTER ADDSLOTS command. The difference between the two commands is that ADDSLOTS takes a list of slots to assign to the node, while ADDSLOTSRANGE takes a list of slot ranges (specified by start and end slots) to assign to the node. :target_node: 'ClusterNode' The node to execute the command on For more information see https://redis.io/commands/cluster-addslotsrange zCLUSTER ADDSLOTSRANGErrrs rcluster_addslotsrangez/ClusterManagementCommands.cluster_addslotsranges,$t## # &+ :E  rslot_idc&|jd|S)z Return the number of local keys in the specified hash slot Send to node based on specified slot_id For more information see https://redis.io/commands/cluster-countkeysinslot zCLUSTER COUNTKEYSINSLOTrrrs rcluster_countkeysinslotz1ClusterManagementCommands.cluster_countkeysinslots##$=wGGrnode_idc&|jd|S)z Return the number of failure reports active for a given node Sends to a random node For more information see https://redis.io/commands/cluster-count-failure-reports zCLUSTER COUNT-FAILURE-REPORTSr)rrs rcluster_count_failure_reportz6ClusterManagementCommands.cluster_count_failure_reports##$CWMMrcL|Dcgc]}|jd|c}Scc}w) Set hash slots as unbound in the cluster. It determines by it self what node the slot is in and sends it there Returns a list of the results for each processed slot. For more information see https://redis.io/commands/cluster-delslots CLUSTER DELSLOTSr)rrrs rcluster_delslotsz*ClusterManagementCommands.cluster_delslotss,LQQ54$$%7>5QQQs!c(|jdg|S)aQ Similar to the CLUSTER DELSLOTS command. The difference is that CLUSTER DELSLOTS takes a list of hash slots to remove from the node, while CLUSTER DELSLOTSRANGE takes a list of slot ranges to remove from the node. For more information see https://redis.io/commands/cluster-delslotsrange zCLUSTER DELSLOTSRANGErrrs rcluster_delslotsrangez/ClusterManagementCommands.cluster_delslotsranges$t##$;DeDDrNoptionc|r4|jdvrtd||jd||S|jd|S)a  Forces a slave to perform a manual failover of its master Sends to specified node :target_node: 'ClusterNode' The node to execute the command on For more information see https://redis.io/commands/cluster-failover )FORCETAKEOVERz-Invalid option for CLUSTER FAILOVER command: zCLUSTER FAILOVERr)upperrr)rrrs rcluster_failoverz*ClusterManagementCommands.cluster_failoversg ||~%:: CF8L++&[,''(:'U Urrc(|jd|S)z Provides info about Redis Cluster node state. The command will be sent to a random node in the cluster if no target node is specified. For more information see https://redis.io/commands/cluster-info z CLUSTER INFOrrrrs r cluster_infoz&ClusterManagementCommands.cluster_info&s##N#NNrrc&|jd|S)z Returns the hash slot of the specified key Sends to random node in the cluster For more information see https://redis.io/commands/cluster-keyslot zCLUSTER KEYSLOTr)rrs rcluster_keyslotz)ClusterManagementCommands.cluster_keyslot0s##$5s;;rhostportc,|jd|||S)z Force a node cluster to handshake with another node. Sends to specified node. For more information see https://redis.io/commands/cluster-meet z CLUSTER MEETrr)rrrrs r cluster_meetz&ClusterManagementCommands.cluster_meet9s%## D$\$  rc$|jdS)z Get Cluster config for the node. Sends to random node in the cluster For more information see https://redis.io/commands/cluster-nodes z CLUSTER NODESr)rs r cluster_nodesz'ClusterManagementCommands.cluster_nodesFs##O44rc*|jd||S)z Reconfigure a node as a slave of the specified master node For more information see https://redis.io/commands/cluster-replicate zCLUSTER REPLICATErr)rrrs rcluster_replicatez+ClusterManagementCommands.cluster_replicateOs### |$  rsoftc>|jd|rd|Sd|S)z Reset a Redis Cluster node If 'soft' is True then it will send 'SOFT' argument If 'soft' is False then it will send 'HARD' argument For more information see https://redis.io/commands/cluster-reset z CLUSTER RESETsSOFTsHARDrr)rrrs r cluster_resetz'ClusterManagementCommands.cluster_reset[s9## W $  29 $  rc(|jd|S)z Forces the node to save cluster state on disk For more information see https://redis.io/commands/cluster-saveconfig zCLUSTER SAVECONFIGrrrs rcluster_save_configz-ClusterManagementCommands.cluster_save_configjs##$8|#TTrrnum_keysc(|jd||S)z Returns the number of keys in the specified cluster slot For more information see https://redis.io/commands/cluster-getkeysinslot zCLUSTER GETKEYSINSLOTr)rrr s rcluster_get_keys_in_slotz2ClusterManagementCommands.cluster_get_keys_in_slotts ##$;T8LLrepochc*|jd||S)z Set the configuration epoch in a new node For more information see https://redis.io/commands/cluster-set-config-epoch zCLUSTER SET-CONFIG-EPOCHrr)rr#rs rcluster_set_config_epochz2ClusterManagementCommands.cluster_set_config_epoch|s### &L$  rstatec|jdvr|jd||||S|jdk(r tdtd|)z Bind an hash slot to a specific node :target_node: 'ClusterNode' The node to execute the command on For more information see https://redis.io/commands/cluster-setslot ) IMPORTINGNODE MIGRATINGCLUSTER SETSLOTrSTABLEz4For "stable" state please use cluster_setslot_stablezInvalid slot state: )r rr)rrrrr&s rcluster_setslotz)ClusterManagementCommands.cluster_setslotse ;;=> >''!7E7( [[]h &ST T3E7;< '+D ###J\#JJrc6d|_|jd|S)z Disables read queries. The command will be sent to the default cluster node if target_nodes is not specified. For more information see https://redis.io/commands/readwrite F READWRITErrDrs r readwritez#ClusterManagementCommands.readwrites"#(##Kl#KKr7.2.0(Use client-side caching feature instead.versionreasonFrBclientidprefixbcastoptinoptoutnoloopc 4|jd|||||||S) Enables the tracking feature of the Redis server, that is used for server assisted client side caching. When clientid is provided - in target_nodes only the node that owns the connection with this id should be provided. When clientid is not provided - target_nodes can be any node. For more information see https://redis.io/commands/client-tracking Trclient_trackingrrNrOrPrQrRrSrs rclient_tracking_onz,ClusterManagementCommands.client_tracking_ons40##       %$  rc 4|jd|||||||S) Disables the tracking feature of the Redis server, that is used for server assisted client side caching. When clientid is provided - in target_nodes only the node that owns the connection with this id should be provided. When clientid is not provided - target_nodes can be any node. For more information see https://redis.io/commands/client-tracking FrrVrXs rclient_tracking_offz-ClusterManagementCommands.client_tracking_offs40##       %$  rmetricscountduration sample_ratioc tdz Cluster client does not support hotkeys command. Please use the non-cluster client. For more information see https://redis.io/commands/hotkeys-start VHOTKEYS commands are not supported in cluster mode. Please use the non-cluster client.r;rr]r^r_r`rrs r hotkeys_startz'ClusterManagementCommands.hotkeys_start@s" d  rc tdz Cluster client does not support hotkeys command. Please use the non-cluster client. For more information see https://redis.io/commands/hotkeys-stop rcr;rrs r hotkeys_stopz&ClusterManagementCommands.hotkeys_stopR " d  rc tdz Cluster client does not support hotkeys command. Please use the non-cluster client. For more information see https://redis.io/commands/hotkeys-reset rcr;rhs r hotkeys_resetz'ClusterManagementCommands.hotkeys_reset\rjrc tdz Cluster client does not support hotkeys command. Please use the non-cluster client. For more information see https://redis.io/commands/hotkeys-get rcr;rhs r hotkeys_getz%ClusterManagementCommands.hotkeys_getfrjrr)TNNNNN):rrrrr rrrrrrrrrrrrr rrrrr rrrrrrrr"r%r-r/r1r3r5r7r9r=r?rErHrrrrYr\r&rbytesrerirmlistdictrrprrrrrsP(PRHROO N N9 N  )  3=     ) 3=  $HsHyHNCNIN Rz Rd4j R EJ E9 EDHV)V3;C=V V0O.)AOYO<3<9<NR    "  2:>2J    5y5  *  58    KO    /7/G    8<U$^4U UMSMCMIMDH    (0(@    =)=47=BE=NQ= =(JcJiJFJ    *2>*B    P(>*BPiPQT O OI O x/G SW  h~.F RV KXn%= K K Lh~&> L) L9 #'!#16 3-         ~.    >9 #'!#16 3-         ~.    D $"&&*%)  )* } 3-  sm  S "   sEz  $ c5j(9  sEz):  tDsEz1BC1G,H'I rrceZdZdZdedeefdZedddgd d d d d fd e e d e e d edededede dde fdZedddgd d d d d fd e e d e e d edededede dde fdZ ddeede e de e de e de ee deeeeff dZdeeeeffdZdeeeeffdZdeeeeeefeffdZy)AsyncClusterManagementCommandsrrrcVKtjfd|Dd{S7w)rc3hK|])}tjjd|+yw)rN)asyncio create_taskr).0rrs r zBAsyncClusterManagementCommands.cluster_delslots..s2!D##D$8$89KT$RS!s/2N)rygatherrs` rrz/AsyncClusterManagementCommands.cluster_delslots{s1^^!    s )')rIrJrKNFrBrNrOrPrQrRrSrr.c PK|jd|||||||d{S7w)rUTrNrVrXs rrYz1AsyncClusterManagementCommands.client_tracking_onsB0))       %*    &$&c PK|jd|||||||d{S7w)r[FrNrVrXs rr\z2AsyncClusterManagementCommands.client_tracking_offsB0))       %*    rr]r^r_r`c Ktdwrbr;rds rrez,AsyncClusterManagementCommands.hotkeys_starts" d   c Ktdwrgr;rhs rriz+AsyncClusterManagementCommands.hotkeys_stop " d  rc Ktdwrlr;rhs rrmz,AsyncClusterManagementCommands.hotkeys_resetrrc Ktdwror;rhs rrpz*AsyncClusterManagementCommands.hotkeys_gets" d  rrq)rrrrrr rrrrrrrrrYr\r&rrrrrrerirmrsrtrrprrrrvrvqs Z DJ 9 #'!#16 3-         ~.    >9 #'!#16 3-         ~.    D $"&&*%)  )* } 3-  sm  S "   5e$ % $ ic5j8I.J  ysEz9J/K   4U3:.345 6  rrvceZdZdZ ddeddededeededfd ed ed ee d ed e ffd Z ddee dee dee d efdZxZS)ClusterDataAccessCommands A class for Redis Cluster Data Access Commands The class inherits from Redis's core DataAccessCommand class and do the required adjustments to work with cluster mode stringsalgorFvalue1value2specific_argumentrlenidx minmatchlen withmatchlenrc | jdd} |dk(r| d} | jd| it | ||||||||fi| S)a Implements complex algorithms that operate on strings. Right now the only algorithm implemented is the LCS algorithm (longest common substring). However new algorithms could be implemented in the future. ``algo`` Right now must be LCS ``value1`` and ``value2`` Can be two strings or two keys ``specific_argument`` Specifying if the arguments to the algorithm will be keys or strings. strings is the default. ``len`` Returns just the len of the match. ``idx`` Returns the match positions in each string. ``minmatchlen`` Restrict the list of matches to the ones of a given minimal length. Can be provided only when ``idx`` set to True. ``withmatchlen`` Returns the matches with the len of the match. Can be provided only when ``idx`` set to True. For more information see https://redis.io/commands/stralgo rNrz default-node)popupdatesuperstralgo) rrrrrrrrrrr __class__s rrz!ClusterDataAccessCommands.stralgo sk>zz.$7  )l.B)L ~|45w            rmatchr^_typec +BK|jd|||d|\}}|Ed{|jDcic]\}}|dk7s ||}}}|r|jDcic]}||j|} }|j dd|ru|jD]5\}}|jd||||| |d|\} }|Ed{| |||<7|jDcic]\}}|dk7s ||}}}|rtyyy7cc}}wcc}w7Jcc}}wwN)rr^rr) node_namer)cursorrr^rrrscanrrget_noder) rrr^rrcursorsdatanamernodescurs r scan_iterz#ClusterDataAccessCommands.scan_iter;sM" RU%R6R 4;MMOSOLD&vQR{4rs">, "G2jl ^aA5aAHL$#:L$^T 2T nP 6P fX 2Xv-6-`> ""r