File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/__pycache__/libcloudfuncs.cpython-310.pyc
Back
o ;jI/ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl m Z m Z z7ddl Z ddl mZmZ ddlmZ ddlmZmZ dZedd � e j�d d ��d d ��d �dd � D ��ZW n eyj dZdZY nw e� e �Z dZ e dfdd�Z dd� Z!d1dd�Z"d1dd�Z#d1dd�Z$dd � Z%d d � Z&d d � Z'd!d"� Z(d1d#d$�Z)d2d%d&�Z*d1d'd(�Z+d1d)d*�Z,d1d+d,�Z-d2d-d.�Z.d/d0� Z/dS )3zd The generic libcloud template used to create the connections and deploy the cloud virtual machines � N)�SaltCloudNotFound�SaltCloudSystemExit)�MultiStepDeployment�ScriptDeployment)� get_driver)� NodeState�ProviderTc c s � | ]}t |�V qd S �N)�int)�.0�part� r �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/libcloudfuncs.py� <genexpr> s � � �r �-�.�rc� F)i� )� � r c C sl t sdS t| ttf�std��t| krtjS d�tjd� dd� | D ���}|r.|d|� �7 }|d7 }t |��) z- Compare different libcloud versions Fz<'reqver' needs to passed as a tuple or list, i.e., (1, 5, 0)zBYour version of libcloud is {}. salt-cloud requires >= libcloud {}r c S s g | ]}t |��qS r )�str)r �numr r r � <listcomp>< s z*check_libcloud_version.<locals>.<listcomp>z for z. Please upgrade.) � HAS_LIBCLOUD� isinstance�list�tuple� RuntimeError�LIBCLOUD_VERSION_INFO�libcloud� __version__�format�join� ImportError)Zreqver�whyZerrormsgr r r �check_libcloud_version+ s ���r% c C sD | � � }|D ]}|j|kr td tjj�|j�tt � | S qdS )z1 Return a libcloud node for the named VM �cloud.cache_nodeN) � list_nodes�name� __utils__�salt�utils�dataZsimple_types_filter�__dict__�__active_provider_name__�__opts__)�connr( �nodes�noder r r �get_nodeE s ���r3 c C s~ |dkrt d��| s t� } | �� }i }|D ]'}t|j�}i ||< t|�D ]}|�d�s/|dkr0q$t||�}||| |< q$q|S )zb Return a dict of all available VM locations on the cloud provider with relevant data �actionzfThe avail_locations function must be called with -f or --function, or with the --list-locations option�_�driver)r �get_conn�list_locationsr r( �dir� startswith�getattr)r0 �call� locations�ret�img�img_name�attr� attr_valuer r r �avail_locationsT s$ � �rC c C s~ |dkrt d��| s t� } | �� }i }|D ]'}t|j�}i ||< t|�D ]}|�d�s/|dv r0q$t||�}||| |< q$q|S )�_ Return a dict of all available VM images on the cloud provider with relevant data r4 z`The avail_images function must be called with -f or --function, or with the --list-images optionr5 �r6 Zget_uuid)r r7 � list_imagesr r( r9 r: r; )r0 r< �imagesr> r? r@ rA rB r r r � avail_imagesr s$ � �rH c C s� |dkrt d��| s t� } | �� }i }|D ]3}t|j�}i ||< t|�D ]#}|�d�s/|dv r0q$zt||�}W n ty@ Y nw ||| |< q$q|S )rD r4 z^The avail_sizes function must be called with -f or --function, or with the --list-sizes optionr5 rE ) r r7 � list_sizesr r( r9 r: r; � Exception)r0 r< �sizesr> �sizeZ size_namerA rB r r r � avail_sizes� s, � �� rM c C �^ | � � }tj�d|t�}|D ]}t|j�}t|j�}|r&|||fv r&| S qtd|� d���)z+ Return the location object to use �locationzThe specified location, '�', could not be found.) r8 r* �config�get_cloud_config_valuer/ r �idr( r )r0 �vm_r= Z vm_locationr? �img_idr@ r r r � get_location� s � �rV c C rN )z( Return the image object to use �imagezThe specified image, 'rP ) rF r* rQ rR r/ r rS r( r )r0 rT rG Zvm_imager? rU r@ r r r � get_image� s �rX c C sf | � � }tj�d|t�}|s|d S |D ]}|r*t|�t|j�t|j�fv r*| S qtd|� d���)z% Return the VM's size object rL r zThe specified size, 'rP ) rI r* rQ rR r/ r rS r( r )r0 rT rK Zvm_sizerL r r r �get_size� s ��rY c C s: t tjj�tj�d| t�| ttjj�tjj� t| ����S )z- Return the script deployment object �os) r r* r+ �cloudZ os_scriptrQ rR r/ Zsalt_config_to_yaml� minion_config)rT r r r �script� s ���r] c C sL |dkrt d��td ddd| � d�d| itd td d � |s#t� }t|| �}t� d }|d u r7t�d| � d }d|jv rLd|jd v rL|jd d }d}|r`||v r`d|| v r`|| d }|r�t� d| � t j j }d� td �d�d d� �}|�t j �tj� |d��� t jj|d��} | �| d�} W d � n1 s�w Y t� d| |� t� d| � |�|�} | �r t� d | � td dd d| � d �d| itd td d � td d u �rt|t�d!d"��} | r�t jj�| d# � t|t�d!d$��} | �rt jj�| d# � t�d%d�d u �r td& | t �d'�d# t� d S t�d(| � dS ))z Delete a single VM �functionzEThe destroy action must be called with -d, --destroy, -a or --action.�cloud.fire_event�eventzdestroying instance� salt/cloud/z /destroyingr( �sock_dir� transport��argsrb rc �profilesN�Unable to find the VM %s�metadata�profileF�flush_mine_on_destroyzClearing Salt Mine: %s�/Z conf_file���Zminion)Zmoptsz mine.flushzClearing Salt Mine: %s, %szDestroying VM: %szDestroyed VM: %szdestroyed instancez /destroyedZdelete_sshkeysTZ ssh_interface� public_ipsr � private_ipsZupdate_cachedirz cloud.delete_minion_cachedir�:zFailed to Destroy VM: %s) r r) r/ r7 r3 Zget_configured_provider�log�error�extra�infor* rQ ZDEFAULT_MINION_OPTSr" �split�updater\ rZ �path�clientZget_local_client�cmdZ destroy_noder; �getr+ r[ Z remove_sshkeyr. )r( r0 r< r2 rf ri rj Zmopts_Z conf_pathrw Zminionsr> rm rn r r r �destroy� sv � � � �� rz c C s� |st � }t|| �}|du rt�d| � t�d| � |�|�}|rBt�d| � td d| � d�d| � d �d | itd td d � dS t�d| � dS )z Reboot a single VM Nrg zRebooting VM: %szRebooted VM: %sr_ r` z has been rebootedra z /rebootingr( rb rc rd TzFailed to reboot VM: %sF)r7 r3 rp rq rs Z reboot_noder) r/ )r( r0 r2 r> r r r �reboot@ s( � r{ c C sd |dkrt d��| s t� } | �� }i }|D ]}|j|j|j|j|j|jt |j �� � d�||j< q|S )z; Return a list of the VMs that are on the provider r4 z=The list_nodes function must be called with -f or --function.)rS rW r( rn rm rL �state) r r7 r' rS rW r( rn rm rL r r| �upper)r0 r< r1 r> r2 r r r r' ] s$ � � r' c C s� |dkrt d��| s t� } | �� }i }|D ]!}i }t|j|j�� �D ]\}}|||< q"|||j< ||j d= qtd |t� d�d t � |S )zL Return a list of the VMs that are on the provider, with all fields r4 zBThe list_nodes_full function must be called with -f or --function.r6 zcloud.cache_node_listro r ) r r7 r' �zipr- �valuesr( r) r. rt r/ )r0 r< r1 r> r2 �pairs�key�valuer r r �list_nodes_fullx s$ � �r� c C s& | st � } tjj�t| d�td |�S )zO Return a list of the VMs that are on the provider, with select fields r^ zquery.selection)r7 r* r+ r[ �list_nodes_selectr� r/ )r0 r< r r r r� � s �r� c C s2 |dkrt d��t� }td || tt� || S )zC Show the details from the provider concerning an instance r4 z<The show_instance action must be called with -a or --action.r& )r r� r) r. r/ )r( r< r1 r r r � show_instance� s �r� c C s |t | �v rdS t�d|� dS )zF Find if the provided connection object has a specific method Tz Method '%s' not yet supported!F)r9 rp rq )r0 � method_namer r r �conn_has_method� s r� )NNr )0�__doc__�loggingrZ Z salt.clientr* Z salt.configZsalt.utils.cloudZsalt.utils.dataZsalt.utils.eventZsalt.exceptionsr r r Zlibcloud.compute.deploymentr r Zlibcloud.compute.providersr Zlibcloud.compute.typesr r r r r �replacert r r# � getLogger�__name__rp ZLIBCLOUD_MINIMAL_VERSIONr% r3 rC rH rM rV rX rY r] rz r{ r' r� r� r� r� r r r r �<module> sV � � � ! L
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings