File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/__pycache__/slb.cpython-310.pyc
Back
o ;j[t � @ s� d dgZ zddlZW n ey ddlZY nw ddlmZ ddlmZmZm Z ddl m Z ddl m Z ddlmZmZ dd lmZmZmZmZ dd lmZ d Zd Zd Zejej ej d�Z dde d�ded�ded�ded�ded�ded�ded�ded�d�iZ ej!ej"d�Z#ej!dej"d iZ$G d d � d e�Z%G d d � d �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*e*�Z+G d+d,� d,e �Z,e(e)e*e+d-�Z-G d.d� de�Z.dS )/�SLB_API_VERSION� SLBDriver� N)�u)�findall�findattr�findtext)� ReprMixin)� LibcloudError)�AliyunXmlResponse�SignedAliyunConnection)�Driver�Member� Algorithm� LoadBalancer)�Statez 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 responseClsZ service_name� r" r" �U/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/slb.pyr E 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( || _ |pg | _|p g | _|pi | _d S �N)r � listeners�backend_servers�extra)�selfr r& r' r( r" r" r# �__init__U s z!SLBLoadBalancerAttribute.__init__c C s$ | j D ] }|�d�|kr dS qdS )N� ListenerPortTF)r& �get)r) �port�listenerr" r" r# � is_listening[ s �z%SLBLoadBalancerAttribute.is_listeningc C s& | j D ] }|�d�|jkr dS qdS )NZServeridTF)r' r, �id)r) �member�serverr" r" r# � is_attacheda s �z$SLBLoadBalancerAttribute.is_attachedc C s d� | jj| j| j�S )Nz:<SLBLoadBalancerAttribute id={}, ports={}, servers={} ...>)�formatr r0 r& r' �r) r" r" r# �__repr__g s �z!SLBLoadBalancerAttribute.__repr__r% )r r r �__doc__r* r/ r3 r6 r" r" r" r# r$ L 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�| _|| _|pi | _d S )Nr )r- r9 �ALGORITHM_TO_SLB_SCHEDULERr, r: r; r( )r) r- r9 � algorithmr; r( r" r" r# r* x 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_paramsr% ) r r r r7 �_repr_attributesrJ rL r* � classmethodrA rG rB rC r" r" r" r# r8 o s r8 c �L e Zd ZdZdZg d�Z d � 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 CookieTimeoutZCookie�HealthCheckDomain�HealthCheckURI�HealthCheckConnectPort�HealthyThreshold�UnhealthyThresholdZHealthCheckTimeout�HealthCheckInterval�HealthCheckHttpCodeNc s& t � j|||||d� || _|| _d S r> )�superr* �sticky_session� health_check)r) r- r9 r= r; r[ r\ r( �� __class__r" r# r* � s z$SLBLoadBalancerHttpListener.__init__c s" t � �� }| j|d< | j|d< |S )N� StickySession� HealthCheck)rZ rB r[ r\ rK r] r" r# rB � s z/SLBLoadBalancerHttpListener.get_required_paramsc C sF d|vrt d��d|vrt 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.creater% � r r r r7 rJ rL r* rB rO rA � __classcell__r" r" r] r# rQ � s � rQ c rP ) � SLBLoadBalancerHttpsListenerzN This class represents a rule to route https request to the backends. Z CreateLoadBalancerHTTPSListenerrR Nc s, t � j|||||d� || _|| _|| _d S r> )rZ r* r[ r\ �certificate_id) r) r- r9 r= r; r[ r\ rh r( r] r" r# r* � s z%SLBLoadBalancerHttpsListener.__init__c s, t � �� }| j|d< | j|d< | j|d< |S )Nr_ r` �ServerCertificateId)rZ rB r[ r\ rh rK r] r" r# rB � s z0SLBLoadBalancerHttpsListener.get_required_paramsc C s` d|vrt d��d|vrt d��d|vrt 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.creater% re r" r" r] r# rg � s � rg c @ � 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# rk � rk c @ rj )�SLBLoadBalancerUdpListenerzL This class represents a rule to route udp request to the backends. Z CreateLoadBalancerUDPListener)rl rU rV rW rm rX Nrn r" r" r" r# rp . ro rp c @ s e Zd Zg d�Zdd� ZdS )�SLBServerCertificate�r0 �name� fingerprintc C s || _ || _|| _d S r% rr )r) r0 rs rt r" r" r# r* A s z SLBServerCertificate.__init__N)r r r rN r* r" r" r" r# rq > s rq )�http�httpsZtcpZudpc s2 e Zd ZdZdZdZeZdZdZ e Z e Z � fdd�Zdd � Zd@d d �Z dAd 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 � �||� || _d S r% )rZ r* �region)r) Z access_idZsecretrx r] r" r# r* ^ s zSLBDriver.__init__c C s t t�� �S r% )�list�PROTOCOL_TO_LISTENER_MAP�keysr5 r" r" r# �list_protocolsb s zSLBDriver.list_protocolsc C sb d| j d�}|rt|t�rd�|�|d< |r"t|t�r"|�|� |}| 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 ) rx � isinstancery �join�dictrD � connection�request�path�object� _to_balancers)r) �ex_balancer_idsZ ex_filtersrE � resp_bodyr" r" r# �list_balancerse s zSLBDriver.list_balancersc K s� d| j d�}|r ||d< |std��|sd}|tvr td| ��d}|r:zt|�}W n ty5 td��w ||d < |rN|�� d krJ|dkrJtd ��||d < |r^|�� d vrZtd��||d< | rd| |d< | rj| |d< | rp| |d< | rv| |d< |r�t|t�r�dd� |D �}tt |��dkr�td��|d p�|}n|}d}z8| j � | j |�j }| �|�}||_|du r�g }|D ]}| �||� q�| j|||||fi | �� | �||� |W S ty� } z|dur�z| �|� W |� ty� Y |�w |�d}~ww )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 requiredru zunsupported 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- )�.0r1 r" r" r# � <listcomp>� s z-SLBDriver.create_balancer.<locals>.<listcomp>� z%the ports of members should be uniquer N)rx rd rz �int� ValueError�lowerr� ry �len�setr� r� r� r� � _to_balancerr- �balancer_attach_member�ex_create_listener�ex_start_listener� Exception�destroy_balancer)r) rs 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� r1 �er" r" r# �create_balancer� s� / � � �� ����zSLBDriver.create_balancerc C s$ d|j d�}| j�| j|�}|�� S )NZDeleteLoadBalancer�rH r �r0 r� r� r� �success)r) r rE �respr" r" r# r� s zSLBDriver.destroy_balancerc C s. | j |gd�}t|�dkrtd| ��|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 )r0 �ipr- )r� Z public_ipsZ private_ipsr r0 r- r� )r) r �noder� r1 r" r" r# � balancer_attach_compute_node s z&SLBDriver.balancer_attach_compute_nodec C s> d|j d�}|rt|t�r| �|g�|d< | j�| j|� |S )NZAddBackendServersr� �BackendServers)r0 r� r �_to_servers_jsonr� r� r� �r) r r1 rE r" r" r# r� s z SLBDriver.balancer_attach_memberc C s@ d|j d�}|rt|t�r| �|j g�|d< | j�| j|� |S )NZRemoveBackendServersr� r� )r0 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� r2 �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� )r0 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� N s ��z/SLBDriver.ex_list_listeners.<locals>.<listcomp>)r� r& )r) r r� r& r" r" r# �ex_list_listenersB 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 ) rz r, rQ r- rA rG r0 rx r� r� r� r� ) r) r r9 r� r= r; r� r@ r- r. rE r� r" r" r# r� T s z SLBDriver.ex_create_listenerc C �& 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� z � �zSLBDriver.ex_start_listenerc C r� )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_listener� r� 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)rx r� r� r� r� �_to_server_certificate)r) rs Zserver_certificateZ private_keyrE r� r" r" r# �ex_upload_certificate� s � z SLBDriver.ex_upload_certificatec s` d� j d�}|rt|t�rd�|�|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 � g | ]}� � |��qS r" )r� �r� �elr5 r" r# r� � � z2SLBDriver.ex_list_certificates.<locals>.<listcomp>) rx r� ry 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 �rx 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 rs 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 r� 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 )r0 rs �stater� r- Zdriverr( ) r r� �STATE_MAPPINGSr, r �UNKNOWN�_get_extra_dict� RESOURCE_EXTRA_ATTRIBUTES_MAPr ) r) r� �_idrs �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 �itemsZlabel�index�itemr" r" r# �_create_list_params s z SLBDriver._create_list_paramsc C sn i }|� � D ].\}}|d }t||d | jd�}|r0z||�||< W q ty/ d||< Y qw |||< 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 s` g }|D ]}|j dd�}d|jv r|jd |d< |�|� qzt�|�W S ty/ td��w )NZ100�r� r� r� z*could not convert member to backend server)r0 r( �append�json�dumpsr� rd )r) r� Zserversr� r2 r" r" r# r� C s �zSLBDriver._to_servers_jsonc s� � � |�}t|d� jd�}t|�dkr � fdd�|D �}nt|d� jd�}dd� |D �}t|d� jd�}� fd d�|D �}t|||�S ) Nz0ListenerPortsAndProtocol/ListenerPortAndProtocolr� r c r� r" )�_to_port_and_protocolr� r5 r" r# r� W r� z4SLBDriver._to_balancer_attribute.<locals>.<listcomp>zListenerPorts/ListenerPortc S s g | ]}|j d d��qS )ru �r+ �ListenerProtocol)�textr� r" r" r# r� Z s �z BackendServers/BackendServerc r� r" )�_to_server_and_weightr� r5 r" r# r� ^ r� )r� r r� r� r$ )r) r� r Zport_proto_elementsr& Z port_elementsZserver_elementsr' r" r5 r# r� O s � � z SLBDriver._to_balancer_attributec C �* t |d| jd�}t |d| jd�}||d�S )Nr+ r� r� r� �r r� )r) r� r- r� r" r" r# r� a � z SLBDriver._to_port_and_protocolc C r� )Nr� r� r� r� r� )r) r� Z server_idZweightr" r" r# r� f r� z SLBDriver._to_server_and_weightc C s> t |d| jd�}t |d| jd�}t |d| jd�}t|||d�S )Nri r� r� Z Fingerprintrr )r r� rq )r) r� r� rs rt r" r" r# r� k s z SLBDriver._to_server_certificatec C s" zt �|�W S ty Y dS w )Nz[])r� r� r� )r) r� r" r" r# r� q s �zSLBDriver._list_to_json)NN)NNNNNNN),r r r r7 rs 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 O s\ " � & )/�__all__Z simplejsonr� � ImportErrorZlibcloud.utils.py3r Zlibcloud.utils.xmlr r r Zlibcloud.utils.miscr Zlibcloud.common.typesr Zlibcloud.common.aliyunr r Zlibcloud.loadbalancer.baser r r r Zlibcloud.loadbalancer.typesr r r ZDEFAULT_SIGNATURE_VERSIONr� ZRUNNINGZPENDINGr� r� r� ZWEIGHTED_ROUND_ROBINZWEIGHTED_LEAST_CONNECTIONSr� r< r r$ r8 rQ rg rk rp rq rz r r" r" r" r# �<module> sf � �����#,<C �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings