File: //usr/lib/python3.9/site-packages/redis/commands/timeseries/__pycache__/__init__.cpython-39.pyc
a
��b\ � @ s� d dl Z ddlmZ ddlmZmZmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZ ddlmZ ddlmZmZmZmZ G dd � d e�ZG d
d � d ee jj�ZG d d
� d
ee j j �Z dS )� N� )�
parse_to_list� )� ALTER_CMD�
CREATE_CMD�CREATERULE_CMD�DEL_CMD�DELETERULE_CMD�GET_CMD�INFO_CMD�MGET_CMD�
MRANGE_CMD�
MREVRANGE_CMD�QUERYINDEX_CMD� RANGE_CMD� REVRANGE_CMD�TimeSeriesCommands)�TSInfo)� parse_get� parse_m_get�
parse_m_range� parse_rangec @ s$ e Zd ZdZddd�Zd dd�ZdS )
�
TimeSeriesz�
This class subclasses redis-py's `Redis` and implements RedisTimeSeries's
commands (prefixed with "ts").
The client allows to interact with RedisTimeSeries and use all of it's
functionality.
Nc K s~ t tjjttjjttjjttttjjt t
t t
t t
tt
tttttttti
| _|| _|j| _| j�� D ]\}}| j�||� qbdS )z$Create a new RedisTimeSeries client.N)r �redis�clientZbool_okr r r �intr r r r r
r r r
r r r r r r r �MODULE_CALLBACKSZexecute_command�itemsZset_response_callback)�selfr �kwargs�key�value� r" �F/usr/lib/python3.9/site-packages/redis/commands/timeseries/__init__.py�__init__ s$ �zTimeSeries.__init__Tc C sj t | jtj�rPt| jj| jj| jjj| jj| jj | jj
| jj | jj | jj
d� }nt| jj| j||d�}|S )aL Creates a pipeline for the TimeSeries module, that can be used
for executing only TimeSeries commands and core commands.
Usage example:
r = redis.Redis()
pipe = r.ts().pipeline()
for i in range(100):
pipeline.add("with_pipeline", i, 1.1 * i)
pipeline.execute()
) �
nodes_manager�commands_parser�
startup_nodes�result_callbacks�cluster_response_callbacks� cluster_error_retry_attempts�read_from_replicas�reinitialize_steps�lock)�connection_poolZresponse_callbacks� transaction�
shard_hint)�
isinstancer r Z RedisCluster�ClusterPipeliner% r& r' r( r) r* r+ r, �_lock�Pipeliner. r )r r/ r0 �pr" r" r# �pipeline9 s&
�
�zTimeSeries.pipeline)N)TN)�__name__�
__module__� __qualname__�__doc__r$ r6 r" r" r" r# r s
r c @ s e Zd ZdZdS )r2 z Cluster pipeline for the module.N�r7 r8 r9 r: r" r" r" r# r2 ] s r2 c @ s e Zd ZdZdS )r4 zPipeline for the module.Nr; r" r" r" r# r4 a s r4 ) r Zhelpersr Zcommandsr r r r r r
r r r
r r r r r �infor Zutilsr r r r r Zclusterr2 r r4 r" r" r" r# �<module> s @ E