)JfddlmZmZmZmZmZddlmZddlm Z m Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZGddZdS))DictListOptionalTupleUnion) DataError)KeyTNumberTS.ADDzTS.ALTERz TS.CREATERULEz TS.CREATEz TS.DECRBYz TS.DELETERULEzTS.DELzTS.GETz TS.INCRBYzTS.INFOzTS.MADDzTS.MGETz TS.MRANGEz TS.MREVRANGEz TS.QUERYINDEXzTS.RANGEz TS.REVRANGEc$eZdZdZ dKdedeedeedeee e fdeed ee f d Z dLdedeedeee e fdeed ee f d Z dKded e ee fd e deedeedeee e fdeed ee fdZdeeee ee fe ffdZ dMded e d ee ee fdeedeedeee e fdeefdZ dMded e d ee ee fdeedeedeee e fdeefdZdededefdZ dNdedede dedeef dZdedefdZdede ee fde ee fdeedee deedeeedeed eed!ee ee fd"eed#ee d$eefd%Z dOdede ee fde ee fdeedee deedeeedeed eed!ee ee fd"eed#ee d$eefd'Z dOdede ee fde ee fdeedee deedeeedeed eed!ee ee fd"eed#ee d$eefd(Zdee deedeed)ee de ee fde ee fd*eedeeedeed eed+ee d,ee d-eee d!ee ee fd"eed#ee d$eef"d.Z dPde ee fde ee fd)ee deedee deed*eedeeedeed eed+ee d,ee d-eee d!ee ee fd"eed#ee d$eef"d/Z dPde ee fde ee fd)ee deedee deed*eedeeedeed eed+ee d,ee d-eee d!ee ee fd"eed#ee d$eef"d0ZdQded"eefd1Z dRd)ee d*eed-eee d"eefd2Zdefd3Zd)ee fd4Z e!d5ee deefd6Z"e!d5ee d*eed-eee fd7Z#e!d5ee d+ee d,ee fd8Z$e!d5ee d9eefd:Z%e!d5ee deee fd;Z&e!d5ee deefd<Z'e!d5ee d eefd=Z(e!d5ee d!ee ee ffd>Z)e!d5ee dee deefd?Z*e!d5ee deefd@Z+e!d5ee dAee d ee fdBZ,e!d5ee dCeeefdDZ-e!d5ee dEeedFeefdGZ.e!d5ee d"eefdHZ/e!d5ee d#ee fdIZ0e!d5ee d$eefdJZ1dS)STimeSeriesCommandszRedisTimeSeries Commands.NFkeyretention_msecs uncompressedlabels chunk_sizeduplicate_policyc|g}|||||||||||t|||||jtg|RS)a Create a new time-series. Args: key: time-series key retention_msecs: Maximum age for samples compared to highest reported timestamp (in milliseconds). If None or 0 is passed then the series is not trimmed at all. uncompressed: Changes data storage from compressed (by default) to uncompressed labels: Set of label-value pairs that represent metadata labels of the key. chunk_size: Memory size, in bytes, allocated for each data chunk. Must be a multiple of 8 in the range [128 .. 1048576]. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': an error will occur for any out of order sample. - 'first': ignore the new value. - 'last': override with latest value. - 'min': only override if the value is lower than the existing value. - 'max': only override if the value is higher than the existing value. For more information: https://redis.io/commands/ts.create/ )_append_retention_append_uncompressed_append_chunk_size_append_duplicate_policy CREATE_CMD_append_labelsexecute_command)selfrrrrrrparamss e/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/redis/commands/timeseries/commands.pycreatezTimeSeriesCommands.createsJ v777 !!&,777  333 %%fj:JKKK FF+++#t#J88888c|g}||||||||t|||||jtg|RS)az Update the retention, chunk size, duplicate policy, and labels of an existing time series. Args: key: time-series key retention_msecs: Maximum retention period, compared to maximal existing timestamp (in milliseconds). If None or 0 is passed then the series is not trimmed at all. labels: Set of label-value pairs that represent metadata labels of the key. chunk_size: Memory size, in bytes, allocated for each data chunk. Must be a multiple of 8 in the range [128 .. 1048576]. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': an error will occur for any out of order sample. - 'first': ignore the new value. - 'last': override with latest value. - 'min': only override if the value is lower than the existing value. - 'max': only override if the value is higher than the existing value. For more information: https://redis.io/commands/ts.alter/ )rrr ALTER_CMDrr)rrrrrrrs ralterzTimeSeriesCommands.alterJsF v777  333 %%fi9IJJJ FF+++#t#I77777r timestampvaluec |||g} || ||| ||| ||| t||| ||jtg| RS)aj Append (or create and append) a new sample to a time series. Args: key: time-series key timestamp: Timestamp of the sample. * can be used for automatic timestamp (using the system clock). value: Numeric data value of the sample retention_msecs: Maximum retention period, compared to maximal existing timestamp (in milliseconds). If None or 0 is passed then the series is not trimmed at all. uncompressed: Changes data storage from compressed (by default) to uncompressed labels: Set of label-value pairs that represent metadata labels of the key. chunk_size: Memory size, in bytes, allocated for each data chunk. Must be a multiple of 8 in the range [128 .. 1048576]. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': an error will occur for any out of order sample. - 'first': ignore the new value. - 'last': override with latest value. - 'min': only override if the value is lower than the existing value. - 'max': only override if the value is higher than the existing value. For more information: https://redis.io/commands/ts.add/ )rrrrADD_CMDrr) rrr$r%rrrrrrs raddzTimeSeriesCommands.addusVy%( v777 !!&,777  333 %%fg7GHHH FF+++#t#G5f5555r ktv_tuplesc`g}|D]}|||jtg|RS)a- Append (or create and append) a new `value` to series `key` with `timestamp`. Expects a list of `tuples` as (`key`,`timestamp`, `value`). Return value is an array with timestamps of insertions. For more information: https://redis.io/commands/ts.madd/ )extendrMADD_CMD)rr)rktvs rmaddzTimeSeriesCommands.maddsH  C MM#    #t#H6v6666r c ||g}||||||||||||||||jt g|RS)a Increment (or create an time-series and increment) the latest sample's of a series. This command can be used as a counter or gauge that automatically gets history as a time series. Args: key: time-series key value: Numeric data value of the sample timestamp: Timestamp of the sample. * can be used for automatic timestamp (using the system clock). retention_msecs: Maximum age for samples compared to last event time (in milliseconds). If None or 0 is passed then the series is not trimmed at all. uncompressed: Changes data storage from compressed (by default) to uncompressed labels: Set of label-value pairs that represent metadata labels of the key. chunk_size: Memory size, in bytes, allocated for each data chunk. For more information: https://redis.io/commands/ts.incrby/ )_append_timestamprrrrr INCRBY_CMD rrr%r$rrrrrs rincrbyzTimeSeriesCommands.incrbyDu vy111 v777 !!&,777  333 FF+++#t#J88888r c ||g}||||||||||||||||jt g|RS)a Decrement (or create an time-series and decrement) the latest sample's of a series. This command can be used as a counter or gauge that automatically gets history as a time series. Args: key: time-series key value: Numeric data value of the sample timestamp: Timestamp of the sample. * can be used for automatic timestamp (using the system clock). retention_msecs: Maximum age for samples compared to last event time (in milliseconds). If None or 0 is passed then the series is not trimmed at all. uncompressed: Changes data storage from compressed (by default) to uncompressed labels: Set of label-value pairs that represent metadata labels of the key. chunk_size: Memory size, in bytes, allocated for each data chunk. For more information: https://redis.io/commands/ts.decrby/ )r0rrrrr DECRBY_CMDr2s rdecrbyzTimeSeriesCommands.decrbyr4r from_timeto_timec<|t|||S)aY Delete all samples between two timestamps for a given time series. Args: key: time-series key. from_time: Start timestamp for the range deletion. to_time: End timestamp for the range deletion. For more information: https://redis.io/commands/ts.del/ )rDEL_CMD)rrr8r9s rdeletezTimeSeriesCommands.deletes##GS)WEEEr source_keydest_keyaggregation_typebucket_size_msecalign_timestampc||g}||||||||jtg|RS)a Create a compaction rule from values added to `source_key` into `dest_key`. Args: source_key: Key name for source time series dest_key: Key name for destination (compacted) time series aggregation_type: Aggregation type: One of the following: [`avg`, `sum`, `min`, `max`, `range`, `count`, `first`, `last`, `std.p`, `std.s`, `var.p`, `var.s`, `twa`] bucket_size_msec: Duration of each bucket, in milliseconds align_timestamp: Assure that there is a bucket that starts at exactly align_timestamp and align all other buckets accordingly. For more information: https://redis.io/commands/ts.createrule/ )_append_aggregationappendrCREATERULE_CMD)rr=r>r?r@rArs r createrulezTimeSeriesCommands.createrules[:h'   )9;KLLL  & MM/ * * *#t#Ns r deleterulezTimeSeriesCommands.deleteruleCs ##NJIIIr count filter_by_tsfilter_by_min_valuefilter_by_max_valuealignlatestbucket_timestampemptyct|||g}||| ||||||| |||||| ||||||| ||| |S)z*Create TS.RANGE and TS.REVRANGE arguments.)_append_latest_append_filer_by_ts_append_filer_by_value _append_count _append_alignrC_append_bucket_timestamp _append_emptyrrr8r9rJr?r@rKrLrMrNrOrPrQrs r__range_paramsz!TimeSeriesCommands.__range_paramsKs"y'* FF+++   666 ##F,?ATUUU 65))) 65)))   )9;KLLL %%f.>??? 65))) r rcj|||||||||| | | | | }|jtg|RS)a Query a range in forward direction for a specific time-serie. Args: key: Key name for timeseries. from_time: Start timestamp for the range query. - can be used to express the minimum possible timestamp (0). to_time: End timestamp for range query, + can be used to express the maximum possible timestamp. count: Limits the number of returned samples. aggregation_type: Optional aggregation type. Can be one of [`avg`, `sum`, `min`, `max`, `range`, `count`, `first`, `last`, `std.p`, `std.s`, `var.p`, `var.s`, `twa`] bucket_size_msec: Time bucket for aggregation in milliseconds. filter_by_ts: List of timestamps to filter the result by specific timestamps. filter_by_min_value: Filter result by minimum value (must mention also filter by_max_value). filter_by_max_value: Filter result by maximum value (must mention also filter by_min_value). align: Timestamp for alignment control for aggregation. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket bucket_timestamp: Controls how bucket timestamps are reported. Can be one of [`-`, `low`, `+`, `high`, `~`, `mid`]. empty: Reports aggregations for empty buckets. For more information: https://redis.io/commands/ts.range/ )!_TimeSeriesCommands__range_paramsr RANGE_CMDrZs rrangezTimeSeriesCommands.rangehs^j$$               $t#I77777r cj|||||||||| | | | | }|jtg|RS)as Query a range in reverse direction for a specific time-series. **Note**: This command is only available since RedisTimeSeries >= v1.4 Args: key: Key name for timeseries. from_time: Start timestamp for the range query. - can be used to express the minimum possible timestamp (0). to_time: End timestamp for range query, + can be used to express the maximum possible timestamp. count: Limits the number of returned samples. aggregation_type: Optional aggregation type. Can be one of [`avg`, `sum`, `min`, `max`, `range`, `count`, `first`, `last`, `std.p`, `std.s`, `var.p`, `var.s`, `twa`] bucket_size_msec: Time bucket for aggregation in milliseconds. filter_by_ts: List of timestamps to filter the result by specific timestamps. filter_by_min_value: Filter result by minimum value (must mention also filter_by_max_value). filter_by_max_value: Filter result by maximum value (must mention also filter_by_min_value). align: Timestamp for alignment control for aggregation. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket bucket_timestamp: Controls how bucket timestamps are reported. Can be one of [`-`, `low`, `+`, `high`, `~`, `mid`]. empty: Reports aggregations for empty buckets. For more information: https://redis.io/commands/ts.revrange/ )r]r REVRANGE_CMDrZs rrevrangezTimeSeriesCommands.revranges^n$$               $t#L:6::::r filters with_labelsgroupbyreduce select_labelsc||g}||||||||| | |||| ||||||||||||||||| dg||z }| || | |S)z,Create TS.MRANGE and TS.MREVRANGE arguments.FILTER) rSrTrU_append_with_labelsrVrWrCrXrYr+_append_groupby_reduce)rr?r@rJrcr8r9rdrKrLrMrerfrgrNrOrPrQrs r__mrange_paramsz"TimeSeriesCommands.__mrange_paramss*W% FF+++   666 ##F,?ATUUU   mDDD 65))) 65)))   )9;KLLL %%f.>??? 65))) xj!!!' ##FGV<<< r cr|||||||||| | | | | ||||}|jtg|RS)a< Query a range across multiple time-series by filters in forward direction. Args: from_time: Start timestamp for the range query. `-` can be used to express the minimum possible timestamp (0). to_time: End timestamp for range query, `+` can be used to express the maximum possible timestamp. filters: filter to match the time-series labels. count: Limits the number of returned samples. aggregation_type: Optional aggregation type. Can be one of [`avg`, `sum`, `min`, `max`, `range`, `count`, `first`, `last`, `std.p`, `std.s`, `var.p`, `var.s`, `twa`] bucket_size_msec: Time bucket for aggregation in milliseconds. with_labels: Include in the reply all label-value pairs representing metadata labels of the time series. filter_by_ts: List of timestamps to filter the result by specific timestamps. filter_by_min_value: Filter result by minimum value (must mention also filter_by_max_value). filter_by_max_value: Filter result by maximum value (must mention also filter_by_min_value). groupby: Grouping by fields the results (must mention also reduce). reduce: Applying reducer functions on each group. Can be one of [`avg` `sum`, `min`, `max`, `range`, `count`, `std.p`, `std.s`, `var.p`, `var.s`]. select_labels: Include in the reply only a subset of the key-value pair labels of a series. align: Timestamp for alignment control for aggregation. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket bucket_timestamp: Controls how bucket timestamps are reported. Can be one of [`-`, `low`, `+`, `high`, `~`, `mid`]. empty: Reports aggregations for empty buckets. For more information: https://redis.io/commands/ts.mrange/ )"_TimeSeriesCommands__mrange_paramsr MRANGE_CMDrr8r9rcrJr?r@rdrKrLrMrerfrgrNrOrPrQrs rmrangezTimeSeriesCommands.mrangesjD%%                 #  ($t#J88888r cr|||||||||| | | | | ||||}|jtg|RS)a; Query a range across multiple time-series by filters in reverse direction. Args: from_time: Start timestamp for the range query. - can be used to express the minimum possible timestamp (0). to_time: End timestamp for range query, + can be used to express the maximum possible timestamp. filters: Filter to match the time-series labels. count: Limits the number of returned samples. aggregation_type: Optional aggregation type. Can be one of [`avg`, `sum`, `min`, `max`, `range`, `count`, `first`, `last`, `std.p`, `std.s`, `var.p`, `var.s`, `twa`] bucket_size_msec: Time bucket for aggregation in milliseconds. with_labels: Include in the reply all label-value pairs representing metadata labels of the time series. filter_by_ts: List of timestamps to filter the result by specific timestamps. filter_by_min_value: Filter result by minimum value (must mention also filter_by_max_value). filter_by_max_value: Filter result by maximum value (must mention also filter_by_min_value). groupby: Grouping by fields the results (must mention also reduce). reduce: Applying reducer functions on each group. Can be one of [`avg` `sum`, `min`, `max`, `range`, `count`, `std.p`, `std.s`, `var.p`, `var.s`]. select_labels: Include in the reply only a subset of the key-value pair labels of a series. align: Timestamp for alignment control for aggregation. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket bucket_timestamp: Controls how bucket timestamps are reported. Can be one of [`-`, `low`, `+`, `high`, `~`, `mid`]. empty: Reports aggregations for empty buckets. For more information: https://redis.io/commands/ts.mrevrange/ )rnr MREVRANGE_CMDrps r mrevrangezTimeSeriesCommands.mrevrangersjD%%                 #  ($t#M;F;;;;r cZ|g}||||jtg|RS)z# noqa Get the last sample of `key`. `latest` used when a time series is a compaction, reports the compacted value of the latest (possibly partial) bucket For more information: https://redis.io/commands/ts.get/ )rSrGET_CMD)rrrOrs rgetzTimeSeriesCommands.gets< FF+++#t#G5f5555r cg}||||||||dg||z }|jtg|RS)ao# noqa Get the last samples matching the specific `filter`. Args: filters: Filter to match the time-series labels. with_labels: Include in the reply all label-value pairs representing metadata labels of the time series. select_labels: Include in the reply only a subset of the key-value pair labels of a series. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket For more information: https://redis.io/commands/ts.mget/ ri)rSrjr+rMGET_CMD)rrcrdrgrOrs rmgetzTimeSeriesCommands.mgetsp2 FF+++   mDDD xj!!!'#t#H6v6666r c8|t|S)zs# noqa Get information of `key`. For more information: https://redis.io/commands/ts.info/ )rINFO_CMD)rrs rinfozTimeSeriesCommands.infos ##Hc222r c(|jtg|RS)z# noqa Get all time series keys matching the `filter` list. For more information: https://redis.io/commands/ts.queryindex/ )rQUERYINDEX_CMD)rrcs r queryindexzTimeSeriesCommands.queryindexs $t#N=W====r rc:|r|dgdSdS)z"Append UNCOMPRESSED tag to params. UNCOMPRESSEDNr+)rrs rrz'TimeSeriesCommands._append_uncompresseds1  , MM>* + + + + + , ,r c|r|rtd|r|dg|r|dg|dSdS)z!Append labels behavior to params.z:with_labels and select_labels cannot be provided together. WITHLABELSSELECTED_LABELSN)rr+)rrdrgs rrjz&TimeSeriesCommands._append_with_labels sy  = L   * MM<. ) ) )  ? MM,=}= > > > > > ? ?r cl|/|/|d|d|gdSdSdS)z)Append GROUPBY REDUCE property to params.NGROUPBYREDUCE)r+upper)rrerfs rrkz)TimeSeriesCommands._append_groupby_reducesF  6#5 MM9gxH I I I I I  #5#5r retentionc<||d|gdSdS)z$Append RETENTION property to params.N RETENTIONr)rrs rrz$TimeSeriesCommands._append_retention%/  MM; 2 3 3 3 3 3 ! r c|rF|d|D]\}}|||gdSdS)z!Append LABELS property to params.LABELSN)rDitemsr+)rrkvs rrz!TimeSeriesCommands._append_labels+sf  & MM( # # #  & &1 q!f%%%% & & & &r c<||d|gdSdS)z Append COUNT property to params.NCOUNTr)rrJs rrVz TimeSeriesCommands._append_count3/   MM7E* + + + + +  r c<||d|gdSdS)z$Append TIMESTAMP property to params.N TIMESTAMPr)rr$s rr0z$TimeSeriesCommands._append_timestamp9rr c<||d|gdSdS)z Append ALIGN property to params.NALIGNr)rrNs rrWz TimeSeriesCommands._append_align?rr c>||d||gdSdS)z&Append AGGREGATION property to params.N AGGREGATIONr)rr?r@s rrCz&TimeSeriesCommands._append_aggregationEs3  ' MM=*:||dg|dSdS)z'Append FILTER_BY_TS property to params.N FILTER_BY_TSr)rrs rrTz&TimeSeriesCommands._append_filer_by_tsbs2   MM>4G4 5 5 5 5 5  r min_value max_valuecF|||d||gdSdSdS)z*Append FILTER_BY_VALUE property to params.NFILTER_BY_VALUEr)rrrs rrUz)TimeSeriesCommands._append_filer_by_valuehs=  Y%: MM,iC D D D D D ! %:%:r c8|r|ddSdS)z!Append LATEST property to params.LATESTNrD)rrOs rrSz!TimeSeriesCommands._append_latestps.  $ MM( # # # # # $ $r c<||d|gdSdS)z+Append BUCKET_TIMESTAMP property to params.NBUCKETTIMESTAMPr)rrPs rrXz+TimeSeriesCommands._append_bucket_timestampvs1  ' MM,.>? @ @ @ @ @ ( 'r c8|r|ddSdS)z Append EMPTY property to params.EMPTYNr)rrQs rrYz TimeSeriesCommands._append_empty|s.  # MM' " " " " " # #r )NFNNN)NNNN)NNFNN)N) NNrNNNNFNF)NNrFNNNNNNNFNF)F)FNF)2__name__ __module__ __qualname____doc__r rintboolrstrrr#rr r(rrr.r3r7r<rFrIr]r_rbrnrqrtrwrzr}r staticmethodrrjrkrrrVr0rWrCrrrTrUrSrXrYr rr r s>## *.',+/$(*.,9,9 ,9"#,9tn ,9 c3h( ,9 SM ,9#3-,9,9,9,9b*.+/$(*. )8)8 )8"#)8c3h( )8 SM )8 #3- )8)8)8)8`*.',+/$(*.2626 26c?26 26 "# 26 tn 26c3h(26SM26#3-26262626h 7tE$c3h*G$HI 7 7 7 7&04)-',+/$()9)9 )9)9E#s(O, )9 "# )9 tn )9c3h()9SM)9)9)9)9^04)-',+/$()9)9 )9)9E#s(O, )9 "# )9 tn )9c3h()9SM)9)9)9)9VF$F3FFFFF.*. "="="="= "=  "= "# "="="="=HJTJTJJJJ c?sCx  }  #3- #3-tCy)&c]&c]c3h(#3-~D $*.*+,0-1-1+/!&*. %D8D8 D8c?D8sCx D8 } D8 #3- D8#3-D8tCy)D8&c]D8&c]D8c3h(D8D8#3-D8~D8D8D8D8V $*.*+,0-1-1+/!&*. %F;F; F;c?F;sCx F; } F; #3- F;#3-F;tCy)F;&c]F;&c]F;c3h(F;F;#3-F;~F;F;F;F;P""3-"#3-"} " c " c? "sCx"d^"tCy)"&c]"&c]"#" " S *"c3h(" !""#3-#"$~%""""R $*.*+&+,0-1-1!% $-1+/!&*. %%V9V9c?V9sCxV9c V9 } V9 #3- V9#3-V9d^V9tCy)V9&c]V9&c]V9#V9 V9 S *V9c3h(V9 !V9"#3-#V9$~%V9V9V9V9z $*.*+&+,0-1-1!% $-1+/!&*. %%V<V<c?V<sCxV<c V< } V< #3- V<#3-V<d^V<tCy)V<&c]V<&c]V<#V< V< S *V<c3h(V< !V<"#3-#V<$~%V<V<V<V$s)>>>>,T#Y,htn,,,\, ?S ?d^? S *???\? JS J$,SMJ;CC=JJJ\J4$s)4 444\4 &tCy&(492E&&&\&,d3i, ,,,\, 4$s)4 444\4 ,d3i,sCx0I,,,\, OS O"3-O#3-OOO\O6496(3-666\6  FS  F$,SM FEMc] F F F\ F6DI6c8K666\6 ES E&.smE@H EEE\E$tCy$(4.$$$\$ AcAhsmAAA\A #d3i####\###r r N)typingrrrrrredis.exceptionsr redis.typingr r r'r"rErr6rHr;rvr1r|r,ryrorsrr^rar rr rrs55555555555555&&&&&&%%%%%%%%                     g #g #g #g #g #g #g #g #g #g #r