归档各类文件
blame | history | raw
hyb
2025-12-23 7e5db3a16b423ec4a43459805e277979bcac7db5 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

Ë  


 


çúhz ãó"—ddlZddlmZddlmZmZddlmZmZm    Z    m


Z


mZmZm Z mZmZmZmZmZmZmZddlmZddlmZmZmZmZGd    „d


e«ZGd„deej:j<«ZGd „deej>j@«Z y)éN)Úbool_oké)Úget_protocol_versionÚ parse_to_listé)Ú    ALTER_CMDÚ


CREATE_CMDÚCREATERULE_CMDÚDEL_CMDÚDELETERULE_CMDÚGET_CMDÚINFO_CMDÚMGET_CMDÚ


MRANGE_CMDÚ MREVRANGE_CMDÚQUERYINDEX_CMDÚ    RANGE_CMDÚREVRANGE_CMDÚTimeSeriesCommands)ÚTSInfo)Ú    parse_getÚparse_m_getÚ parse_m_rangeÚparse_rangecó —eZdZdZdd„Zdd„Zy)Ú


TimeSerieszÔ


    This class subclasses redis-py's `Redis` and implements RedisTimeSeries's


    commands (prefixed with "ts").


    The client allows to interact with RedisTimeSeries and use all of it's


    functionality.


    Ncóf—tttttttti|_ttttttttttt tt"t$t&t$t(t*i    }i}||_|j.|_t1|j,«dvr|j


j3|«n|j


j3|«|j


j5«D]!\}}|j,j7||«Œ#y)z$Create a new RedisTimeSeries client.)Ú3éN)rrr    r


rÚ_MODULE_CALLBACKSrÚintr rrrrrrrrrrrrrÚclientÚexecute_commandrÚupdateÚitemsÚset_response_callback)Úselfr"ÚkwargsÚ_RESP2_MODULE_CALLBACKSÚ_RESP3_MODULE_CALLBACKSÚkÚvs       õuH:\项目\archive\测试组\脚本\Change_password\venv_build\Lib\site-packages\redis/commands/timeseries/__init__.pyÚ__init__zTimeSeries.__init__!sç€ô ”wÜœÜœGÜœGð    "


ˆÔô ”SÜ”YÜ”fÜ”kÜœ Üœ=Ü”{Üœ+ÜœMð


#


Ðð#%ÐàˆŒØ%×5Ñ5ˆÔä §¡Ó,°Ñ8Ø×"Ñ"×)Ñ)Ð*AÕBà×"Ñ"×)Ñ)Ð*AÔBà×*Ñ*×0Ñ0Ó2ò    4‰DˆAˆqØK‰K×-Ñ-¨a°Õ3ñ    4ócól—t|jtj«rât    |jj


|jj|jj


j|jj|jj|jjj«|jj|jj|jj¬«    }|St|jj |j"||¬«}|S)aLCreates a pipeline for the TimeSeries module, that can be used


        for executing only TimeSeries commands and core commands.


 


        Usage example:


 


        r = redis.Redis()


        pipe = r.ts().pipeline()


        for i in range(100):


            pipeline.add("with_pipeline", i, 1.1 * i)


        pipeline.execute()


 


        )    Ú nodes_managerÚcommands_parserÚ startup_nodesÚresult_callbacksÚcluster_response_callbacksÚcluster_error_retry_attemptsÚread_from_replicasÚreinitialize_stepsÚlock)Úconnection_poolÚresponse_callbacksÚtransactionÚ


shard_hint)Ú


isinstancer"ÚredisÚRedisClusterÚClusterPipeliner1r2r3r4r5ÚretryÚget_retriesr7r8Ú_lockÚPipeliner:r )r'r<r=Úps    r-ÚpipelinezTimeSeries.pipelineCs܀ôd—k‘k¤5×#5Ñ#5Ô6ÜØ"Ÿk™k×7Ñ7Ø $§¡× ;Ñ ;Ø"Ÿk™k×7Ñ7×EÑEØ!%§¡×!=Ñ!=Ø+/¯;©;×+QÑ+QØ-1¯[©[×->Ñ->×-JÑ-JÓ-LØ#'§;¡;×#AÑ#AØ#'§;¡;×#AÑ#AØ—[‘[×&Ñ&ô


ˆAð&ˆô Ø $§¡× ;Ñ ;Ø#'×#9Ñ#9Ø'Ø%ô    ˆAðˆr/)N)TN)Ú__name__Ú


__module__Ú__qualname__Ú__doc__r.rG©r/r-rrs„ñó 4ôD!r/rcó—eZdZdZy)rAz Cluster pipeline for the module.N©rHrIrJrKrLr/r-rArAgs„Ú*r/rAcó—eZdZdZy)rEzPipeline for the module.NrNrLr/r-rErEks„Ú"r/rE)!r?Úredis._parsers.helpersrÚhelpersrrÚcommandsrr    r


rrr rrrrrrrrÚinforÚutilsrrrrrÚclusterrAr"rErLr/r-ú<module>rVsoðÛÝ*ç9÷÷÷÷õ ßEÓEôKÐ#ôKô\+Ð(¨%¯-©-×*GÑ*Gô+ô#Ð! 5§<¡<×#8Ñ#8õ#r/