PfddlmZmZmZmZmZddlmZddlm Z m Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZGddZdS))DictListOptionalTupleUnion) DataError)KeyTNumberzTS.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$4eZdZdZ dOdedeedeedeee e fdeed ee d eed ee fd Z dPdedeedeee e fdeed ee d eed ee fd Z dQdede ee fde deedeedeee e fdeed ee d eed ee dee fdZdeeee ee fe ffdZ dRdede dee ee fdeedeedeee e fdeed ee d eed ee fdZ dRdede dee ee fdeedeedeee e fdeed ee d eed ee fdZdededefdZ dSdedede dedeef dZdedefdZdede ee fde ee fd eedee deed!eeed"eed#eed$ee ee fd%eed&ee d'eefd(Z dTdede ee fde ee fd eedee deed!eeed"eed#eed$ee ee fd%eed&ee d'eefd*Z dTdede ee fde ee fd eedee deed!eeed"eed#eed$ee ee fd%eed&ee d'eefd+Zdee deed eed,ee de ee fde ee fd-eed!eeed"eed#eed.ee d/ee d0eee d$ee ee fd%eed&ee d'eef"d1Z dUde ee fde ee fd,ee d eedee deed-eed!eeed"eed#eed.ee d/ee d0eee d$ee ee fd%eed&ee d'eef"d2Z dUde ee fde ee fd,ee d eedee deed-eed!eeed"eed#eed.ee d/ee d0eee d$ee ee fd%eed&ee d'eef"d3ZdVded%eefd4Z dWd,ee d-eed0eee d%eefd5Zdefd6Zd,ee fd7Z e!d8ee deefd9Z"e!d8ee d-eed0eee fd:Z#e!d8ee d.ee d/ee fd;Z$e!d8ee dZ&e!d8ee d eefd?Z'e!d8ee deefd@Z(e!d8ee d$ee ee ffdAZ)e!d8ee dee deefdBZ*e!d8ee deefdCZ+e!d8ee d ee fdDZ,e!d8ee dee fdEZ-e!d8ee dFeeefdGZ.e!d8ee dHeedIeefdJZ/e!d8ee d%eefdKZ0e!d8ee d&ee fdLZ1e!d8ee d'eefdMZ2e! dXd8ee d eed ee fdNZ3dS)YTimeSeriesCommandszRedisTimeSeries Commands.NFkeyretention_msecs uncompressedlabels chunk_sizeduplicate_policyignore_max_time_diffignore_max_val_diffc 8|g} || ||| ||| ||| ||| ||| |||jtg| RS)a Create a new time-series. For more information see https://redis.io/commands/ts.create/ Args: key: The time-series key. retention_msecs: Maximum age for samples, compared to the highest reported timestamp in milliseconds. If `None` or `0` is passed, the series is not trimmed at all. uncompressed: Changes data storage from compressed (default) to uncompressed. labels: A dictionary 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 `[48..1048576]`. In earlier versions of the module the minimum value was different. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': An error will occur and the new value will be ignored. - 'first': Ignore the new value. - 'last': Override with the 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. ignore_max_time_diff: A non-negative integer value, in milliseconds, that sets an ignore threshold for added timestamps. If the difference between the last timestamp and the new timestamp is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_val_diff` is also set. Available since RedisTimeSeries version 1.12.0. ignore_max_val_diff: A non-negative floating point value, that sets an ignore threshold for added values. If the difference between the last value and the new value is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_time_diff` is also set. Available since RedisTimeSeries version 1.12.0. )_append_retention_append_uncompressed_append_chunk_size_append_duplicate_policy_append_labels_append_insertion_filtersexecute_command CREATE_CMD) selfr rrrrrrrparamss T/var/www/html/env/lib/python3.11/site-packages/redis/commands/timeseries/commands.pycreatezTimeSeriesCommands.createsx v777 !!&,777  333 %%f.>??? FF+++ && (*=   $t#J88888c |g}|||||||||||||||||jt g|RS)ag Update an existing time series. For more information see https://redis.io/commands/ts.alter/ Args: key: The time-series key. retention_msecs: Maximum age for samples, compared to the highest reported timestamp in milliseconds. If `None` or `0` is passed, the series is not trimmed at all. labels: A dictionary 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 `[48..1048576]`. In earlier versions of the module the minimum value was different. Changing this value does not affect existing chunks. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': An error will occur and the new value will be ignored. - 'first': Ignore the new value. - 'last': Override with the 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. ignore_max_time_diff: A non-negative integer value, in milliseconds, that sets an ignore threshold for added timestamps. If the difference between the last timestamp and the new timestamp is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_val_diff` is also set. Available since RedisTimeSeries version 1.12.0. ignore_max_val_diff: A non-negative floating point value, that sets an ignore threshold for added values. If the difference between the last value and the new value is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_time_diff` is also set. Available since RedisTimeSeries version 1.12.0. )rrrrrr ALTER_CMD) rr rrrrrrrs r alterzTimeSeriesCommands.alterdst v777  333 %%f.>??? FF+++ && (*=   $t#I77777r" timestampvalue on_duplicatec h|||g} || ||| ||| ||| ||| ||| | | || | |jtg| RS)aa Append a sample to a time series. When the specified key does not exist, a new time series is created. For more information see https://redis.io/commands/ts.add/ Args: key: The 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 age for samples, compared to the highest reported timestamp in milliseconds. If `None` or `0` is passed, the series is not trimmed at all. uncompressed: Changes data storage from compressed (default) to uncompressed. labels: A dictionary 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 `[48..1048576]`. In earlier versions of the module the minimum value was different. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': An error will occur and the new value will be ignored. - 'first': Ignore the new value. - 'last': Override with the 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. ignore_max_time_diff: A non-negative integer value, in milliseconds, that sets an ignore threshold for added timestamps. If the difference between the last timestamp and the new timestamp is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_val_diff` is also set. Available since RedisTimeSeries version 1.12.0. ignore_max_val_diff: A non-negative floating point value, that sets an ignore threshold for added values. If the difference between the last value and the new value is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_time_diff` is also set. Available since RedisTimeSeries version 1.12.0. on_duplicate: Use a specific duplicate policy for the specified timestamp. Overrides the duplicate policy set by `duplicate_policy`. ) rrrrrr_append_on_duplicaterADD_CMD) rr r&r'rrrrrrrr(rs r addzTimeSeriesCommands.addsPy%( v777 !!&,777  333 %%f.>??? FF+++ && (*=    !!&,777#t#G5f5555r" ktv_tuplesc`g}|D]}|||jtg|RS)ay Append new samples to one or more time series. Each time series must already exist. The method expects a list of tuples. Each tuple should contain three elements: (`key`, `timestamp`, `value`). The `value` will be appended to the time series identified by 'key', at the given 'timestamp'. For more information see https://redis.io/commands/ts.madd/ Args: ktv_tuples: A list of tuples, where each tuple contains: - `key`: The key of the time series. - `timestamp`: The timestamp at which the value should be appended. - `value`: The value to append to the time series. Returns: A list that contains, for each sample, either the timestamp that was used, or an error, if the sample could not be added. )extendrMADD_CMD)rr-rktvs r maddzTimeSeriesCommands.maddsH.  C MM#    #t#H6v6666r"c f||g} || ||| ||| ||| ||| ||| ||| | | |jtg| RS)a9 Increment the latest sample's of a series. When the specified key does not exist, a new time series is created. This command can be used as a counter or gauge that automatically gets history as a time series. For more information see https://redis.io/commands/ts.incrby/ Args: key: The time-series key. value: Numeric value to be added (addend). timestamp: Timestamp of the sample. `*` can be used for automatic timestamp (using the system clock). `timestamp` must be equal to or higher than the maximum existing timestamp in the series. When equal, the value of the sample with the maximum existing timestamp is increased. If it is higher, a new sample with a timestamp set to `timestamp` is created, and its value is set to the value of the sample with the maximum existing timestamp plus the addend. retention_msecs: Maximum age for samples, compared to the highest reported timestamp in milliseconds. If `None` or `0` is passed, the series is not trimmed at all. uncompressed: Changes data storage from compressed (default) to uncompressed. labels: A dictionary 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 `[48..1048576]`. In earlier versions of the module the minimum value was different. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': An error will occur and the new value will be ignored. - 'first': Ignore the new value. - 'last': Override with the 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. ignore_max_time_diff: A non-negative integer value, in milliseconds, that sets an ignore threshold for added timestamps. If the difference between the last timestamp and the new timestamp is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_val_diff` is also set. Available since RedisTimeSeries version 1.12.0. ignore_max_val_diff: A non-negative floating point value, that sets an ignore threshold for added values. If the difference between the last value and the new value is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_time_diff` is also set. Available since RedisTimeSeries version 1.12.0. Returns: The timestamp of the sample that was modified or added. ) _append_timestamprrrrrrr INCRBY_CMD rr r'r&rrrrrrrrs r incrbyzTimeSeriesCommands.incrby^u vy111 v777 !!&,777  333 %%f.>??? FF+++ && (*=   $t#J88888r"c f||g} || ||| ||| ||| ||| ||| ||| | | |jtg| RS)a> Decrement the latest sample's of a series. When the specified key does not exist, a new time series is created. This command can be used as a counter or gauge that automatically gets history as a time series. For more information see https://redis.io/commands/ts.decrby/ Args: key: The time-series key. value: Numeric value to subtract (subtrahend). timestamp: Timestamp of the sample. `*` can be used for automatic timestamp (using the system clock). `timestamp` must be equal to or higher than the maximum existing timestamp in the series. When equal, the value of the sample with the maximum existing timestamp is decreased. If it is higher, a new sample with a timestamp set to `timestamp` is created, and its value is set to the value of the sample with the maximum existing timestamp minus subtrahend. retention_msecs: Maximum age for samples, compared to the highest reported timestamp in milliseconds. If `None` or `0` is passed, the series is not trimmed at all. uncompressed: Changes data storage from compressed (default) to uncompressed. labels: A dictionary 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 `[48..1048576]`. In earlier versions of the module the minimum value was different. duplicate_policy: Policy for handling multiple samples with identical timestamps. Can be one of: - 'block': An error will occur and the new value will be ignored. - 'first': Ignore the new value. - 'last': Override with the 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. ignore_max_time_diff: A non-negative integer value, in milliseconds, that sets an ignore threshold for added timestamps. If the difference between the last timestamp and the new timestamp is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_val_diff` is also set. Available since RedisTimeSeries version 1.12.0. ignore_max_val_diff: A non-negative floating point value, that sets an ignore threshold for added values. If the difference between the last value and the new value is lower than this threshold, the new entry is ignored. Only applicable if `duplicate_policy` is set to `last`, and if `ignore_max_time_diff` is also set. Available since RedisTimeSeries version 1.12.0. Returns: The timestamp of the sample that was modified or added. ) r4rrrrrrr DECRBY_CMDr6s r decrbyzTimeSeriesCommands.decrbywr8r" from_timeto_timec<|t|||S)aP Delete all samples between two timestamps for a given time series. The given timestamp interval is closed (inclusive), meaning that samples whose timestamp equals `from_time` or `to_time` are also deleted. For more information see https://redis.io/commands/ts.del/ Args: key: The time-series key. from_time: Start timestamp for the range deletion. to_time: End timestamp for the range deletion. Returns: The number of samples deleted. )rDEL_CMD)rr r<r=s r deletezTimeSeriesCommands.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`. For more information see https://redis.io/commands/ts.createrule/ 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. )_append_aggregationappendrCREATERULE_CMD)rrArBrCrDrErs r createrulezTimeSeriesCommands.createrules[8h'   )9;KLLL  & MM/ * * *#t#N??? 65))) r"rcj|||||||||| | | | | }|jtg|RS)a Query a range in forward direction for a specific time-series. For more information see https://redis.io/commands/ts.range/ 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. )!_TimeSeriesCommands__range_paramsr RANGE_CMDr^s r rangezTimeSeriesCommands.range1s^r$$               $t#I77777r"cj|||||||||| | | | | }|jtg|RS)aB Query a range in reverse direction for a specific time-series. **Note**: This command is only available since RedisTimeSeries >= v1.4 For more information see https://redis.io/commands/ts.revrange/ 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. )rar REVRANGE_CMDr^s r revrangezTimeSeriesCommands.revrange{s^v$$               $t#L:6::::r"filters with_labelsgroupbyreduce select_labelsc||g}||||||||| | |||| ||||||||||||||||| dg||z }| || | |S)z,Create TS.MRANGE and TS.MREVRANGE arguments.FILTER) rWrXrY_append_with_labelsrZr[rGr\r]r/_append_groupby_reduce)rrCrDrNrgr<r=rhrOrPrQrirjrkrRrSrTrUrs r __mrange_paramsz"TimeSeriesCommands.__mrange_paramss*W% FF+++   666 ##F,?ATUUU   mDDD 65))) 65)))   )9;KLLL %%f.>??? 65))) xj!!!' ##FGV<<< r"cr|||||||||| | | | | ||||}|jtg|RS)aM Query a range across multiple time-series by filters in forward direction. For more information see https://redis.io/commands/ts.mrange/ 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. )"_TimeSeriesCommands__mrange_paramsr MRANGE_CMDrr<r=rgrNrCrDrhrOrPrQrirjrkrRrSrTrUrs r mrangezTimeSeriesCommands.mrangesjP%%                 #  ($t#J88888r"cr|||||||||| | | | | ||||}|jtg|RS)aQ Query a range across multiple time-series by filters in reverse direction. For more information see https://redis.io/commands/ts.mrevrange/ 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. )rrr MREVRANGE_CMDrts r mrevrangezTimeSeriesCommands.mrevrangeIsjP%%                 #  ($t#M;F;;;;r"cZ|g}||||jtg|RS)a$ Get the last sample of `key`. For more information see https://redis.io/commands/ts.get/ Args: latest: Used when a time series is a compaction, reports the compacted value of the latest (possibly partial) bucket. )rWrGET_CMD)rr rSrs r getzTimeSeriesCommands.gets< FF+++#t#G5f5555r"cg}||||||||dg||z }|jtg|RS)a Get the last samples matching the specific `filter`. For more information see https://redis.io/commands/ts.mget/ 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 o the time series. latest: Used when a time series is a compaction, reports the compacted value of the latest possibly partial bucket. rm)rWrnr/rMGET_CMD)rrgrhrkrSrs r mgetzTimeSeriesCommands.mgetsp2 FF+++   mDDD xj!!!'#t#H6v6666r"c8|t|S)zp Get information of `key`. For more information see https://redis.io/commands/ts.info/ )rINFO_CMD)rr s r infozTimeSeriesCommands.infos ##Hc222r"c(|jtg|RS)z Get all time series keys matching the `filter` list. For more information see https://redis.io/commands/ts.queryindex/ )rQUERYINDEX_CMD)rrgs r queryindexzTimeSeriesCommands.queryindexs $t#N=W====r"rc<|r|ddgdSdS)z"Append UNCOMPRESSED tag to params.ENCODING UNCOMPRESSEDNr/)rrs r rz'TimeSeriesCommands._append_uncompresseds3  8 MM:~6 7 7 7 7 7 8 8r"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/)rrhrks r rnz&TimeSeriesCommands._append_with_labelssy  = L   * MM<. ) ) )  ? MM,=}= > > > > > ? ?r"cl|/|/|d|d|gdSdSdS)z)Append GROUPBY REDUCE property to params.NGROUPBYREDUCE)r/upper)rrirjs r roz)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 r rz$TimeSeriesCommands._append_retention/  MM; 2 3 3 3 3 3 ! r"c|rF|d|D]\}}|||gdSdS)z!Append LABELS property to params.LABELSN)rHitemsr/)rrkvs r rz!TimeSeriesCommands._append_labels sf  & MM( # # #  & &1 q!f%%%% & & & &r"c<||d|gdSdS)z Append COUNT property to params.NCOUNTr)rrNs r rZz TimeSeriesCommands._append_count/   MM7E* + + + + +  r"c<||d|gdSdS)z$Append TIMESTAMP property to params.N TIMESTAMPr)rr&s r r4z$TimeSeriesCommands._append_timestamprr"c<||d|gdSdS)z Append ALIGN property to params.NALIGNr)rrRs r r[z TimeSeriesCommands._append_alignrr"c>||d||gdSdS)z&Append AGGREGATION property to params.N AGGREGATIONr)rrCrDs r rGz&TimeSeriesCommands._append_aggregation%s3  ' MM=*:<8 9 9 9 9 9 $ #r"ts_listc>||dg|dSdS)z'Append FILTER_BY_TS property to params.N FILTER_BY_TSr)rrs r rXz&TimeSeriesCommands._append_filer_by_tsAs2   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 r rYz)TimeSeriesCommands._append_filer_by_valueGs=  Y%: MM,iC D D D D D ! %:%:r"c8|r|ddSdS)z!Append LATEST property to params.LATESTNrH)rrSs r rWz!TimeSeriesCommands._append_latestOs.  $ MM( # # # # # $ $r"c<||d|gdSdS)z+Append BUCKET_TIMESTAMP property to params.NBUCKETTIMESTAMPr)rrTs r r\z+TimeSeriesCommands._append_bucket_timestampUs1  ' MM,.>? @ @ @ @ @ ( 'r"c8|r|ddSdS)z Append EMPTY property to params.EMPTYNr)rrUs r r]z TimeSeriesCommands._append_empty[s.  # MM' " " " " " # #r"c|du|dukrtd|6|6|dt|t|gdSdSdS)z#Append insertion filters to params.Nz>Both ignore_max_time_diff and ignore_max_val_diff must be set.IGNORE) ValueErrorr/str)rrrs r rz,TimeSeriesCommands._append_insertion_filtersas !D (.AT.I J JP  +0C0O MM3344c:M6N6NO      , +0O0Or")NFNNNNN)NNNNNN)NFNNNNNN)NNFNNNNN)N) NNrNNNNFNF)NNrFNNNNNNNFNF)F)FNF)NN)4__name__ __module__ __qualname____doc__r rintboolrrr r!r%rr,rrr2r7r;r@rJrMrarcrfrrrurxr{r~rr staticmethodrrnrorrrZr4r[rGrrr*rXrYrWr\r]rr"r r r s## *.',+/$(*..204F9F9 F9"#F9tn F9 c3h( F9 SM F9#3-F9'smF9&f-F9F9F9F9V*.+/$(*..204C8C8 C8"#C8c3h( C8 SM C8 #3- C8'smC8&f-C8C8C8C8T*.',+/$(*..204&*S6S6 S6c?S6 S6 "# S6 tn S6c3h(S6SMS6#3-S6'smS6&f-S6smS6S6S6S6j7tE$c3h*G$HI7777B04)-',+/$(*..204Z9Z9 Z9Z9E#s(O, Z9 "# Z9 tn Z9c3h(Z9SMZ9#3-Z9'smZ9&f-Z9Z9Z9Z9@04)-',+/$(*..204Z9Z9 Z9Z9E#s(O, Z9 "# Z9 tn Z9c3h(Z9SMZ9#3-Z9'smZ9&f-Z9Z9Z9Z9xF$F3FFFFF8*. !=!=!=!= !=  != "# !=!=!=!=FJTJTJJJJ c?sCx  }  #3- #3-tCy)&c]&c]c3h(#3-~D $*.*+,0-1-1+/!&*. %H8H8 H8c?H8sCx H8 } H8 #3- H8#3-H8tCy)H8&c]H8&c]H8c3h(H8H8#3-H8~H8H8H8H8^ $*.*+,0-1-1+/!&*. %J;J; J;c?J;sCx J; } J; #3- J;#3-J;tCy)J;&c]J;&c]J;c3h(J;J;#3-J;~J;J;J;J;X""3-"#3-"} " c " c? "sCx"d^"tCy)"&c]"&c]"#" " S *"c3h(" !""#3-#"$~%""""R $*.*+&+,0-1-1!% $-1+/!&*. %%\9\9c?\9sCx\9c \9 } \9 #3- \9#3-\9d^\9tCy)\9&c]\9&c]\9#\9 \9 S *\9c3h(\9 !\9"#3-#\9$~%\9\9\9\9F $*.*+&+,0-1-1!% $-1+/!&*. %%\<\<c?\<sCx\<c \< } \< #3- \<#3-\<d^\<tCy)\<&c]\<&c]\<#\< \< S *\<c3h(\< !\<"#3-#\<$~%\<\<\<\<| 6 6t 6Xd^ 6 6 6 6$',-1!& 77c7d^7 S * 7  7777@33333>$s)>>>>8T#Y8htn888\8 ?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 BcBhsmBBB\B :T#Y:hsm:::\: 6DI6c8K666\6 ES E&.smE@H EEE\E$tCy$(4.$$$\$ AcAhsmAAA\A #d3i####\# /304S &sm&f-\r"r N)typingrrrrrredis.exceptionsr redis.typingr r r+r$rIrr:rLr?rzr5rr0r}rsrwrrbrer rr"r rs55555555555555&&&&&&%%%%%%%%                     WWWWWWWWWWr"