Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/loadbalancer/drivers/__pycache__/slb.cpython-39.pyc
Ðазад
a q�h6w � @ s� d dgZ z ddlZW n ey. ddlZY n0 ddlmZmZ ddlmZ ddl m Z ddl m Z m Z mZmZ ddlmZ dd lmZ dd lmZmZmZ d Zd Zd Ze je j e j d�Z dde d�ded�ded�ded�ded�ded�ded�ded�d�iZ e j!e j"d�Z#e j!de j"d iZ$G d d � d e�Z%G d d � d e&�Z'G d!d"� d"ee&�Z(G d#d$� d$e(�Z)G d%d&� d&e(�Z*G d'd(� d(e(�Z+G d)d*� d*e+�Z,G d+d,� d,ee&�Z-e)e*e+e,d-�Z.G d.d� de �Z/dS )/�SLB_API_VERSION� SLBDriver� N)�AliyunXmlResponse�SignedAliyunConnection)� LibcloudError)�State)� Algorithm�Driver� LoadBalancer�Member)� ReprMixin)�u)�findattr�findtext�findallz 2014-05-15zslb.aliyuncs.comz1.0)ZinactiveZactive�locked�balancerZCreateTimeStamp)�xpath�transform_func� AddressType�RegionIdZ RegionIdAliasZ CreateTime� MasterZoneId� SlaveZoneIdZ NetworkType)Zcreate_timestampZ address_typeZ region_idZregion_id_aliasZ create_timeZmaster_zone_idZ slave_zone_idZ network_type)�wrr�wlcr r c @ s e Zd ZeZeZeZdZ dS )� SLBConnectionZslbN) �__name__� __module__� __qualname__r � api_version� SLB_API_HOST�hostr Z responseCls� service_name� r# r# ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/loadbalancer/drivers/slb.pyr a s r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � ZdS ) �SLBLoadBalancerAttributea* This class used to get listeners and backend servers related to a balancer listeners is a ``list`` of ``dict``, each element contains 'ListenerPort' and 'ListenerProtocol' keys. backend_servers is a ``list`` of ``dict``, each element contains 'ServerId' and 'Weight' keys. Nc C s( || _ |p g | _|pg | _|p i | _d S �N)r � listeners�backend_servers�extra)�selfr r' r( r) r# r# r$ �__init__p s z!SLBLoadBalancerAttribute.__init__c C s$ | j D ]}|�d�|kr dS qdS )N� ListenerPortTF)r' �get)r* �port�listenerr# r# r$ � is_listeningv s z%SLBLoadBalancerAttribute.is_listeningc C s& | j D ]}|�d�|jkr dS qdS )NZServeridTF)r( r- �id)r* �member�serverr# r# r$ � is_attached| s z$SLBLoadBalancerAttribute.is_attachedc C s d| j j| j| jf S )Nz:<SLBLoadBalancerAttribute id=%s, ports=%s, servers=%s ...>)r r1 r' r( �r* r# r# r$ �__repr__� s �z!SLBLoadBalancerAttribute.__repr__)N)r r r �__doc__r+ r0 r4 r6 r# r# r# r$ r% h s r% c @ sP e Zd ZdZg d�ZdZg Zddd�Zeddd��Z dd � Z d d � Z d d � Z dS )�SLBLoadBalancerListenerz/ Base SLB load balancer listener class )r. � backend_port� scheduler� bandwidthNc C s. || _ || _t�|d�| _|| _|p&i | _d S )Nr )r. r9 �ALGORITHM_TO_SLB_SCHEDULERr- r: r; r) )r* r. r9 � algorithmr; r) r# r# r$ r+ � s z SLBLoadBalancerListener.__init__c C s | |||||d�S �N�r) r# )�clsr. r9 r= r; r) r# r# r$ �create� s z SLBLoadBalancerListener.createc C s | � � }| �� }|�|� |S r& )�get_required_params�get_optional_params�update)r* �params�optionsr# r# r$ �get_create_params� s z)SLBLoadBalancerListener.get_create_paramsc C s | j | j| j| j| jd�}|S )N)�Actionr, ZBackendServerPortZ Scheduler� Bandwidth)�actionr. r9 r: r; �r* rE r# r# r$ rB � s �z+SLBLoadBalancerListener.get_required_paramsc C s2 i }| j D ]"}| jr || jv r | j| ||< q |S r& )� option_keysr) )r* rF �optionr# r# r$ rC � s z+SLBLoadBalancerListener.get_optional_params)N)N) r r r r7 �_repr_attributesrJ rL r+ � classmethodrA rG rB rC r# r# r# r$ r8 � s r8 c sJ e Zd ZdZdZg d�Zd � fdd� Z� fdd�Zei fd d ��Z � Z S ) �SLBLoadBalancerHttpListenerzM This class represents a rule to route http request to the backends. Z CreateLoadBalancerHTTPListener� Z XForwardedForZStickySessionTypeZ CookieTimeout�Cookie�HealthCheckDomain�HealthCheckURI�HealthCheckConnectPort�HealthyThreshold�UnhealthyThresholdZHealthCheckTimeout�HealthCheckInterval�HealthCheckHttpCodeNc s* t t| �j|||||d� || _|| _d S r> )�superrP r+ �sticky_session� health_check)r* r. r9 r= r; r[ r\ r) �� __class__r# r$ r+ � s �z$SLBLoadBalancerHttpListener.__init__c s& t t| ��� }| j|d< | j|d< |S )N� StickySession� HealthCheck)rZ rP rB r[ r\ rK r] r# r$ rB � s � z/SLBLoadBalancerHttpListener.get_required_paramsc C sF d|vrt d��d|vr t d��|d }|d }| |||||||d�S )Nr_ �StickySession is requiredr` �HealthCheck is requiredr? ��AttributeError)r@ r. r9 r= r; r) r[ r\ r# r# r$ rA � s �z"SLBLoadBalancerHttpListener.create)N� r r r r7 rJ rL r+ rB rO rA � __classcell__r# r# r] r$ rP � s � rP c sJ e Zd ZdZdZg d�Zd � fdd� Z� fdd�Zei fd d ��Z � Z S ) � SLBLoadBalancerHttpsListenerzN This class represents a rule to route https request to the backends. Z CreateLoadBalancerHTTPSListenerrQ Nc s0 t t| �j|||||d� || _|| _|| _d S r> )rZ rg r+ r[ r\ �certificate_id) r* r. r9 r= r; r[ r\ rh r) r] r# r$ r+ � s �z%SLBLoadBalancerHttpsListener.__init__c s0 t t| ��� }| j|d< | j|d< | j|d< |S )Nr_ r` �ServerCertificateId)rZ rg rB r[ r\ rh rK r] r# r$ rB � s � z0SLBLoadBalancerHttpsListener.get_required_paramsc C s` d|vrt d��d|vr t d��d|vr0t d��|d }|d }|d }| ||||||||d�S )Nr_ ra r` rb ri z ServerCertificateId is requiredr? rc ) r@ r. r9 r= r; r) r[ r\ rh r# r# r$ rA � s �z#SLBLoadBalancerHttpsListener.create)Nre r# r# r] r$ rg � s � rg c @ s e Zd ZdZdZg d�ZdS )�SLBLoadBalancerTcpListenerzL This class represents a rule to route tcp request to the backends. Z CreateLoadBalancerTCPListener) �PersistenceTimeoutZHealthCheckTyperS rT rU rV rW �HealthCheckConnectTimeoutrX rY N�r r r r7 rJ rL r# r# r# r$ rj � s rj c @ s e Zd ZdZdZg d�ZdS )�SLBLoadBalancerUdpListenerzL This class represents a rule to route udp request to the backends. Z CreateLoadBalancerUDPListener)rk rU rV rW rl rX Nrm r# r# r# r$ rn s rn c @ s e Zd Zg d�Zdd� ZdS )�SLBServerCertificate�r1 �name� fingerprintc C s || _ || _|| _d S r& rp )r* r1 rq rr r# r# r$ r+ s z SLBServerCertificate.__init__N)r r r rN r+ r# r# r# r$ ro s ro )�http�httpsZtcpZudpc s$ e Zd ZdZdZdZeZdZdZ e Z e Z � fdd�Zdd � Zd@d d �ZdAd d �Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Z d$d%� Z g fd&d'�Z d(d)� Z d*d+� Z d,d-� Z!d.d/� Z"d0d1� Z#d2d3� Z$d4d5� Z%d6d7� Z&d8d9� Z'd:d;� Z(d<d=� Z)d>d?� Z*� Z+S )Br z* Aliyun SLB load balancer driver. zAliyun Server Load Balancerz"https://www.aliyun.com/product/slb�/Nc s t t| ��||� || _d S r& )rZ r r+ �region)r* Z access_id�secretrv r] r# r$ r+ 4 s zSLBDriver.__init__c C s t t�� �S r& )�list�PROTOCOL_TO_LISTENER_MAP�keysr5 r# r# r$ �list_protocols8 s zSLBDriver.list_protocolsc C sb d| j d�}|r(t|t�r(d�|�|d< |rDt|t�rD|�|� |}| jj| j|d�j }| � |�S )a? List all loadbalancers @inherits :class:`Driver.list_balancers` :keyword ex_balancer_ids: a list of balancer ids to filter results Only balancers which's id in this list will be returned :type ex_balancer_ids: ``list`` of ``str`` :keyword ex_filters: attributes to filter results. Only balancers which have all the desired attributes and values will be returned :type ex_filters: ``dict`` ZDescribeLoadBalancers�rH r �,�LoadBalancerId)rE ) rv � isinstancerx �join�dictrD � connection�request�path�object� _to_balancers)r* �ex_balancer_idsZ ex_filtersrE � resp_bodyr# r# r$ �list_balancers; s � zSLBDriver.list_balancersc K s d| j d�}|r||d< |s$td��|s,d}|tvr@td| ��d}|rxz t|�}W n tyn td��Y n0 ||d < |r�|�� d kr�|dkr�td ��||d < |r�|�� d vr�td��||d< | r�| |d< | r�| |d< | r�| |d< | r�| |d< |�r:t|t��r:dd� |D �}tt |��dk�r*td��|d �p6|}n|}d}zt| j � | j |�j }| �|�}||_|du �rtg }|D ]}| �||� �qx| j|||||fi | �� | �||� |W S t�y } z>|du�r�z| �|� W n t�y� Y n0 |�W Y d}~n d}~0 0 dS )ac Create a new load balancer instance @inherits: :class:`Driver.create_balancer` :keyword ex_bandwidth: The max bandwidth limit for `paybybandwidth` internet charge type, in Mbps unit :type ex_bandwidth: ``int`` in range [1, 1000] :keyword ex_internet_charge_type: The internet charge type :type ex_internet_charge_type: a ``str`` of `paybybandwidth` or `paybytraffic` :keyword ex_address_type: The listening IP address type :type ex_address_type: a ``str`` of `internet` or `intranet` :keyword ex_vswitch_id: The vswitch id in a VPC network :type ex_vswitch_id: ``str`` :keyword ex_master_zone_id: The id of the master availability zone :type ex_master_zone_id: ``str`` :keyword ex_slave_zone_id: The id of the slave availability zone :type ex_slave_zone_id: ``str`` :keyword ex_client_token: The token generated by client to identify requests :type ex_client_token: ``str`` ZCreateLoadBalancerr| �LoadBalancerNamezport is requiredrs zunsupport protocol %s���z4ex_bandwidth should be a integer in range [1, 1000].rI Zpaybybandwidthz<PayByBandwidth internet charge type need ex_bandwidth be setZInternetChargeType)ZinternetZintranetz2ex_address_type should be "internet" or "intranet"r Z VSwitchIdr r Z ClientTokenc S s g | ] }|j �qS r# )r. )�.0r2 r# r# r$ � <listcomp>� � z-SLBDriver.create_balancer.<locals>.<listcomp>� z%the ports of members should be uniquer N)rv rd ry �int� ValueError�lowerr rx �len�setr� r� r� r� � _to_balancerr. �balancer_attach_member�ex_create_listener�ex_start_listener� Exception�destroy_balancer)r* rq r. �protocolr= �membersZ ex_bandwidthZex_internet_charge_typeZex_address_typeZ ex_vswitch_idZex_master_zone_idZex_slave_zone_idZex_client_token�kwargsrE r; Z backend_portsr9 r r� r2 �er# r# r$ �create_balancerW s� %� �� zSLBDriver.create_balancerc C s$ d|j d�}| j�| j|�}|�� S )NZDeleteLoadBalancer�rH r~ �r1 r� r� r� �success)r* r rE �respr# r# r$ r� � s �zSLBDriver.destroy_balancerc C s. | j |gd�}t|�dkr&td| ��|d S )N)r� r� z'could not find load balancer with id %sr )r� r� r )r* Z balancer_idZ balancersr# r# r$ � get_balancer� s �zSLBDriver.get_balancerc C sB t |j�dkr|jd }n |jd }t|j||jd�}| �||�S )Nr )r1 �ipr. )r� Z public_ipsZ private_ipsr r1 r. r� )r* r �noder� r2 r# r# r$ � balancer_attach_compute_node� s z&SLBDriver.balancer_attach_compute_nodec C s> d|j d�}|r*t|t�r*| �|g�|d< | j�| j|� |S )NZAddBackendServersr� �BackendServers)r1 r r �_to_servers_jsonr� r� r� �r* r r2 rE r# r# r$ r� � s �z SLBDriver.balancer_attach_memberc C s@ d|j d�}|r,t|t�r,| �|j g�|d< | j�| j|� |S )NZRemoveBackendServersr� r� )r1 r r � _list_to_jsonr� r� r� r� r# r# r$ �balancer_detach_member� s �z SLBDriver.balancer_detach_memberc s" | � � �}� fdd�|jD �}|S )Nc s* g | ]"}t |d dd� d|d id��qS )�ServerIdN�Weight)r r) )r )r� r3 �r r# r$ r� � s � �z3SLBDriver.balancer_list_members.<locals>.<listcomp>)�ex_get_balancer_attributer( )r* r � attributer� r# r� r$ �balancer_list_members� s �z SLBDriver.balancer_list_membersc C s, d|j d�}| j�| j|�j}| �|�}|S )z� Get balancer attribute :param balancer: the balancer to get attribute :type balancer: ``LoadBalancer`` :return: the balancer attribute :rtype: ``SLBLoadBalancerAttribute`` Z DescribeLoadBalancerAttributer� )r1 r� r� r� r� �_to_balancer_attribute)r* r rE r� r� r# r# r$ r� � s � z#SLBDriver.ex_get_balancer_attributec C s | � |�}dd� |jD �}|S )a Get all listener related to the given balancer :param balancer: the balancer to list listeners :type balancer: ``LoadBalancer`` :return: a list of listeners :rtype: ``list`` of ``SLBLoadBalancerListener`` c S s g | ]}t |d ddd��qS )r, N)r8 )r� �eachr# r# r$ r� s � �z/SLBDriver.ex_list_listeners.<locals>.<listcomp>)r� r' )r* r r� r' r# r# r$ �ex_list_listeners s �zSLBDriver.ex_list_listenersc K sl t �|t�}d|v r |d }n|j}|j|||||d�} | �� } |j| d< | j| d< | j� | j | �} | � � S )a/ Create load balancer listening rule. :param balancer: the balancer which the rule belongs to. The listener created will listen on the port of the the balancer as default. 'ListenerPort' in kwargs will *OVERRIDE* it. :type balancer: ``LoadBalancer`` :param backend_port: the backend server port :type backend_port: ``int`` :param protocol: the balancer protocol, default to http :type protocol: ``str`` :param algorithm: the balancer routing algorithm :type algorithm: ``Algorithm`` :param bandwidth: the listener bandwidth limits :type bandwidth: ``str`` :return: the created listener :rtype: ``SLBLoadBalancerListener`` r, r? r~ r ) ry r- rP r. rA rG r1 rv r� r� r� r� ) r* r r9 r� r= r; r� r@ r. r/ rE r� r# r# r$ r� s � � z SLBDriver.ex_create_listenerc C s& d|j |d�}| j�| j|�}|�� S )a! Start balancer's listener listening the given port. :param balancer: a load balancer :type balancer: ``LoadBalancer`` :param port: listening port :type port: ``int`` :return: whether operation is success :rtype: ``bool`` ZStartLoadBalancerListener�rH r~ r, r� �r* r r. rE r� r# r# r$ r� E s �zSLBDriver.ex_start_listenerc C s& d|j |d�}| j�| j|�}|�� S )a Stop balancer's listener listening the given port. :param balancer: a load balancer :type balancer: ``LoadBalancer`` :param port: listening port :type port: ``int`` :return: whether operation is success :rtype: ``bool`` ZStopLoadBalancerListenerr� r� r� r# r# r$ �ex_stop_listenerY s �zSLBDriver.ex_stop_listenerc C s8 d| j ||d�}|r ||d< | j�| j|�j}| �|�S )a/ Upload certificate and private key for https load balancer listener :param name: the certificate name :type name: ``str`` :param server_certificate: the content of the certificate to upload in PEM format :type server_certificate: ``str`` :param private_key: the content of the private key to upload in PEM format :type private_key: ``str`` :return: new created certificate info :rtype: ``SLBServerCertificate`` ZUploadServerCertificate)rH r ZServerCertificateZ PrivateKey�ServerCertificateName)rv r� r� r� r� �_to_server_certificate)r* rq Zserver_certificateZ private_keyrE r� r# r# r$ �ex_upload_certificatem s �z SLBDriver.ex_upload_certificatec s` d� j d�}|r(t|t�r(d�|�|d< � j�� j|�j}t|d� j d�}� fdd�|D �}|S ) z� List all server certificates :param certificate_ids: certificate ids to filter results :type certificate_ids: ``str`` :return: certificates :rtype: ``SLBServerCertificate`` ZDescribeServerCertificatesr| r} ri z$ServerCertificates/ServerCertificate�� namespacec s g | ]}� � |��qS r# )r� �r� �elr5 r# r$ r� � s �z2SLBDriver.ex_list_certificates.<locals>.<listcomp>) rv r rx r� r� r� r� r� r r� )r* Zcertificate_idsrE r� Z cert_elementsZ certificatesr# r5 r$ �ex_list_certificates� s �� �z SLBDriver.ex_list_certificatesc C s& d| j |d�}| j�| j|�}|�� S )z� Delete the given server certificate :param certificate_id: the id of the certificate to delete :type certificate_id: ``str`` :return: whether process is success :rtype: ``bool`` ZDeleteServerCertificate)rH r ri �rv r� r� r� r� )r* rh rE r� r# r# r$ �ex_delete_certificate� s �z SLBDriver.ex_delete_certificatec C s( d| j ||d�}| j�| j|�}|�� S )a% Set server certificate name. :param certificate_id: the id of the server certificate to update :type certificate_id: ``str`` :param name: the new name :type name: ``str`` :return: whether updating is success :rtype: ``bool`` ZSetServerCertificateName)rH r ri r� r� )r* rh rq rE r� r# r# r$ �ex_set_certificate_name� s �z!SLBDriver.ex_set_certificate_namec s" d}� fdd�t ||� jd�D �S )NzLoadBalancers/LoadBalancerc s g | ]}� � |��qS r# )r� r� r5 r# r$ r� � s �z+SLBDriver._to_balancers.<locals>.<listcomp>��elementr r� )r r� )r* r� r r# r5 r$ r� � s ��zSLBDriver._to_balancersc C sx t |d| jd�}t |d| jd�}t |d| jd�}t�|tj�}t |d| jd�}| �|td �}t||||d | |d�}|S )Nr~ r� r� ZLoadBalancerStatusZAddressr )r1 rq �stater� r. Zdriverr) ) r r� �STATE_MAPPINGSr- r �UNKNOWN�_get_extra_dict� RESOURCE_EXTRA_ATTRIBUTES_MAPr ) r* r� �_idrq �statusr� �addressr) r r# r# r$ r� � s( ����� �zSLBDriver._to_balancerc C s6 t |t�r|g}t|�D ]\}}||||d < q|S )z' return parameter list r� )r �str� enumerate)r* rE �items�label�index�itemr# r# r$ �_create_list_params� s z SLBDriver._create_list_paramsc C sp i }|� � D ]^\}}|d }t||d | jd�}|rbz||�||< W qj ty^ d||< Y qj0 q |||< q |S )am Extract attributes from the element based on rules provided in the mapping dictionary. :param element: Element to parse the values from. :type element: xml.etree.ElementTree.Element. :param mapping: Dictionary with the extra layout :type node: :class:`Node` :rtype: ``dict`` r r r� N)r� r r� r� )r* r� �mappingr) r� �valuesr �valuer# r# r$ r� � s � zSLBDriver._get_extra_dictc C sh g }|D ]2}|j dd�}d|jv r0|jd |d< |�|� qz t�|�W S tyb td��Y n0 d S )N�100�r� r� r� z*could not convert member to backend server)r1 r) �append�json�dumpsr� rd )r* r� Zserversr� r3 r# r# r$ r� s � zSLBDriver._to_servers_jsonc s� � � |�}t|d� jd�}t|�dkr:� fdd�|D �}n t|d� jd�}dd� |D �}t|d� jd�}� fd d�|D �}t|||�S ) Nz0ListenerPortsAndProtocol/ListenerPortAndProtocolr� r c s g | ]}� � |��qS r# )�_to_port_and_protocolr� r5 r# r$ r� s �z4SLBDriver._to_balancer_attribute.<locals>.<listcomp>zListenerPorts/ListenerPortc S s g | ]}|j d d��qS )rs �r, �ListenerProtocol)�textr� r# r# r$ r� s �z BackendServers/BackendServerc s g | ]}� � |��qS r# )�_to_server_and_weightr� r5 r# r$ r� # s �)r� r r� r� r% )r* r� r Zport_proto_elementsr' Z port_elementsZserver_elementsr( r# r5 r$ r� s. � ���� �z SLBDriver._to_balancer_attributec C s* t |d| jd�}t |d| jd�}||d�S )Nr, r� r� r� �r r� )r* r� r. r� r# r# r$ r� ' s z SLBDriver._to_port_and_protocolc C s* t |d| jd�}t |d| jd�}||d�S )Nr� r� r� r� r� )r* r� Z server_id�weightr# r# r$ r� , s z SLBDriver._to_server_and_weightc C s> t |d| jd�}t |d| jd�}t |d| jd�}t|||d�S )Nri r� r� Z Fingerprintrp )r r� ro )r* r� r� rq rr r# r# r$ r� 1 s �z SLBDriver._to_server_certificatec C s& z t �|�W S ty Y dS 0 d S )Nz[])r� r� r� )r* r� r# r# r$ r� 8 s zSLBDriver._list_to_json)NN)NNNNNNN),r r r r7 rq Zwebsiter Z connectionClsr� r� �SLB_SCHEDULER_TO_ALGORITHMZ_VALUE_TO_ALGORITHM_MAPr< Z_ALGORITHM_TO_VALUE_MAPr+ r{ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rf r# r# r] r$ r & sR � w) )0�__all__Z simplejsonr� � ImportErrorZlibcloud.common.aliyunr r Zlibcloud.common.typesr Zlibcloud.loadbalancer.typesr Zlibcloud.loadbalancer.baser r r r Zlibcloud.utils.miscr Zlibcloud.utils.py3r Zlibcloud.utils.xmlr r r r r ZDEFAULT_SIGNATURE_VERSIONr� ZRUNNINGZPENDINGr� r� r� ZWEIGHTED_ROUND_ROBINZWEIGHTED_LEAST_CONNECTIONSr� r< r r� r% r8 rP rg rj rn ro ry r r# r# r# r$ �<module> s� � �����������'�� )%* �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка