o rPf_@sddlmZmZmZmZmZddlmZddlm Z m Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZGdddZdS))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$@seZdZdZ     dndedeedeedeee e fdeed ee f d d Z    dodedeedeee e fdeed ee f d d Z     dndede ee fde deedeedeee e fdeed ee fddZdeeee ee fe ffddZ     dpdede dee ee fdeedeedeee e fdeefddZ     dpdede dee ee fdeedeedeee e fdeefddZdededefddZ dqdedede d ed!eef d"d#Zdedefd$d%Zdede ee fde ee fd&eedee d eed'eeed(eed)eed*ee ee fd+eed,ee d-eefd.d/Z   0       drdede ee fde ee fd&eedee d eed'eeed(eed)eed*ee ee fd+eed,ee d-eefd1d2Z   0       drdede ee fde ee fd&eedee d eed'eeed(eed)eed*ee ee fd+eed,ee d-eefd3d4Zdee d eed&eed5ee de ee fde ee fd6eed'eeed(eed)eed7ee d8ee d9eee d*ee ee fd+eed,ee d-eef"d:d;Z   0           dsde ee fde ee fd5ee d&eedee d eed6eed'eeed(eed)eed7ee d8ee d9eee d*ee ee fd+eed,ee d-eef"dd?Zdtded+eefd@dAZ   dud5ee d6eed9eee d+eefdBdCZdefdDdEZd5ee fdFdGZ e!dHee deefdIdJZ"e!dHee d6eed9eee fdKdLZ#e!dHee d7ee d8ee fdMdNZ$e!dHee dOeefdPdQZ%e!dHee deee fdRdSZ&e!dHee d&eefdTdUZ'e!dHee deefdVdWZ(e!dHee d*ee ee ffdXdYZ)e!dHee dee d eefdZd[Z*e!dHee deefd\d]Z+e!dHee d^ee d ee fd_d`Z,e!dHee daeeefdbdcZ-e!dHee ddeedeeefdfdgZ.e!dHee d+eefdhdiZ/e!dHee d,ee fdjdkZ0e!dHee d-eefdldmZ1dS)vTimeSeriesCommandszRedisTimeSeries Commands.NFkeyretention_msecs uncompressedlabels chunk_sizeduplicate_policycCsV|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. - 'sum': If a previous sample exists, add the new sample to it so that the updated value is equal to (previous + new). If no previous sample exists, set the updated value equal to the new 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)selfr r rrrrparamsrc/var/www/html/humari/django-venv/lib/python3.10/site-packages/redis/commands/timeseries/commands.pycreates(    zTimeSeriesCommands.createcCsJ|g}||||||||t|||||jtg|RS)aa 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. - 'sum': If a previous sample exists, add the new sample to it so that the updated value is equal to (previous + new). If no previous sample exists, set the updated value equal to the new value. For more information: https://redis.io/commands/ts.alter/ )rrr ALTER_CMDrr)rr r rrrrrrralterMs &   zTimeSeriesCommands.alter timestampvaluec CsZ|||g} || ||| ||| ||| t||| ||jtg| RS)aQ 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. - 'sum': If a previous sample exists, add the new sample to it so that the updated value is equal to (previous + new). If no previous sample exists, set the updated value equal to the new value. For more information: https://redis.io/commands/ts.add/ )rrrrADD_CMDrr) rr r r!r rrrrrrrradd{s .    zTimeSeriesCommands.add ktv_tuplescCs*g}|D]}||q|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$rktvrrrmadds  zTimeSeriesCommands.maddc CV||g}||||||||||||||||jtg|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 rr r!r r rrrrrrrincrby"     zTimeSeriesCommands.incrbyc Cr))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/ )r*rrrrr DECRBY_CMDr,rrrdecrbyr.zTimeSeriesCommands.decrby from_timeto_timecCs|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)rr r1r2rrrdeleteszTimeSeriesCommands.delete source_keydest_keyaggregation_typebucket_size_msecalign_timestampcCs:||g}|||||dur|||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/ N)_append_aggregationappendrCREATERULE_CMD)rr5r6r7r8r9rrrr createrule(s  zTimeSeriesCommands.createrulecCs|t||S)z Delete a compaction rule from `source_key` to `dest_key`.. For more information: https://redis.io/commands/ts.deleterule/ )rDELETERULE_CMD)rr5r6rrr deleteruleLszTimeSeriesCommands.deleterulecount filter_by_tsfilter_by_min_valuefilter_by_max_valuealignlatestbucket_timestampemptycCsr|||g}||| ||||||| |||||| ||||||| ||| |S)z*Create TS.RANGE and TS.REVRANGE arguments.)_append_latest_append_filer_by_ts_append_filer_by_value _append_count _append_alignr:_append_bucket_timestamp _append_emptyrr r1r2r@r7r8rArBrCrDrErFrGrrrr__range_paramsTs       z!TimeSeriesCommands.__range_paramsrcC4|||||||||| | | | | }|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_CMDrOrrrrangeqs 5zTimeSeriesCommands.rangecCrQ)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/ )rRr REVRANGE_CMDrOrrrrevranges 7zTimeSeriesCommands.revrangefilters with_labelsgroupbyreduce select_labelscCs||g}||||||||| | |||| ||||||||||||||||| dg||7}| || | |S)z,Create TS.MRANGE and TS.MREVRANGE arguments.FILTER) rHrIrJ_append_with_labelsrKrLr:rMrNr%_append_groupby_reduce)rr7r8r@rWr1r2rXrArBrCrYrZr[rDrErFrGrrrr__mrange_paramss       z"TimeSeriesCommands.__mrange_paramscC<|||||||||| | | | | ||||}|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_CMDrr1r2rWr@r7r8rXrArBrCrYrZr[rDrErFrGrrrrmrange#(BzTimeSeriesCommands.mrangecCr`)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/ )rar MREVRANGE_CMDrcrrr mrevrange{rezTimeSeriesCommands.mrevrangecCs$|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/ )rHrGET_CMD)rr rErrrrgets zTimeSeriesCommands.getcCsDg}||||||||dg||7}|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/ r\)rHr]r%rMGET_CMD)rrWrXr[rErrrrmgets   zTimeSeriesCommands.mgetcCs |t|S)zs# noqa Get information of `key`. For more information: https://redis.io/commands/ts.info/ )rINFO_CMD)rr rrrinfos zTimeSeriesCommands.infocCs|jtg|RS)z# noqa Get all time series keys matching the `filter` list. For more information: https://redis.io/commands/ts.queryindex/ )rQUERYINDEX_CMD)rrWrrr queryindexszTimeSeriesCommands.queryindexrcCs|r |dgdSdS)z"Append UNCOMPRESSED tag to params. UNCOMPRESSEDNr%)rrrrrrsz'TimeSeriesCommands._append_uncompressedcCs<|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%)rrXr[rrrr]s z&TimeSeriesCommands._append_with_labelscCs2|dur|dur|d|d|gdSdSdS)z)Append GROUPBY REDUCE property to params.NGROUPBYREDUCE)r%upper)rrYrZrrrr^&sz)TimeSeriesCommands._append_groupby_reduce retentioncC|dur |d|gdSdS)z$Append RETENTION property to params.N RETENTIONrq)rrwrrrr.z$TimeSeriesCommands._append_retentioncCs6|r|d|D] \}}|||gq dSdS)z!Append LABELS property to params.LABELSN)r;itemsr%)rrkvrrrr4s  z!TimeSeriesCommands._append_labelscCrx)z Append COUNT property to params.NCOUNTrq)rr@rrrrK<rzz TimeSeriesCommands._append_countcCrx)z$Append TIMESTAMP property to params.N TIMESTAMPrq)rr rrrr*Brzz$TimeSeriesCommands._append_timestampcCrx)z Append ALIGN property to params.NALIGNrq)rrDrrrrLHrzz TimeSeriesCommands._append_aligncCs |dur|d||gdSdS)z&Append AGGREGATION property to params.N AGGREGATIONrq)rr7r8rrrr:Nsz&TimeSeriesCommands._append_aggregationcCrx)z%Append CHUNK_SIZE property to params.N CHUNK_SIZErq)rrrrrrXrzz%TimeSeriesCommands._append_chunk_sizecommandcCs8|dur|dkr|d|gdS|d|gdSdS)z^Append DUPLICATE_POLICY property to params on CREATE and ON_DUPLICATE on ADD. Nr ON_DUPLICATEDUPLICATE_POLICYrq)rrrrrrr^s z+TimeSeriesCommands._append_duplicate_policyts_listcCs |dur|dg|dSdS)z'Append FILTER_BY_TS property to params.N FILTER_BY_TSrq)rrrrrrIksz&TimeSeriesCommands._append_filer_by_ts min_value max_valuecCs,|dur|dur|d||gdSdSdS)z*Append FILTER_BY_VALUE property to params.NFILTER_BY_VALUErq)rrrrrrrJqsz)TimeSeriesCommands._append_filer_by_valuecC|r |ddSdS)z!Append LATEST property to params.LATESTNr;)rrErrrrHyz!TimeSeriesCommands._append_latestcCrx)z+Append BUCKET_TIMESTAMP property to params.NBUCKETTIMESTAMPrq)rrFrrrrMrzz+TimeSeriesCommands._append_bucket_timestampcCr)z Append EMPTY property to params.EMPTYNr)rrGrrrrNrz TimeSeriesCommands._append_empty)NFNNN)NNNN)NNFNN)N) NNrNNNNFNF)NNrFNNNNNNNFNF)F)FNF)2__name__ __module__ __qualname____doc__rrintboolrstrrrrr r#rrr(r-r0r4r=r?rRrTrVrardrgrirkrmro staticmethodrr]r^rrrKr*rLr:rrrIrJrHrMrNrrrrr sN 4 3  $7 / + $         "         K         H         )         ]         X       $      r N)typingrrrrrredis.exceptionsr redis.typingrr r"rr<rr/r>r3rhr+rlr&rjrbrfrnrSrUr rrrrs*