U d@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@seZdZdZdjeeeeeeee e feeee dddZ dkeeeeee e feeee ddd Z dlee ee fe eeeeeee e feeee d d d Zeeee ee fe fd ddZdmee ee ee feeeeeee e feedddZdnee ee ee feeeeeee e feedddZeeedddZdoeee eeedddZeedddZee ee fe ee feeee eeeeeeeeeee ee feeee eed dd Zdpee ee fe ee feeee eeeeeeeeeee ee feeee eed d"d#Zdqee ee fe ee feeee eeeeeeeeeee ee feeee eed d$d%Zee eeeeee e ee fe ee feeeeeeeeeee ee eee ee ee feeee eed&d'd(Zdre ee fe ee fee eeee eeeeeeeeeeeee ee eee ee ee feeee eed)d*d+Zdse ee fe ee fee eeee eeeeeeeeeeeee ee eee ee ee feeee eed)d,d-Zdteeed.d/d0Zduee eeeee eed1d2d3Zed4d5d6Zee d7d8d9Z e!ee eed:d;d<Z"e!ee eeeee d=d>d?Z#e!ee ee ee d@dAdBZ$e!ee eedCdDdEZ%e!ee eee dFdGdHZ&e!ee eedIdJdKZ'e!ee eedLdMdNZ(e!ee ee ee fdOdPdQZ)e!ee ee eedRdSdTZ*e!ee eedUdVdWZ+e!ee ee ee dXdYdZZ,e!ee eeed[d\d]Z-e!ee eeeed^d_d`Z.e!ee eedadbdcZ/e!ee ee dddedfZ0e!ee eedgdhdiZ1dS)vTimeSeriesCommandszRedisTimeSeries Commands.NF)keyretention_msecs uncompressedlabels chunk_sizeduplicate_policycCsT|g}|||||||||||t|||||jtf|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)selfr r rrrrparamsrF/tmp/pip-unpacked-wheel-f5h5_hbx/redis/commands/timeseries/commands.pycreates%    zTimeSeriesCommands.create)r r rrrcCsH|g}||||||||t|||||jtf|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)rr r rrrrrrralterJs #   zTimeSeriesCommands.alter)r timestampvaluer rrrrc CsX|||g} || ||| ||| ||| t||| ||jtf| 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) rr r r!r rrrrrrrraddus+     zTimeSeriesCommands.add) ktv_tuplescCs(g}|D]}||q|jtf|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$rZktvrrrmadds  zTimeSeriesCommands.madd)r r!r r rrrc CsT||g}||||||||||||||||jtf|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 rr r!r r rrrrrrrincrbys"     zTimeSeriesCommands.incrbyc CsT||g}||||||||||||||||jtf|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/ )r(rrrrr DECRBY_CMDr*rrrdecrbys"     zTimeSeriesCommands.decrby)r 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 r.r/rrrdeleteszTimeSeriesCommands.delete) source_keydest_keyaggregation_typebucket_size_msecalign_timestampcCs8||g}|||||dk r(|||jtf|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/ N)_append_aggregationappendrCREATERULE_CMD)rr2r3r4r5r6rrrr createrules  zTimeSeriesCommands.createrule)r2r3cCs|t||S)z Delete a compaction rule from `source_key` to `dest_key`.. For more information: https://redis.io/commands/ts.deleterule/ )rDELETERULE_CMD)rr2r3rrr deleteruleCszTimeSeriesCommands.deleterule) r r.r/countr4r5 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_alignr7_append_bucket_timestamp _append_emptyrr r.r/r=r4r5r>r?r@rArBrCrDrrrrZ__range_paramsKs       z!TimeSeriesCommands.__range_paramsrcCs2|||||||||| | | | | }|jtf|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_CMDrLrrrrangehs 5zTimeSeriesCommands.rangecCs2|||||||||| | | | | }|jtf|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/ )rMr REVRANGE_CMDrLrrrrevranges 7zTimeSeriesCommands.revrange)r4r5r=filtersr.r/ with_labelsr>r?r@groupbyreduce select_labelsrArBrCrDcCs||g}||||||||| | |||| ||||||||||||||||| dg||7}| || | |S)z,Create TS.MRANGE and TS.MREVRANGE arguments.FILTER) rErFrG_append_with_labelsrHrIr7rJrKr%_append_groupby_reduce)rr4r5r=rRr.r/rSr>r?r@rTrUrVrArBrCrDrrrrZ__mrange_paramss       z"TimeSeriesCommands.__mrange_params)r.r/rRr=r4r5rSr>r?r@rTrUrVrArBrCrDcCs:|||||||||| | | | | ||||}|jtf|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_CMDrr.r/rRr=r4r5rSr>r?r@rTrUrVrArBrCrDrrrrmranges(BzTimeSeriesCommands.mrangecCs:|||||||||| | | | | ||||}|jtf|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/ )rZr MREVRANGE_CMDr\rrr mrevrangers(BzTimeSeriesCommands.mrevrange)r rBcCs"|g}||||jtf|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/ )rErGET_CMD)rr rBrrrrgets zTimeSeriesCommands.get)rRrSrVrBcCsBg}||||||||dg||7}|jtf|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/ rW)rErXr%rMGET_CMD)rrRrSrVrBrrrrmgets   zTimeSeriesCommands.mget)r cCs |t|S)zs# noqa Get information of `key`. For more information: https://redis.io/commands/ts.info/ )rINFO_CMD)rr rrrinfoszTimeSeriesCommands.info)rRcCs|jtf|S)z# noqa Get all time series keys matching the `filter` list. For more information: https://redis.io/commands/ts.queryindex/ )rQUERYINDEX_CMD)rrRrrr queryindexszTimeSeriesCommands.queryindexrrcCs|r|dgdS)z"Append UNCOMPRESSED tag to params.Z UNCOMPRESSEDNr%rhrrrrsz'TimeSeriesCommands._append_uncompressedrrSrVcCs6|r|rtd|r |dg|r2|d|dS)z!Append labels behavior to params.z:with_labels and select_labels cannot be provided together.Z WITHLABELSSELECTED_LABELSN)rk)rr%rjrrrrX s z&TimeSeriesCommands._append_with_labelsrrTrUcCs*|dk r&|dk r&|d|d|gdS)z)Append GROUPBY REDUCE property to params.NZGROUPBYREDUCE)r%upperrlrrrrYsz)TimeSeriesCommands._append_groupby_reducerZ retentioncCs|dk r|d|gdS)z$Append RETENTION property to params.NZ RETENTIONrirorrrr%sz$TimeSeriesCommands._append_retention)rrcCs2|r.|d|D]\}}|||gqdS)z!Append LABELS property to params.LABELSN)r8itemsr%)rrkvrrrr+s z!TimeSeriesCommands._append_labelsrr=cCs|dk r|d|gdS)z Append COUNT property to params.NZCOUNTrirtrrrrH3sz TimeSeriesCommands._append_countrr cCs|dk r|d|gdS)z$Append TIMESTAMP property to params.N TIMESTAMPrirurrrr(9sz$TimeSeriesCommands._append_timestamprrAcCs|dk r|d|gdS)z Append ALIGN property to params.NZALIGNrirwrrrrI?sz TimeSeriesCommands._append_alignrr4r5cCs|dk r|d||gdS)z&Append AGGREGATION property to params.NZ AGGREGATIONrirxrrrr7Esz&TimeSeriesCommands._append_aggregationrrcCs|dk r|d|gdS)z%Append CHUNK_SIZE property to params.NZ CHUNK_SIZEriryrrrrOsz%TimeSeriesCommands._append_chunk_sizercommandrcCs2|dk r.|dkr |d|gn|d|gdS)z^Append DUPLICATE_POLICY property to params on CREATE and ON_DUPLICATE on ADD. Nr Z ON_DUPLICATEZDUPLICATE_POLICYrirzrrrrUsz+TimeSeriesCommands._append_duplicate_policyrZts_listcCs|dk r|d|dS)z'Append FILTER_BY_TS property to params.N FILTER_BY_TS)r}rir|rrrrFbsz&TimeSeriesCommands._append_filer_by_tsrZ min_valueZ max_valuecCs$|dk r |dk r |d||gdS)z*Append FILTER_BY_VALUE property to params.NZFILTER_BY_VALUErir~rrrrGhsz)TimeSeriesCommands._append_filer_by_valuerrBcCs|r|ddS)z!Append LATEST property to params.ZLATESTNr8rrrrrEpsz!TimeSeriesCommands._append_latestrrCcCs|dk r|d|gdS)z+Append BUCKET_TIMESTAMP property to params.NZBUCKETTIMESTAMPrirrrrrJvsz+TimeSeriesCommands._append_bucket_timestamprrDcCs|r|ddS)z Append EMPTY property to params.ZEMPTYNrrrrrrK|sz TimeSeriesCommands._append_empty)NFNNN)NNNN)NFNNN)NNFNN)NNFNN)N) NNrNNNNFNF) NNrNNNNFNF)NNrFNNNNNNNFNF)NNrFNNNNNNNFNF)F)FNF)2__name__ __module__ __qualname____doc__rrintboolrstrrrrr r#rrr'r+r-r1r:r<rMrOrQrZr]r_rarcrerg staticmethodrrXrYrrrHr(rIr7rrrFrGrErJrKrrrrr s< 1 0  4$ / + $     "    K    J     )     ]     X   "  r N)typingrrrrrZredis.exceptionsrZ redis.typingrr r"rr9rr,r;r0r`r)rdr&rbr[r^rfrNrPr rrrrs(