Ë
|
|
çúh+¸ ã ó d dl mZmZmZmZmZ d dlmZ d dlm Z m
|
Z
|
dZ dZ dZ dZdZd Zd
|
Zd Zd Zd ZdZdZdZdZdZdZdZ G d d« Z y)é )ÚDictÚListÚOptionalÚTupleÚUnion)Ú DataError)ÚKeyTÚNumberzTS.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 $ ó e Zd ZdZ dMdedee dee deee e f dee dee d ee d
|
ee
|
fd Z dNdedee deee e f dee dee d ee d
|
ee
|
fd Z dOded e ee f de
|
dee dee deee e f dee dee d ee d
|
ee
|
dee fdZdeeee ee f e
|
f fdZ dPdede
|
d ee ee f dee dee deee e f dee dee d ee d
|
ee
|
fdZ dPdede
|
d ee ee f dee dee deee e f dee dee d ee d
|
ee
|
fdZdededefdZ dQdedede ded ee f
|
d Zdedefd Zdede ee f de ee f d ee dee dee d eee d!ee d"ee d#ee ee f d$ee d%ee d&ee fd'Z dRdede ee f de ee f d ee dee dee d eee d!ee d"ee d#ee ee f d$ee d%ee d&ee fd(Z dRdede ee f de ee f d ee dee dee d eee d!ee d"ee d#ee ee f d$ee d%ee d&ee fd)Zdee dee d ee d*ee de ee f de ee f d+ee d eee d!ee d"ee d,ee d-ee d.eee d#ee ee f d$ee d%ee d&ee f"d/Z dSde ee f de ee f d*ee d ee dee dee d+ee d eee d!ee d"ee d,ee d-ee d.eee d#ee ee f d$ee d%ee d&ee f"d0Z dSde ee f de ee f d*ee d ee dee dee d+ee d eee d!ee d"ee d,ee d-ee d.eee d#ee ee f d$ee d%ee d&ee f"d1Z dTded$ee fd2Z dUd*ee d+ee d.eee d$ee fd3Z defd4Z d*ee fd5Z e!d6ee dee fd7« Z"e!d6ee d+ee d.eee fd8« Z#e!d6ee d,ee d-ee fd9« Z$e!d6ee d:ee fd;« Z%e!d6ee deee fd<« Z&e!d6ee d ee fd=« Z'e!d6ee d ee fd>« Z(e!d6ee d#ee ee f fd?« Z)e!d6ee dee dee fd@« Z*e!d6ee dee fdA« Z+e!d6ee dee fdB« Z,e!d6ee dee fdC« Z-e!d6ee dDeee fdE« Z.e!d6ee dFee dGee fdH« Z/e!d6ee d$ee fdI« Z0e!d6ee d%ee fdJ« Z1e!d6ee d&ee fdK« Z2e! dVd6ee d ee d
|
ee
|
fdL« Z3y)WÚTimeSeriesCommandszRedisTimeSeries Commands.NÚkeyÚretention_msecsÚ uncompressedÚlabelsÚ
|
chunk_sizeÚduplicate_policyÚignore_max_time_diffÚignore_max_val_diffc ó |g} | j | |« | j | |« | j | |« | j | |« | j | |« | j | ||« | j t g| ¢ S )a9
|
|
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_filtersÚexecute_commandÚ
|
CREATE_CMD)
|
Úselfr r r r r r r r Úparamss
|
õu H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/commands/timeseries/commands.pyÚcreatezTimeSeriesCommands.create s ðx Ø × Ñ v Ô7Ø ×!Ñ! &¨,Ô7Ø × Ñ ¨
|
Ô3Ø ×%Ñ% fÐ.>Ô?Ø ×ÑF FÔ+Ø ×&Ñ&Ø Ð(Ð*=ô
|
ð $t×#Ñ#¤JÐ8°Ò8Ð8ó c óì |g}| j ||« | j ||« | j ||« | j ||« | j |||« | j
|
t g|¢ S )a
|
|
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.
|
)r r r r r r Ú ALTER_CMD) r r r r r r r r r s r ÚalterzTimeSeriesCommands.alterd s~ ðt Ø × Ñ v Ô7Ø × Ñ ¨
|
Ô3Ø ×%Ñ% fÐ.>Ô?Ø ×ÑF FÔ+Ø ×&Ñ&Ø Ð(Ð*=ô
|
ð $t×#Ñ#¤IÐ7°Ò7Ð7r" Ú timestampÚvalueÚ on_duplicatec ó8 |||g} | j | |« | j | |« | j | |« | j | |« | j | |« | j | | |
|
« | j | | « | j t g| ¢ S )a
|
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`.
|
) r r r r r r Ú_append_on_duplicater ÚADD_CMD) r r r& r' r r r r r r r r( r s r ÚaddzTimeSeriesCommands.add© s£ ðP y %Ð(Ø × Ñ v Ô7Ø ×!Ñ! &¨,Ô7Ø × Ñ ¨
|
Ô3Ø ×%Ñ% fÐ.>Ô?Ø ×ÑF FÔ+Ø ×&Ñ&Ø Ð(Ð*=ô
|
ð ×!Ñ! &¨,Ô7à#t×#Ñ#¤GÐ5¨fÒ5Ð5r" Ú
|
ktv_tuplesc ód g }|D ] }|j |« | j t g|¢ S )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.
|
)Úextendr ÚMADD_CMD)r r- r Úktvs r ÚmaddzTimeSeriesCommands.maddþ s> ð. Ø ò CØ MM#Õ ð ð $t×#Ñ#¤HÐ6¨vÒ6Ð6r" c ó6 ||g} | j | |« | j | |« | j | |« | j | |« | j | |« | j | |« | j | | |
|
« | j t g| ¢ S )aë
|
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_timestampr r r r r r r Ú
|
INCRBY_CMD© r r r' r& r r r r r r r r s r ÚincrbyzTimeSeriesCommands.incrby ó ð^ u Ø × Ñ v yÔ1Ø × Ñ v Ô7Ø ×!Ñ! &¨,Ô7Ø × Ñ ¨
|
Ô3Ø ×%Ñ% fÐ.>Ô?Ø ×ÑF FÔ+Ø ×&Ñ&Ø Ð(Ð*=ô
|
ð $t×#Ñ#¤JÐ8°Ò8Ð8r" c ó6 ||g} | j | |« | j | |« | j | |« | j | |« | j | |« | j | |« | j | | |
|
« | j t g| ¢ S )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.
|
) r4 r r r r r r r Ú
|
DECRBY_CMDr6 s r ÚdecrbyzTimeSeriesCommands.decrbyw r8 r" Ú from_timeÚto_timec ó2 | j 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.
|
)r ÚDEL_CMD)r r r< r= s r ÚdeletezTimeSeriesCommands.deleteÓ s ð( ×#Ñ#¤G¨S°)¸WÓEÐEr" Ú
|
source_keyÚdest_keyÚaggregation_typeÚbucket_size_msecÚalign_timestampc ó ||g}| j |||« ||j |« | j t g|¢ S )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_aggregationÚappendr ÚCREATERULE_CMD)r rA rB rC rD rE r s r Ú
|
createrulez TimeSeriesCommands.createruleé sL ð8 hÐ'Ø × Ñ Ð)9Ð;KÔLØ Ð &Ø MM/Ô *à#t×#Ñ#¤NÐ<°VÒ<Ð<r" c ó0 | j t ||« S )z
|
Delete a compaction rule from `source_key` to `dest_key`.
|
|
For more information see https://redis.io/commands/ts.deleterule/
|
)r ÚDELETERULE_CMD)r rA rB s r Ú
|
deleterulez TimeSeriesCommands.deleterule s ð ×#Ñ#¤N°JÀÓIÐIr" ÚcountÚ filter_by_tsÚfilter_by_min_valueÚfilter_by_max_valueÚalignÚlatestÚbucket_timestampÚemptyc ó4 |||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_alignrG Ú_append_bucket_timestampÚ _append_empty©r r r< r= rN rC rD rO rP rQ rR rS rT rU r s r Ú__range_paramsz!TimeSeriesCommands.__range_params s ð" y 'Ð*Ø ×ÑF FÔ+Ø × Ñ ¨ Ô6Ø ×#Ñ# FÐ,?ÐATÔUØ ×Ñ6 5Ô)Ø ×Ñ6 5Ô)Ø × Ñ Ð)9Ð;KÔLØ ×%Ñ% fÐ.>Ô?Ø ×Ñ6 5Ô)à r" c ór | j ||||||||| |
|
| | | « } | j t g|¢d|giS )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.
|
Úkeys)Ú!_TimeSeriesCommands__range_paramsr Ú RANGE_CMDr^ s r ÚrangezTimeSeriesCommands.range1 s] ðr ×$Ñ$Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø ó
|
ð $t×#Ñ#¤IÐC°ÒC¸c¸UÑCÐCr" c ór | j ||||||||| |
|
| | | « } | j t g|¢d|giS )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.
|
ra )rb r Ú REVRANGE_CMDr^ s r ÚrevrangezTimeSeriesCommands.revrange{ s] ðv ×$Ñ$Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø ó
|
ð $t×#Ñ#¤LÐF°6ÒFÀÀÑFÐFr" ÚfiltersÚ with_labelsÚgroupbyÚreduceÚ select_labelsc ó¬ ||g}| j ||« | j ||« | j || |
|
« | j ||| « | j ||« | j ||« | j |||« | j ||« | j ||« |j dg« ||z }| j || | « |S )z,Create TS.MRANGE and TS.MREVRANGE arguments.ÚFILTER) rW rX rY Ú_append_with_labelsrZ r[ rG r\ r] r/ Ú_append_groupby_reduce)r rC rD rN rh r< r= ri rO rP rQ rj rk rl rR rS rT rU r s r Ú__mrange_paramsz"TimeSeriesCommands.__mrange_paramsÇ sØ ð* WÐ%Ø ×ÑF FÔ+Ø × Ñ ¨ Ô6Ø ×#Ñ# FÐ,?ÐATÔUØ × Ñ ¨°mÔDØ ×Ñ6 5Ô)Ø ×Ñ6 5Ô)Ø × Ñ Ð)9Ð;KÔLØ ×%Ñ% fÐ.>Ô?Ø ×Ñ6 5Ô)Ø xjÔ!Ø'ÑØ ×#Ñ# F¨G°VÔ<Ø r" c ór | j ||||||||| |
|
| | | ||||« } | j t g|¢ S )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_CMD©r r< r= rh rN rC rD ri rO rP rQ rj rk rl rR rS rT rU r s r ÚmrangezTimeSeriesCommands.mrangeë sb ðP ×%Ñ%Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø ó#
|
ð( $t×#Ñ#¤JÐ8°Ò8Ð8r" c ór | j ||||||||| |
|
| | | ||||« } | j t g|¢ S )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.
|
)rs r Ú MREVRANGE_CMDru s r Ú mrevrangez TimeSeriesCommands.mrevrangeI sb ðP ×%Ñ%Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø ó#
|
ð( $t×#Ñ#¤MÐ;°FÒ;Ð;r" c ób |g}| j ||« | j t g|¢d|giS )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.
|
ra )rW r ÚGET_CMD)r r rS r s r ÚgetzTimeSeriesCommands.get§ s: ð Ø ×ÑF FÔ+Ø#t×#Ñ#¤GÐA¨fÒA¸C¸5ÑAÐAr" c ó¬ g }| j ||« | j |||« |j dg« ||z } | j t g|¢ S )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.
|
rn )rW ro r/ r ÚMGET_CMD)r rh ri rl rS r s r ÚmgetzTimeSeriesCommands.mget¶ s[ ð2 Ø ×ÑF FÔ+Ø × Ñ ¨°mÔDØ xjÔ!Ø'ÑØ#t×#Ñ#¤HÐ6¨vÒ6Ð6r" c ó4 | j t ||g¬« S )zp
|
Get information of `key`.
|
|
For more information see https://redis.io/commands/ts.info/
|
)ra )r ÚINFO_CMD)r r s r ÚinfozTimeSeriesCommands.infoÖ s ð ×#Ñ#¤H¨c¸¸Ð#Ó>Ð>r" c ó0 | j t g|¢ S )z
|
Get all time series keys matching the `filter` list.
|
|
For more information see https://redis.io/commands/ts.queryindex/
|
)r ÚQUERYINDEX_CMD)r rh s r Ú
|
queryindexz TimeSeriesCommands.queryindexÞ s ð $t×#Ñ#¤NÐ=°WÒ=Ð=r" r c ó0 |r| j ddg« yy)z"Append UNCOMPRESSED tag to params.ÚENCODINGÚ UNCOMPRESSEDN©r/ )r r s r r z'TimeSeriesCommands._append_uncompressedæ s ñ Ø MM: ~Ð6Õ 7ð r" c óx |r |r t d« |r| j dg« |r| j dg|¢« yy)z!Append labels behavior to params.z:with_labels and select_labels cannot be provided together.Ú
|
WITHLABELSÚSELECTED_LABELSN)r r/ )r ri rl s r ro z&TimeSeriesCommands._append_with_labelsì sI ñ =ÜØLóð ñ Ø MM<.Ô )Ù Ø MMÐ,Ð=¨}Ð=Õ >ð r" c óV |'|$| j d|d|j « g« yyy)z)Append GROUPBY REDUCE property to params.NÚGROUPBYÚREDUCE)r/ Úupper)r rj rk s r rp z)TimeSeriesCommands._append_groupby_reduceý s2 ð
|
Ð 6Ð#5Ø MM9 g¨x¸¿ ¹ » ÐHÕ Ið $6Ð r" Ú retentionc ó0 || j d|g« yy)z$Append RETENTION property to params.NÚ RETENTIONr )r r s r r z$TimeSeriesCommands._append_retention ó ð Ð Ø MM;¨ Ð2Õ 3ð !r" c ó |r=| j d« |j « D ] \ }}| j ||g« yy)z!Append LABELS property to params.ÚLABELSN)rH Úitemsr/ )r r ÚkÚvs r r z!TimeSeriesCommands._append_labels sA ñ Ø MM(Ô #Ø ò &1Ø q !fÕ%ñ &ð r" c ó0 || j d|g« yy)z Append COUNT property to params.NÚCOUNTr )r rN s r rZ z TimeSeriesCommands._append_count ó ð Ð Ø MM7 EÐ*Õ +ð r" c ó0 || j d|g« yy)z$Append TIMESTAMP property to params.NÚ TIMESTAMPr )r r& s r r4 z$TimeSeriesCommands._append_timestamp r r" c ó0 || j d|g« yy)z Append ALIGN property to params.NÚALIGNr )r rR s r r[ z TimeSeriesCommands._append_align r r" c ó2 || j d||g« yy)z&Append AGGREGATION property to params.NÚ AGGREGATIONr )r rC rD s r rG z&TimeSeriesCommands._append_aggregation% s$ ð Ð 'Ø MM=Ð*:Ð<LÐMÕ Nð (r" c ó0 || j d|g« yy)z%Append CHUNK_SIZE property to params.NÚ
|
CHUNK_SIZEr )r r s r r z%TimeSeriesCommands._append_chunk_size/ s ð Ð !Ø MM<¨Ð4Õ 5ð "r" c ó0 || j d|g« yy)z+Append DUPLICATE_POLICY property to params.NÚDUPLICATE_POLICYr )r r s r r z+TimeSeriesCommands._append_duplicate_policy5 s" ð Ð 'Ø MMÐ-Ð/?Ð@Õ Að (r" c ó0 || j d|g« yy)z'Append ON_DUPLICATE property to params.NÚ ON_DUPLICATEr )r r( s r r* z'TimeSeriesCommands._append_on_duplicate; s ð Ð #Ø MM>¨<Ð8Õ 9ð $r" Úts_listc ó2 || j dg|¢« yy)z'Append FILTER_BY_TS property to params.NÚ FILTER_BY_TSr )r r© s r rX z&TimeSeriesCommands._append_filer_by_tsA s# ð Ð Ø MM>Ð4¨GÐ4Õ 5ð r" Ú min_valueÚ max_valuec ó8 ||| j d||g« yyy)z*Append FILTER_BY_VALUE property to params.NÚFILTER_BY_VALUEr )r r¬ r s r rY z)TimeSeriesCommands._append_filer_by_valueG s+ ð
|
Ð YÐ%:Ø MMÐ,¨i¸ÐCÕ Dð &;Ð r" c ó, |r| j d« yy)z!Append LATEST property to params.ÚLATESTN©rH )r rS s r rW z!TimeSeriesCommands._append_latestO s ñ Ø MM(Õ #ð r" c ó0 || j d|g« yy)z+Append BUCKET_TIMESTAMP property to params.NÚBUCKETTIMESTAMPr )r rT s r r\ z+TimeSeriesCommands._append_bucket_timestampU s" ð Ð 'Ø MMÐ,Ð.>Ð?Õ @ð (r" c ó, |r| j d« yy)z Append EMPTY property to params.ÚEMPTYNr² )r rU s r r] z TimeSeriesCommands._append_empty[ s ñ Ø MM'Õ "ð r" c ó |du |du k7 r t d« |*|'| j dt |« t |« g« yyy)z#Append insertion filters to params.Nz>Both ignore_max_time_diff and ignore_max_val_diff must be set.ÚIGNORE)Ú
|
ValueErrorr/ Ústr)r r r s r r z,TimeSeriesCommands._append_insertion_filtersa s` ð ! DÐ (Ð.AÀTÐ.IÒ JÜ ØPóð ð Ð +Ð0CÐ0OØ MMØ3Ð 3Ó4´cÐ:MÓ6NÐOõ ð 1PÐ +r" )NFNNNNN)NNNNNN)NFNNNNNN)NNFNNNNN)N)
|
NNr NNNNFNF)NNr FNNNNNNNFNF)F)FNF)NN)4Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r ÚintÚboolr rº r
|
r! r% r r, r r r2 r7 r; r@ rJ rM rb rd rg rs rv ry r| r r r
Ú staticmethodr ro rp r r rZ r4 r[ rG r r r* rX rY rW r\ r] r © r" r r r s Ù#ð
|
*.Ø',Ø+/Ø$(Ø*.Ø.2Ø04ñF9à ðF9ð " # ðF9ð tnð F9ð
|
c 3h Ñ(ð F9ð SMð F9ð # 3-ðF9ð ' smðF9ð & fÑ -óF9ðV *.Ø+/Ø$(Ø*.Ø.2Ø04ñC8à ðC8ð " # ðC8ð c 3h Ñ(ð C8ð
|
SMð C8ð # 3-ð C8ð ' smðC8ð & fÑ -óC8ðT *.Ø',Ø+/Ø$(Ø*.Ø.2Ø04Ø&*ñS6à ðS6ð c?ðS6ð ð S6ð
|
" # ð S6ð tnð S6ð c 3h Ñ(ðS6ð SMðS6ð # 3-ðS6ð ' smðS6ð & fÑ -ðS6ð smóS6ðj7t E¨$°°c¸3°h±ÀÐ*GÑ$HÑ Ió 7ðB 04Ø)-Ø',Ø+/Ø$(Ø*.Ø.2Ø04ñZ9à ðZ9ð ðZ9ð E # s (OÑ,ð Z9ð
|
" # ð Z9ð tnð Z9ð c 3h Ñ(ðZ9ð SMðZ9ð # 3-ðZ9ð ' smðZ9ð & fÑ -óZ9ð@ 04Ø)-Ø',Ø+/Ø$(Ø*.Ø.2Ø04ñZ9à ðZ9ð ðZ9ð E # s (OÑ,ð Z9ð
|
" # ð Z9ð tnð Z9ð c 3h Ñ(ðZ9ð SMðZ9ð # 3-ðZ9ð ' smðZ9ð & fÑ -óZ9ðxF$ð F¨3ð F¸ó Fð8 *.ñ !=àð!=ð ð!=ð ð !=ð
|
ð !=ð " # ó !=ðFJ Tð J°Tó Jðà ðð c?ðð sCx ð ð
|
}ð ð # 3-ð ð # 3-ðð t CyÑ)ðð & c]ðð & c]ðð c 3hÑ(ðð ðð # 3-ðð ~ó ðD $Ø*.Ø*+Ø,0Ø-1Ø-1Ø+/Ø!&Ø*.Ø %ñ HDà ðHDð c?ðHDð sCx ð HDð
|
}ð HDð # 3-ð HDð # 3-ðHDð t CyÑ)ðHDð & c]ðHDð & c]ðHDð c 3hÑ(ðHDð ðHDð # 3-ðHDð ~ó HDð^ $Ø*.Ø*+Ø,0Ø-1Ø-1Ø+/Ø!&Ø*.Ø %ñ JGà ðJGð c?ðJGð sCx ð JGð
|
}ð JGð # 3-ð JGð # 3-ðJGð t CyÑ)ðJGð & c]ðJGð & c]ðJGð c 3hÑ(ðJGð ðJGð # 3-ðJGð ~ó JGðX"à" 3-ð"ð # 3-ð"ð }ð "ð
|
cð "ð c?ð "ð sCx ð"ð d^ð"ð t CyÑ)ð"ð & c]ð"ð & c]ð"ð # ð"ð ð"ð S¡ Ñ*ð "ð c 3hÑ(ð "ð ð!"ð" # 3-ð#"ð$ ~ó%"ðR $Ø*.Ø*+Ø&+Ø,0Ø-1Ø-1Ø!%Ø $Ø-1Ø+/Ø!&Ø*.Ø %ñ%\9àc?ð\9ð sCx ð\9ð cð \9ð
|
}ð \9ð # 3-ð \9ð # 3-ð\9ð d^ð\9ð t CyÑ)ð\9ð & c]ð\9ð & c]ð\9ð # ð\9ð ð\9ð S¡ Ñ*ð \9ð c 3hÑ(ð \9ð ð!\9ð" # 3-ð#\9ð$ ~ó%\9ðF $Ø*.Ø*+Ø&+Ø,0Ø-1Ø-1Ø!%Ø $Ø-1Ø+/Ø!&Ø*.Ø %ñ%\<àc?ð\<ð sCx ð\<ð cð \<ð
|
}ð \<ð # 3-ð \<ð # 3-ð\<ð d^ð\<ð t CyÑ)ð\<ð & c]ð\<ð & c]ð\<ð # ð\<ð ð\<ð S¡ Ñ*ð \<ð c 3hÑ(ð \<ð ð!\<ð" # 3-ð#\<ð$ ~ó%\<ñ| Btð B X¨d¡^ó Bð$ ',Ø-1Ø!&ñ 7àcð 7ð d^ð 7ð S¡ Ñ*ð 7ð
|
ó 7ð@?ó ?ð> $ s¡)ó >ð ð8 T¨#¡Yð 8¸hÀt¹nò 8ó ð8ð
|
ð?ØS ð?à d^ð?ð S¡ Ñ*ò?ó ð?ð ðJØS ðJØ$,¨S¡MðJØ;CÀC¹=òJó ðJð ð4 $ s¡)ð 4¸À¹ ò 4ó ð4ð
|
ð&t Cyð &°(¸4À¹9Ñ2Eò &ó ð&ð ð,d 3ið ,°¸± ò ,ó ð,ð
|
ð4 $ s¡)ð 4¸À¹ ò 4ó ð4ð
|
ð,d 3ið ,°¸¸sÀC¸x¹ Ñ0Iò ,ó ð,ð
|
ðOØS ðOà" 3-ðOð # 3-òOó ðOð ð6 4¨¡9ð 6¸(À3¹-ò 6ó ð6ð
|
ðB¨¨c©ð BÀhÈsÁmò Bó ðBð
|
ð: T¨#¡Yð :¸hÀs¹mò :ó ð:ð
|
ð6 D¨¡Ið 6¸ÀÀcÁÑ8Kò 6ó ð6ð
|
ðEØS ðEØ&.¨s¡mðEØ@HÈÁ òEó ðEð ð$t Cyð $°(¸4±.ò $ó ð$ð
|
ðA¨¨c©ð AÀhÈsÁmò Aó ðAð
|
ð#d 3ið #°¸±ò #ó ð#ð
|
ð /3Ø04ñØS ðà & smðð & fÑ -òó ñr" r N) Útypingr r r r r Úredis.exceptionsr Ú redis.typingr r
|
r+ r$ rI r r: rL r? r{ r5 r r0 r~ rt rx r rc rf r r r" r ú<module>rÆ sr ðß 5Õ 5å &ß %à
|
Ø Ø Ø
|
Ø
|
Ø Ø
|
Ø
|
Ø
|
Ø Ø Ø Ø
|
Ø Ø Ø Ø ÷Wò Wr"
|
