Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/redis/__pycache__/sentinel.cpython-39.pyc
Ðазад
a a�h�- � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZm Z m Z m Z d dl m Z mZmZ G dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�ZG dd� de�ZdS )� N)�Redis)�ConnectionPool� Connection)�ConnectionError� ResponseError� ReadOnlyError� TimeoutError)� iteritems� nativestr�xrangec @ s e Zd ZdS )�MasterNotFoundErrorN��__name__� __module__� __qualname__� r r �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/redis/sentinel.pyr s r c @ s e Zd ZdS )�SlaveNotFoundErrorNr r r r r r s r c sD e Zd Z� fdd�Zdd� Z� fdd�Zdd� Z� fd d �Z� ZS ) �SentinelManagedConnectionc s& |� d�| _tt| �jf i |�� d S )N�connection_pool)�popr �superr �__init__)�self�kwargs�� __class__r r r s z"SentinelManagedConnection.__init__c C s< | j }dt| �j|jf }| jr8d| j| jf }|| }|S )Nz%s<service=%s%%s>z,host=%s,port=%s)r �typer � service_name�host�port)r �pool�sZ host_infor r r �__repr__ s z"SentinelManagedConnection.__repr__c sH |\| _ | _tt| ��� | jjrD| �d� t| � � �dkrDt d��d S )NZPINGZPONGz PING failed) r r r r �connectr �check_connectionZ send_commandr � read_responser )r �addressr r r � connect_to s z$SentinelManagedConnection.connect_toc C sd | j r d S | jjr$| �| j�� � n<| j�� D ],}z| �|�W S tyX Y q.Y q.0 q.t�d S �N)�_sockr � is_masterr( �get_master_address� rotate_slavesr r )r �slaver r r r$ ( s z!SentinelManagedConnection.connectc sB zt t| ��� W S ty< | jjr6| �� td��� Y n0 d S )Nz"The previous master is now a slave)r r r& r r r+ � disconnectr �r r r r r& 5 s z'SentinelManagedConnection.read_response) r r r r r# r( r$ r& � __classcell__r r r r r s r c sP e Zd ZdZ� fdd�Zdd� Z� fdd�Z� fdd �Zd d � Zd d � Z � Z S )�SentinelConnectionPoolz� Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c sb |� dt�|d< |�dd�| _|�dd�| _tt| �jf i |�� t� | �| j d< || _ || _ d S )NZconnection_classr+ Tr% Fr ) �getr r r+ r% r r2 r �weakref�proxy�connection_kwargsr �sentinel_manager)r r r7 r r r r r L s �z SentinelConnectionPool.__init__c C s dt | �j| j| jrdpdf S )Nz%s<service=%s(%s)Zmasterr. )r r r r+ r0 r r r r# V s �z SentinelConnectionPool.__repr__c s t t| ��� d | _d | _d S r) )r r2 �reset�master_address�slave_rr_counterr0 r r r r8 ] s z SentinelConnectionPool.resetc s8 | j p | j o | j|j|jfk}tt| �}|o6|�|�S r) )r+ r9 r r r r2 �owns_connection)r � connection�check�parentr r r r; b s � z&SentinelConnectionPool.owns_connectionc C s4 | j �| j�}| jr0| j|kr0|| _| jdd� |S )NF)Zinuse_connections)r7 �discover_masterr r+ r9 r/ )r r9 r r r r, i s � z)SentinelConnectionPool.get_master_addressc c s� | j �| j�}|rh| jdu r2t�dt|�d �| _tt|��D ](}| jd t|� | _|| j }|V q>z| �� V W n t y� Y n0 t d| j ��dS )zRound-robin slave balancerNr � zNo slave found for %r) r7 �discover_slavesr r: �random�randint�lenr r, r r )r �slaves�_r. r r r r- t s � z$SentinelConnectionPool.rotate_slaves) r r r �__doc__r r# r8 r; r, r- r1 r r r r r2 D s r2 c @ s^ e Zd ZdZddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z e e fdd�Z e e fdd�Z dS )�Sentinelar Redis Sentinel cluster client >>> from redis.sentinel import Sentinel >>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1) >>> master = sentinel.master_for('mymaster', socket_timeout=0.1) >>> master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> slave.get('foo') b'bar' ``sentinels`` is a list of sentinel nodes. Each node is represented by a pair (hostname, port). ``min_other_sentinels`` defined a minimum number of peers for a sentinel. When querying a sentinel, if it doesn't meet this threshold, responses from that sentinel won't be considered valid. ``sentinel_kwargs`` is a dictionary of connection arguments used when connecting to sentinel instances. Any argument that can be passed to a normal Redis connection can be specified here. If ``sentinel_kwargs`` is not specified, any socket_timeout and socket_keepalive options specified in ``connection_kwargs`` will be used. ``connection_kwargs`` are keyword arguments that will be used when establishing a connection to a Redis server. r Nc sD |d u rdd� t |�D �}|� _� fdd�|D �� _|� _|� _d S )Nc S s i | ]\}}|� d �r||�qS )Zsocket_)� startswith)�.0�k�vr r r � <dictcomp>� s �z%Sentinel.__init__.<locals>.<dictcomp>c s$ g | ] \}}t ||fi � j���qS r )r �sentinel_kwargs)rJ �hostnamer r0 r r � <listcomp>� s �z%Sentinel.__init__.<locals>.<listcomp>)r rN � sentinels�min_other_sentinelsr6 )r rQ rR rN r6 r r0 r r � s � �zSentinel.__init__c C sJ g }| j D ]&}|�d|jjd |jjd f � q dt| �jd�|�f S )Nz%s:%sr r z%s<sentinels=[%s]>�,)rQ �appendr r6 r r �join)r Zsentinel_addresses�sentinelr r r r# � s � �zSentinel.__repr__c C s2 |d r|d s|d r dS |d | j k r.dS dS )Nr+ �is_sdown�is_odownFznum-other-sentinelsT)rR )r �stater r r r �check_master_state� s zSentinel.check_master_statec C s� t | j�D ]z\}}z |�� }W n ttfy8 Y q Y n0 |�|�}|r | �||�r || jd | jd< | j|< |d |d f S q td|f ��dS )z� Asks sentinel servers for the Redis master's address corresponding to the service labeled ``service_name``. Returns a pair (address, port) or raises MasterNotFoundError if no master is found. r �ipr zNo master found for %rN)� enumeraterQ Zsentinel_mastersr r r3 rZ r )r r Z sentinel_norV ZmastersrY r r r r? � s �zSentinel.discover_masterc C s: g }|D ],}|d s|d r q|� |d |d f� q|S )z1Remove slaves that are in an ODOWN or SDOWN staterX rW r[ r )rT )r rE Z slaves_aliver. r r r � filter_slaves� s zSentinel.filter_slavesc C sR | j D ]F}z|�|�}W n tttfy4 Y qY n0 | �|�}|r| S qg S )z;Returns a list of alive slaves for service ``service_name``)rQ Zsentinel_slavesr r r r] )r r rV rE r r r rA � s zSentinel.discover_slavesc K s4 d|d< t | j�}|�|� |||| fi |��d�S )aF Returns a redis client instance for the ``service_name`` master. A SentinelConnectionPool class is used to retrive the master's address before establishing a new connection. NOTE: If the master's address has changed, any cached connections to the old master are closed. By default clients will be a redis.Redis instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The SentinelConnectionPool will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. Tr+ �r ��dictr6 �update�r r Z redis_classZconnection_pool_classr r6 r r r � master_for� s ��zSentinel.master_forc K s4 d|d< t | j�}|�|� |||| fi |��d�S )a� Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrive the slave's address before establishing a new connection. By default clients will be a redis.Redis instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The SentinelConnectionPool will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. Fr+ r^ r_ rb r r r � slave_for s ��zSentinel.slave_for)r N)r r r rG r r# rZ r? r] rA r r2 rc rd r r r r rH � s � �rH )rB r4 Z redis.clientr Zredis.connectionr r Zredis.exceptionsr r r r Z redis._compatr r r r r r r2 �objectrH r r r r �<module> s 1C
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка