+hddlmZmZmZmZmZddlmZddlm Z m Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZGddZy))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 dIdedeedeedeee e fdeedee f d Z dJdedeedeee e fdeedee f d Z dIded e ee fd e deedeedeee e fdeedee fd Zdeeee ee fe ffdZ dKded e d ee ee fdeedeedeee e fdeefdZ dKded e d ee ee fdeedeedeee e fdeefdZdededefdZ dLdedede dedeef dZdedefdZdede ee fde ee fdeedee deedeeedeedeed ee ee fd!eed"ee d#eefd$Z dMdede ee fde ee fdeedee deedeeedeedeed ee ee fd!eed"ee d#eefd%Z dMdede ee fde ee fdeedee deedeeedeedeed ee ee fd!eed"ee d#eefd&Zdee deedeed'ee de ee fde ee fd(eedeeedeedeed)ee d*ee d+eee d ee ee fd!eed"ee d#eef"d,Z dNde ee fde ee fd'ee deedee deed(eedeeedeedeed)ee d*ee d+eee d ee ee fd!eed"ee d#eef"d-Z dNde ee fde ee fd'ee deedee deed(eedeeedeedeed)ee d*ee d+eee d ee ee fd!eed"ee d#eef"d.ZdOded!eefd/Z dPd'ee d(eed+eee d!eefd0Zdefd1Zd'ee fd2Z e!d3ee deefd4Z"e!d3ee d(eed+eee fd5Z#e!d3ee d)ee d*ee fd6Z$e!d3ee d7eefd8Z%e!d3ee deee fd9Z&e!d3ee deefd:Z'e!d3ee d eefd;Z(e!d3ee d ee ee ffd<Z)e!d3ee dee deefd=Z*e!d3ee deefd>Z+e!d3ee d?ee dee fd@Z,e!d3ee dAeeefdBZ-e!d3ee dCeedDeefdEZ.e!d3ee d!eefdFZ/e!d3ee d"ee fdGZ0e!d3ee d#eefdHZ1y)QTimeSeriesCommandszRedisTimeSeries Commands.Nkeyretention_msecs uncompressedlabels chunk_sizeduplicate_policyc|g}|j|||j|||j|||j|t||j |||j tg|S)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 U/var/www/html/venv/lib/python3.12/site-packages/redis/commands/timeseries/commands.pycreatezTimeSeriesCommands.createswJ v7 !!&,7  3 %%fj:JK FF+#t##J888c|g}|j|||j|||j|t||j |||j tg|S)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.alterJsgF v7  3 %%fi9IJ FF+#t##I777r timestampvaluec |||g} |j| ||j| ||j| ||j| t||j | ||j tg| S)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.addus|Vy%( v7 !!&,7  3 %%fg7GH FF+#t##G5f55r ktv_tuplescdg}|D]}|j||jtg|S)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.madds> C MM#  $t##H6v66r c||g}|j|||j|||j|||j|||j |||j t g|S)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.incrbyvDu vy1 v7 !!&,7  3 FF+#t##J888r c||g}|j|||j|||j|||j|||j |||j t g|S)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_timec2|jt|||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)WEEr source_keydest_keyaggregation_typebucket_size_msecalign_timestampc||g}|j|||||j||jtg|S)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.createrulesL:h'   )9;KL  & MM/ *#t##Ns r deleterulezTimeSeriesCommands.deleteruleCs ##NJIIr count filter_by_tsfilter_by_min_valuefilter_by_max_valuealignlatestbucket_timestampemptyc4|||g}|j|| |j|||j||| |j|||j || |j ||||j || |j|| |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+   6 ##F,?ATU 65) 65)   )9;KL %%f.>? 65) r cj|j||||||||| | | | | }|jtg|S)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.rangehsVj$$              $t##I777r cj|j||||||||| | | | | }|jtg|S)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.revrangesVn$$              $t##L:6::r filters with_labelsgroupbyreduce select_labelsc||g}|j|||j|||j|| | |j||| |j |||j |||j ||||j|||j|||jdg||z }|j|| | |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+   6 ##F,?ATU   mD 65) 65)   )9;KL %%f.>? 65) xj!' ##FGV< r cr|j||||||||| | | | | ||||}|jtg|S)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.mrangesbD%%                 # ($t##J888r cr|j||||||||| | | | | ||||}|jtg|S)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.mrevrangersbD%%                 # ($t##M;F;;r cZ|g}|j|||jtg|S)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.gets3 FF+#t##G5f55r cg}|j|||j||||jdg||z }|jtg|S)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.mgets[2 FF+   mD xj!'#t##H6v66r c.|jt|S)zs# noqa Get information of `key`. For more information: https://redis.io/commands/ts.info/ )rINFO_CMD)rrs rinfozTimeSeriesCommands.infos ##Hc22r c0|jtg|S)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|jdgyy)z"Append UNCOMPRESSED tag to params. UNCOMPRESSEDNr+)rrs rrz'TimeSeriesCommands._append_uncompresseds  MM>* + r cx|r |r td|r|jdg|r|jdg|yy)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 sI =L   MM<. )  MM,=}= > r cV|'|$|jd|d|jgyyy)z)Append GROUPBY REDUCE property to params.NGROUPBYREDUCE)r+upper)rrerfs rrkz)TimeSeriesCommands._append_groupby_reduces2  6#5 MM9gxH I$6 r retentionc0||jd|gyy)z$Append RETENTION property to params.N RETENTIONr)rrs rrz$TimeSeriesCommands._append_retention%   MM; 2 3 !r c|r=|jd|jD]\}}|j||gyy)z!Append LABELS property to params.LABELSN)rDitemsr+)rrkvs rrz!TimeSeriesCommands._append_labels+sA  MM( #  &1 q!f% & r c0||jd|gyy)z Append COUNT property to params.NCOUNTr)rrJs rrVz TimeSeriesCommands._append_count3    MM7E* + r c0||jd|gyy)z$Append TIMESTAMP property to params.N TIMESTAMPr)rr$s rr0z$TimeSeriesCommands._append_timestamp9rr c0||jd|gyy)z Append ALIGN property to params.NALIGNr)rrNs rrWz TimeSeriesCommands._append_align?rr c2||jd||gyy)z&Append AGGREGATION property to params.N AGGREGATIONr)rr?r@s rrCz&TimeSeriesCommands._append_aggregationEs$  ' MM=*:4G4 5 r min_value max_valuec8|||jd||gyyy)z*Append FILTER_BY_VALUE property to params.NFILTER_BY_VALUEr)rrrs rrUz)TimeSeriesCommands._append_filer_by_valuehs+  Y%: MM,iC D&; r c,|r|jdyy)z!Append LATEST property to params.LATESTNrD)rrOs rrSz!TimeSeriesCommands._append_latestps  MM( # r c0||jd|gyy)z+Append BUCKET_TIMESTAMP property to params.NBUCKETTIMESTAMPr)rrPs rrXz+TimeSeriesCommands._append_bucket_timestampvs"  ' MM,.>? @ (r c,|r|jdyy)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"#,9tn ,9 c3h( ,9 SM ,9#3-,9b*.+/$(*. )8 )8"#)8c3h( )8 SM )8 #3- )8`*.',+/$(*.26 26c?26 26 "# 26 tn 26c3h(26SM26#3-26h 7tE$c3h*G$HI 7&04)-',+/$()9 )9)9E#s(O, )9 "# )9 tn )9c3h()9SM)9^04)-',+/$()9 )9)9E#s(O, )9 "# )9 tn )9c3h()9SM)9VF$F3FF.*. "="="= "=  "= "# "=HJTJTJ c?sCx  }  #3- #3-tCy)&c]&c]c3h(#3-~D $*.*+,0-1-1+/!&*. %D8 D8c?D8sCx D8 } D8 #3- D8#3-D8tCy)D8&c]D8&c]D8c3h(D8D8#3-D8~D8V $*.*+,0-1-1+/!&*. %F; F;c?F;sCx F; } F; #3- F;#3-F;tCy)F;&c]F;&c]F;c3h(F;F;#3-F;~F;P""3-"#3-"} " c " c? "sCx"d^"tCy)"&c]"&c]"#" " S *"c3h(" !""#3-#"$~%"R $*.*+&+,0-1-1!% $-1+/!&*. %%V9c?V9sCxV9c V9 } V9 #3- V9#3-V9d^V9tCy)V9&c]V9&c]V9#V9 V9 S *V9c3h(V9 !V9"#3-#V9$~%V9z $*.*+&+,0-1-1!% $-1+/!&*. %%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$s)>,T#Y,htn,, ?S ?d^? S *?? JS J$,SMJ;CC=JJ4$s)4 44 &tCy&(492E&&,d3i, ,, 4$s)4 44 ,d3i,sCx0I,, OS O"3-O#3-OO6496(3-66  FS  F$,SM FEMc] F F6DI6c8K66 ES E&.smE@H EE$tCy$(4.$$ AcAhsmAA #d3i###r r N)typingrrrrrredis.exceptionsr redis.typingr r r'r"rErr6rHr;rvr1r|r,ryrorsrr^rar rr rrsr55&%                     g #g #r