Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/cloud/__pycache__/_clustering.cpython-39.pyc
Ðазад
a t�h:T � @ sN d dl Z d dlmZ d dlmZ d dlmZ d dlmZ G dd� dej�ZdS )� N)�exc)� _normalize)�_utils)�utilsc @ sP e Zd Zedd� �ZdMdd�Zdd� Zd d � ZdNd d �ZdOdd�Z dd� Z dPdd�Z dd� Z dd� Z dQdd�Zdd � Zd d � Zd d � ZdRd!d"�Zd#d$� ZdSd%d&�Zd'd(� Zd)d*� ZdTd+d,�Zd-d.� ZdUd/d0�Zd1d2� ZdVd3d4�Zd5d6� Z d7d8� Z dWd9d:�Z d;d<� Z d=d>� Z dXd?d@�Z!dYdAdB�Z"dCdD� Z#dEdF� Z$dZdGdH�Z%d[dIdJ�Z&d\dKdL�Z'dS )]�ClusteringCloudMixinc C s. d| j vr$| jdddd�}|| j d< | j d S )NZ clustering� z1.latest)� min_versionZ max_version)Z _raw_clientsZ_get_versioned_client)�selfZclustering_client� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/cloud/_clustering.py�_clustering_client s � z'ClusteringCloudMixin._clustering_clientNr c C s� | � |�}|d } ||| d�} |d ur.|| d< |d ur>|| d< |d urN|| d< |d ur^|| d< |d urn|| d< | jjdd | id j|d �d �} | jd | d �S )N�id)�desired_capacity�name� profile_id�config�max_size�metadata�min_size�timeout� /clusters�clusterz Error creating cluster {name}�r ��json� error_message��key�data)�get_cluster_profiler �post�format�_get_and_munchify) r r �profiler r r r r r r �bodyr r r r �create_cluster" s* � �z#ClusteringCloudMixin.create_clusterc C sF | � |�}|s t�dj|d���| jjdj|d d�d|idd� d S ) N�Invalid Cluster {cluster}�r z /clusters/{cluster_id}/metadatar �� cluster_idr z Error updating cluster metadatar )� get_clusterr �OpenStackCloudExceptionr! r r )r � name_or_idr r r r r �set_cluster_metadataB s ��z)ClusteringCloudMixin.set_cluster_metadatac C sH z.| j jdj|d�dj|d�d�}| �d|�W S tyB Y d S 0 d S )N�/clusters/{cluster_id}r( z Error fetching cluster {name}r �r r �r �getr! r" � Exception)r r) r r r r �get_cluster_by_idM s �� z&ClusteringCloudMixin.get_cluster_by_idc C s t j| d||d�S )Nr )�cloud�resourcer, �filters�r Z _get_entity�r r, r6 r r r r* W s �z ClusteringCloudMixin.get_clusterFc C s� | � |�}|d u r$t�dj|d���d|i} |d ur<|| d< |d urL|| d< |d ur�| �|�} | d u rxt�dj|d���| j| d< |d ur�|| d < |d ur�|| d < | jjd j|d d �d| idj|d�d�} | jd | d�S )Nr& r' � profile_onlyr r z!Invalid Cluster Profile {profile}�r# r r r r. r r( r z Error updating cluster {name}r r r ) r* r r+ r! r r r �patchr" ) r r, �new_nameZprofile_name_or_idr r r r9 Z old_clusterr r# r r r r �update_cluster\ s@ �� �� ��z#ClusteringCloudMixin.update_clusterc C s� | � |�}|d u r$| j�d|� dS | �|�D ] }| �|d �}| �||� q.| �� D ]&}|d |d krV| j|d dd� qV| jj dj |d �d j |d �d � dS ) Nz!Cluster %s not found for deletingF� policy_idr r) T)�waitr. r( z Error deleting cluster {name}r r/ ) r* �log�debug�list_policies_on_cluster�get_cluster_policy_by_id�detach_policy_from_cluster�list_cluster_receivers�delete_cluster_receiverr �deleter! )r r, r �policyZ detach_policy�receiverr r r �delete_cluster� s& � ��z#ClusteringCloudMixin.delete_clusterc C s | � � }t�|||�S �N)� list_clustersr � _filter_list)r r, r6 �clustersr r r �search_clusters� s z$ClusteringCloudMixin.search_clustersc C sb z | j jddd�}| �d|�W S tjy\ } z$| jjt|�dd� g W Y d }~S d }~0 0 d S )Nr zError fetching clustersr/ rN T��exc_info)r r1 r" r �OpenStackCloudURINotFoundr@ rA �str�r r �er r r rL � s �z"ClusteringCloudMixin.list_clustersc C s� | � |�}| �|�}|d u r.t�dj|d���|d u rHt�dj|d���|d |d�}| jjdj|d d�d j|d |d d �d |id � d S )Nz)Cluster {cluster} not found for attachingr' z'Policy {policy} not found for attaching�rH r �r> �enabled� /clusters/{cluster_id}/actionsr( z4Error attaching policy {policy} to cluster {cluster}�rH r Z policy_attach�r r T�r* �get_cluster_policyr r+ r! r r �r r, �policy_name_or_id� is_enabledr rH r$ r r r �attach_policy_to_cluster� s4 �������z-ClusteringCloudMixin.attach_policy_to_cluster� c C s� | � |�}| �|�}|d u r.t�dj|d���|d u rHt�dj|d���d|d i}| jjdj|d d�d j|d |d d �d |id � |s�d S g }t�|d�D ]"} | � |d �d } | |kr� q�q�d S )Nz)Cluster {cluster} not found for detachingr' z'Policy {policy} not found for detachingrV r> r rY r( z6Error detaching policy {policy} from cluster {cluster}rZ Z policy_detachr[ Tz,Timeout waiting for cluster policy to detach�policies) r* r] r r+ r! r r r �iterate_timeoutr3 ) r r, r_ r? r r rH r$ �value�countZ policy_statusr r r rD � sB ���� ���z/ClusteringCloudMixin.detach_policy_from_clusterc C s� | � |�}| �|�}|d u r.t�dj|d���|d u rHt�dj|d���|d |d�}| jjdj|d d�d j|d |d d �d |id � d S )Nz(Cluster {cluster} not found for updatingr' z&Policy {policy} not found for updatingrV r rW rY r( z3Error updating policy {policy} on cluster {cluster}rZ Z policy_updater[ Tr\ r^ r r r �update_policy_on_cluster� s4 �������z-ClusteringCloudMixin.update_policy_on_clusterc C sJ z0| j jdj||d�dj|d�d�}| �d|�W S tyD Y dS 0 d S )Nz+/clusters/{cluster_id}/policies/{policy_id})r) r> � Error fetching policy {name}r r/ Zcluster_policyFr0 )r r, r_ rH r r r �get_policy_on_cluster s ��� z*ClusteringCloudMixin.get_policy_on_clusterc C sl dj |d�}z| jj|dd�}W n> tjy^ } z$| jjt|�dd� g W Y d }~S d }~0 0 | �d|�S )Nz /clusters/{cluster_id}/policiesr( � Error fetching cluster policiesr/ TrP �cluster_policies) r! r r1 r rR r@ rA rS r" )r r, �endpointr rU r r r rB s �� z-ClusteringCloudMixin.list_policies_on_clusterc C sD ||d�}|d ur||d< | j jdd|idj|d�d�}| �d|�S )N�r �specr � /profilesr# z Error creating profile {name}r r �r r r! r" )r r rn r r# r r r r �create_cluster_profile s � �z+ClusteringCloudMixin.create_cluster_profilec C sF | � |�}|s t�dj|d���| jjdj|d d�d|idd� d S ) N�Invalid Profile {profile}r: z /profiles/{profile_id}/metadatar �r r z Error updating profile metadatar )r r r+ r! r r )r r, r r# r r r � set_cluster_profile_metadata. s ��z1ClusteringCloudMixin.set_cluster_profile_metadatac C s | � � }t�|||�S rK )�list_cluster_profilesr rM )r r, r6 Zcluster_profilesr r r �search_cluster_profiles9 s z,ClusteringCloudMixin.search_cluster_profilesc C s` z| j jddd�}W n> tjyR } z$| jjt|�dd� g W Y d }~S d }~0 0 | �d|�S )Nro zError fetching profilesr/ TrP Zprofiles�r r1 r rR r@ rA rS r" rT r r r ru = s � z*ClusteringCloudMixin.list_cluster_profilesc C sp z.| j jdj|d�dj|d�d�}| �d|�W S tjyj } z"| jjt|�dd� W Y d }~d S d }~0 0 d S ) N�/profiles/{profile_id}rs z Error fetching profile {name}r r/ r# TrP � r r1 r! r" r rR r@ rA rS )r r r rU r r r �get_cluster_profile_by_idG s ��z.ClusteringCloudMixin.get_cluster_profile_by_idc C s t �| d||�S )NZcluster_profiler7 r8 r r r r R s z(ClusteringCloudMixin.get_cluster_profilec C s� | � |�}|d u r$| j�d|� dS | �� D ].}||jf|�� v r,| j�d||j� dS q,| jjdj |d d�dj |d�d � d S ) Nz!Profile %s not found for deletingFz4Profile %s is being used by cluster %s, won't deleterx r rs z Error deleting profile {name}r r/ T) r r@ rA rL r �itemsr r rG r! )r r, r# r r r r �delete_cluster_profileU s$ ���z+ClusteringCloudMixin.delete_cluster_profilec C sz | � |�}|s t�dj|d���i }|d ur4||d< |d urD||d< | jjdj|jd�d|idj|d �d �}| jd |d �S ) Nrr r: r r rx rs r# z Error updating profile {name}r r r )r r r+ r! r r; r r" )r r, r r< Z old_profiler# r r r r �update_cluster_profilei s$ � ��z+ClusteringCloudMixin.update_cluster_profilec C s8 ||d�}| j jdd|idj|d d�d�}| �d|�S )Nrm � /policiesrH z Error creating policy {name}r r r rp )r r rn rH r r r r �create_cluster_policy s ���z*ClusteringCloudMixin.create_cluster_policyc C s | � � }t�|||�S rK )�list_cluster_policiesr rM )r r, r6 rk r r r �search_cluster_policies� s z,ClusteringCloudMixin.search_cluster_policiesc C sd d}z| j j|dd�}W n> tjyV } z$| jjt|�dd� g W Y d }~S d }~0 0 | �d|�S )Nr~ rj r/ TrP rc rw )r rl r rU r r r r� � s � z*ClusteringCloudMixin.list_cluster_policiesc C sp z.| j jdj|d�dj|d�d�}| �d|�W S tjyj } z"| jjt|�dd� W Y d }~d S d }~0 0 d S ) N�/policies/{policy_id}�r> rh r r/ rH TrP ry )r r> r rU r r r rC � s ��z-ClusteringCloudMixin.get_cluster_policy_by_idc C s t �| d||�S )NZcluster_policier7 r8 r r r r] � s �z'ClusteringCloudMixin.get_cluster_policyc C s� | � |�}|d u r$| j�d|� dS | �� D ].}||jf|�� v r,| j�d||j� dS q,| jjdj |d�dj |d�d� d S ) Nz Policy %s not found for deletingFz3Policy %s is being used by cluster %s, won't deleter� r� z Error deleting policy {name}r r/ T) rC r@ rA rL r r{ r r rG r! )r r, rH r r r r �delete_cluster_policy� s$ � ��z*ClusteringCloudMixin.delete_cluster_policyc C s^ | � |�}|s t�dj|d���d|i}| jjdj|jd�d|idj|d�d �}| jd |d �S ) NzInvalid Policy {policy}rV r r� r� rH z Error updating policy {name}r r r )r] r r+ r! r r; r r" )r r, r< Z old_policyrH r r r r �update_cluster_policy� s � ��z*ClusteringCloudMixin.update_cluster_policyc C s� | � |�}|d u r$t�dj|d���||d�}|d ur@|j|d< |d urP||d< |d ur`||d< |d urp||d< | jjdd |id j|d �d �} | �d | �S ) NzInvalid cluster {cluster}r' )r �typer) �action�actor�params� /receiversrI z Error creating receiver {name}r r )r* r r+ r! r r r r" ) r r Z receiver_typeZcluster_name_or_idr� r� r� r rI r r r r �create_cluster_receiver� s* �� �z,ClusteringCloudMixin.create_cluster_receiverc C s | � � }t�|||�S rK )rE r rM )r r, r6 Zcluster_receiversr r r �search_cluster_receivers� s z-ClusteringCloudMixin.search_cluster_receiversc C s` z| j jddd�}W n> tjyR } z$| jjt|�dd� g W Y d }~S d }~0 0 | �d|�S )Nr� zError fetching receiversr/ TrP Z receiversrw rT r r r rE � s � z+ClusteringCloudMixin.list_cluster_receiversc C sp z.| j jdj|d�dj|d�d�}| �d|�W S tjyj } z"| jjt|�dd� W Y d }~d S d }~0 0 d S ) N�/receivers/{receiver_id}�� receiver_idz Error fetching receiver {name}r r/ rI TrP ry )r r� r rU r r r �get_cluster_receiver_by_id� s ��z/ClusteringCloudMixin.get_cluster_receiver_by_idc C s t �| d||�S )NZcluster_receiverr7 r8 r r r �get_cluster_receiver s �z)ClusteringCloudMixin.get_cluster_receiverc C s| | � |�}|d u r$| j�d|� dS |d }| jjdj|d�dj|d�d� |sTd S t�|d �D ]}| �|�}|s` qxq`d S ) Nz"Receiver %s not found for deletingFr r� r� z Error deleting receiver {name}r r/ Tz.Timeout waiting for cluster receiver to delete) r� r@ rA r rG r! r rd r� )r r, r? r rI r� rf r r r rF s( ��� z,ClusteringCloudMixin.delete_cluster_receiverc C s� | � |�}|d u r$t�dj|d���i }|d ur8||d< |d urH||d< |d urX||d< | jjdj|jd�d|id j|d �d �}| jd |d �S ) NzInvalid receiver {receiver})rI r r� r� r� r� rI z Error updating receiver {name}r r r )r� r r+ r! r r; r r" )r r, r< r� r� Z old_receiverrI r r r r �update_cluster_receiver s( � ��z,ClusteringCloudMixin.update_cluster_receiver)Nr NNNN)N)NNNNNF)NN)Frb )N)NN)N)NN)NN)N)NNNN)NN)N)Frb )NNN)(�__name__� __module__� __qualname__�propertyr r% r- r3 r* r= rJ rO rL ra rD rg ri rB rq rt rv ru rz r r| r} r r� r� rC r] r� r� r� r� rE r� r� rF r� r r r r r s` � � ' � ( � �r ) �typesZopenstack.cloudr r r Z openstackr Z Normalizerr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка