File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/__pycache__/libvirt.cpython-310.pyc
Back
o ;j_ � @ sn d Z ddlZddlZddlZddlmZ ddlmZ ddlZ ddl m Z m Z m Z mZ zddlZddlmZ dZW n eyC dZY nw dddd d d d d �Zd ZdZe�e�Zdd� Zerdejedd� dd� Zdd� Z dd� Z dd� Z d8dd�Z d8d d �Z d8d d �Z!d d!� Z"d"d#� Z#d9d$d%�Z$d&d'� Z%d(d)� Z&d8d*d+�Z'd,d-� Z(d.d/� Z)d0d1� Z*d2d3� Z+d4d5� Z,d6d7� Z-dS ):a Libvirt Cloud Module ==================== Example provider: .. code-block:: yaml # A provider maps to a libvirt instance my-libvirt-config: driver: libvirt # url: "qemu+ssh://user@remotekvm/system?socket=/var/run/libvirt/libvirt-sock" url: qemu:///system Example profile: .. code-block:: yaml base-itest: # points back at provider configuration e.g. the libvirt daemon to talk to provider: my-libvirt-config base_domain: base-image # ip_source = [ ip-learning | qemu-agent ] ip_source: ip-learning # clone_strategy = [ quick | full ] clone_strategy: quick ssh_username: vagrant # has_ssh_agent: True password: vagrant # if /tmp is mounted noexec do workaround deploy_command: sh /tmp/.saltcloud/deploy.sh # -F makes the bootstrap script overwrite existing config # which make reprovisioning a box work script_args: -F grains: sushi: more tasty # point at the another master at another port minion: master: 192.168.16.1 master_port: 5506 Tested on: - Fedora 26 (libvirt 3.2.1, qemu 2.9.1) - Fedora 25 (libvirt 1.3.3.2, qemu 2.6.1) - Fedora 23 (libvirt 1.2.18, qemu 2.4.1) - Centos 7 (libvirt 1.2.17, qemu 1.5.3) � N)� ElementTree)�SaltCloudConfigError�SaltCloudExecutionFailure�SaltCloudNotFound�SaltCloudSystemExit)� libvirtErrorTFZrunningZpaused�shutdownZcrashed)r � � � � � � zn<filterref filter='clean-traffic'> <parameter name='CTRL_IP_LEARNING' value='any'/> </filterref>�libvirtc C s t �d|� dS )z> Redirect stderr prints from libvirt to salt logging. zlibvirt error %sN)�log�debug)�ctx�error� r �M/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/libvirt.py�libvirt_error_handlerg s r )�fr c C s t sdS t� du r dS tS )a� This function determines whether or not to make this cloud module available upon execution. Most often, it uses get_configured_provider() to determine if the necessary configuration has been set up. It may also check for necessary imports decide whether to load the module. In most cases, it will return a True or False value. If the name of the driver used does not match the filename, then that name should be returned instead of True. @return True|False|str )Fz2Unable to locate or import python libvirt library.F)Fz)The 'libvirt' provider is not configured.)� HAS_LIBVIRT�get_configured_provider�__virtualname__r r r r � __virtual__r s r c C s" zt �� W S ty t Y S w �N)Z__active_provider_name__�value�AttributeErrorr r r r �_get_active_provider_name� s �r c C s t �tt� ptd�S )z/ Return the first configured instance. )�url)�configZis_provider_configured�__opts__r r r r r r r � s �r c C s4 zt �| �}W |S ty td�td | ���w )NzFSorry, {} failed to open a connection to the hypervisor software at {}Zfqdn)r �open� Exceptionr �formatZ __grains__)r �connr r r � __get_conn� s � ��r' c C s� | dkrt d��t�di �}i }dd� dd� |�� D �D �}|D ],}t|d �}|�� }|D ] }|�� ddt|�� d g t |t j �d �}|||� � < q.q |S ) z� Return a list of the VMs id (str) image (str) size (str) state (str) private_ips (list) public_ips (list) �actionz=The list_nodes function must be called with -f or --function.� providersc S � g | ]}|r|�qS r r ��.0Z_fr r r � <listcomp>� � ��z list_nodes.<locals>.<listcomp>c S � g | ]}|� d ��qS �r ��get�r, Zcfgr r r r- � � r � r )�idZimage�size�stateZ private_ipsZ public_ips) r r" r2 �valuesr' ZlistAllDomainsZ UUIDString�VIRT_STATE_NAME_MAPr8 �get_domain_ipsr �(VIR_DOMAIN_INTERFACE_ADDRESSES_SRC_LEASE�name) �callr) �ret�providers_to_check�providerr& Zdomains�domain�datar r r � list_nodes� s2 � � �� �rD c C s | dkrt d��t| �S )zi Because this module is not specific to any cloud providers, there will be no nodes to list. r( zBThe list_nodes_full function must be called with -f or --function.)r rD )r> r r r �list_nodes_full� s �rE c C s: | dkrt d��t�d�}|st d��tjj�t� || �S )zO Return a list of the VMs that are on the provider, with select fields r( zDThe list_nodes_select function must be called with -f or --function.zquery.selectionz,query.selection not found in /etc/salt/cloud)r r" r2 �salt�utils�cloud�list_nodes_selectrE )r> Z selectionr r r rI � s � �rI c C s | t jkrdS | t jkrdS d S )N�ipv4Zipv6)r ZVIR_IP_ADDR_TYPE_IPV4ZVIR_IP_ADDR_TYPE_IPV6)Z addr_typer r r �to_ip_addr_type� s �rK c C s� g }| � d�}|d tjkr|S z| �|d�}W n tjy3 } zt�d|� |W Y d }~S d }~ww |�� D ]&\}}|d r^|d D ]}t|d �} t�d|� | dkr]|� |d � qDq8|S )Nr z Exception polling address %s�addrs�typezFound address %srJ �addr) r8 r ZVIR_DOMAIN_RUNNINGZinterfaceAddressesr r �info�itemsrK �append) rB � ip_source�ipsr8 � addressesr r= �valrN �tpr r r r; � s( �� �r; c C s8 t | |�}|rdd� |D �}|rt|�|krd S || S )Nc S s g | ] }|� d �s|�qS )z127.)� startswith)r, �ipr r r r- s z!get_domain_ip.<locals>.<listcomp>)r; �len)rB �idxrR Z skip_loopbackrS r r r � get_domain_ip s r[ c ! C s� | � d�pd}|dvrtd�|���| � d�pd}|dvr$td�|���| � d �d ur0| � d �nd }t�d | d ||� z| d rRt�tt� pHd| d �du rRW dS W n t y\ Y nw | d }t d ddd|� d�t d d| g d��td td d� tj d | tdd d �}|d ur�t j �|�s�td |� d ���|| d < || d < g }�z | d! }t| d" �}z|�|�} W �n� t�yX } �z�|�|�} | �d#�} ||d$�} t d dd%d|� d&�d't d d(| t| ��itd td d� t�d)| � t�| �}||�d*�_|�d+�d u �rt�d,�}|�d#|� |�d+�}d-|� �|_|� |�d.�� |� d/�D ] }|� |�d0�� |dk�rI|�d1�d u �rI|� t�t �� �q*|� d2�D ]7}|�d3�d u�r�|�d4�}|�r�d5|j v �r�|j d5 }|�!d6|� d7�d6|� d7��}t�d8|� ||j d5< �qP|� d9�D ]�}|�d:�}|d u �r�t"d;��|j � d<�}t�d=|j � |d>k�r�|�d?�j d@ }t#||�\}}|dAk�r�|�$t%|�d#�} n |�&t'|�|d#�} |� dB| dC�� | � � |�d?�j d@< �q�|dDk�r|�d?�j d@ }t#||�\}}|�&t'|�|d#�} |� dB| dC�� | � � |�d?�j d@< �q�t"dE|� dF���t(j)j*�+t�,|��} t�dG| � |�r8t-j.nd#} |�/| | �} |� dH| dC�� | �0t-j1� W Y d } ~ nd } ~ ww t�dI| � |dJk�rht-j2}n|dk�rpt-j3}t(j)j4j5t6| d#|ftj dK| tdLdM�tj dN| tdOdM�tj dP| tdQdM�dR�} t�dS| � | | dT< t dU | t�} t d ddVd|� dW�t d dX| g d��td td d� | W S t7�y� t8|� � w )Yz$ Provision a single machine �clone_strategy�full)�quickr] z7'clone_strategy' must be one of quick or full. Got '{}'rR � ip-learning)r_ � qemu-agentz>'ip_source' must be one of qemu-agent or ip-learning. Got '{}'� validate_xmlNTz1Cloning '%s' with strategy '%s' validate_xml='%s'r= �profiler F�cloud.fire_event�eventzstarting create� salt/cloud/z /creatingzcloud.filter_eventZcreating)r= rb rA �driver�sock_dir� transport��argsrg rh Z private_key)Z search_global�defaultzThe defined key_filename 'z' does not exist� key_filename� base_domainr r )r= rm zrequesting instancez /requesting�kwargsZ requestingzSource machine XML '%s'z./namez ./description� descriptionz Cloned from z./uuidz./devices/interfacez./macz/./filterref/parameter[@name='CTRL_IP_LEARNING']z ./devices/channel[@type='unix']z8./target[@type='virtio'][@name='org.qemu.guest_agent.0']z./source[@mode='bind']�pathz/domain-�/z!Rewriting agent socket path to %s�,./devices/disk[@device='disk'][@type='file']z./driver[@name='qemu']z-Non qemu driver disk encountered bailing out.rM zdisk attributes %sZqcow2�./source�filer^ �volume)�what�item�rawz Disk type 'z' not supportedzClone XML '%s'rB zVM '%s'r` Zwait_for_ip_timeoutiX )rk Zwait_for_ip_interval� Z wait_for_ip_interval_multiplierr )Z update_args�timeout�intervalZinterval_multiplierz Address = %sZssh_hostzcloud.bootstrapzcreated instancez/created�created)9r2 r r% r rO r! Zis_profile_configuredr" r r � __utils__Zget_cloud_config_value�osrp �isfiler r' � lookupByNamer �XMLDesc�listr r � fromstring�find�textZElement�insert�remove�findallrQ �IP_LEARNING_XML�attrib�replacer �find_pool_and_volumeZ createXML�$create_volume_with_backing_store_xmlZ createXMLFrom�create_volume_xmlrF rG � stringutils�to_str�tostringr ZVIR_DOMAIN_DEFINE_VALIDATEZdefineXMLFlagsZcreateWithFlagsZVIR_DOMAIN_START_FORCE_BOOTZ(VIR_DOMAIN_INTERFACE_ADDRESSES_SRC_AGENTr< rH Z wait_for_ipr[ r$ � do_cleanup)!Zvm_r\ rR ra r= rl �cleanup�baser& Z clone_domain�erB �xmlrn Z domain_xmlZdescription_elemro Z iface_xmlZ agent_xmlZsource_elementrp �new_path�diskrf Z disk_type�source�poolru Z new_volumeZ clone_xmlZvalidate_flags�addressr? r r r �create sv ���������� � �� � � � ��� ����� �� � � � � � �� x ���� �� �r� c C s� t �d� | D ]n}|d }|d }|dkrXt �d||�� � z|�� t �d||�� � W n ty6 Y nw z|�tjtj tj � t �d||�� � W n tyW Y nw |dkruz|� � t �d ||�� � W q tyt Y qw qd S ) aK Clean up clone domain leftovers as much as possible. Extra robust clean up in order to deal with some small changes in libvirt behavior over time. Passed in volumes and domains are deleted, any errors are ignored. Used when cloning/provisioning a domain fails. :param cleanup: list containing dictionaries with two keys: 'what' and 'item'. If 'what' is domain the 'item' is a libvirt domain object. If 'what' is volume then the item is a libvirt volume object. Returns: none .. versionadded:: 2017.7.3 zCleaning up after exceptionrv rw rB zCleaning up %s %sz%s %s forced offz%s %s undefinedru z%s %s cleaned upN) r rO r= �destroyr r � undefineFlagsr � VIR_DOMAIN_UNDEFINE_MANAGED_SAVE�&VIR_DOMAIN_UNDEFINE_SNAPSHOTS_METADATA�VIR_DOMAIN_UNDEFINE_NVRAM�delete)r� �leftoverrv rw r r r r� sB ���� � ���r� c C s8 t �d| � |dkrtd��g }t�di �}dd� dd� |�� D �D �}|D ](}t|d �}t �d |d � z|�| �}|�||d �� W q& t yN Y q&w |sV| � d �S t |�d kra| � d �S t d ddd| � d�d| itd td d� t |d d |d d � t d ddd| � d�d| itd td d� d S ) a& This function irreversibly destroys a virtual machine on the cloud provider. Before doing so, it should fire an event on the Salt event bus. The tag for this event is `salt/cloud/<vm name>/destroying`. Once the virtual machine has been destroyed, another event is fired. The tag for that event is `salt/cloud/<vm name>/destroyed`. Dependencies: list_nodes @param name: @type name: str @param call: @type call: @return: True if all went well, otherwise an error message @rtype: bool|str z Attempting to delete instance %s�functionzEThe destroy action must be called with -d, --destroy, -a or --action.r) c S r* r r r+ r r r r- ] r. zdestroy.<locals>.<listcomp>c S r/ r0 r1 r3 r r r r- ^ r4 r z looking at %s)rB r& z# doesn't exist and can't be deletedr z1 doesn't identify a unique machine leaving thingsrc rd zdestroying instancere z /destroyingr= rg rh ri r r& rB zdestroyed instancez /destroyedN) r rO r r" r2 r9 r' r� rQ r rY r} �destroy_domain)r= r> �foundr) r@ rA r& rB r r r r� @ sP � � � � �r� c C s� t �d|�� � z|�� W n ty Y nw t| |�}|D ]}t �d|�� � |�� q t �d|�� � |�t j t j t j � d S )NzDestroying domain %szRemoving volume %szUndefining domain %s) r rO r= r� r �get_domain_volumesr r� r� r r� r� r� )r& rB �volumesru r r r r� � s$ � ���r� c C �~ d}t �|�}t| �� �|�d�_t�dt| �� t | � � d �|�d�_| � � |�d�_t j j�t �|��}t�d|� |S )Nan <volume> <name>n</name> <capacity>c</capacity> <allocation>0</allocation> <target> <path>p</path> <format type='qcow2'/> <compat>1.1</compat> </target> </volume> r= z Volume: %sr �capacityz ./target/path� Creating %s�r r� �generate_new_namer= r� r� r r �dir�strrO rp rF rG r� r� r� �ru �templateZ volume_xmlZ xml_stringr r r r� � s r� c C r� )Na� <volume> <name>n</name> <capacity>c</capacity> <allocation>0</allocation> <target> <format type='qcow2'/> <compat>1.1</compat> </target> <backingStore> <format type='qcow2'/> <path>p</path> </backingStore> </volume> r= z volume: %sr r� z./backingStore/pathr� r� r� r r r r� � s r� c C sH | � d�D ]}|�� D ]}|�� |kr||f S q qtd|� ���)Nr z Could not find volume for path )ZlistAllStoragePoolsZlistAllVolumesrp r )r& rp �sp�vr r r r� � s ��r� c C sB d| vr | � dt �� � �S | �dd�\}}|� dt �� � d|� �S )N�.�-r )�uuidZuuid1�rsplit)Z orig_namer= �extr r r r� � s r� c C s� g }t �|�d��}|�d�D ]/}|�d�d ur>|�d�jd }zt| |�\}}|�|� W q ty= t � d|� Y qw q|S )Nr rr z%./driver[@name='qemu'][@type='qcow2']rs rt zDisk not found '%s') r r� r� r� r� r� r� rQ r r �warning)r& rB r� r� r� r� r� ru r r r r� � s ��r� r )T).�__doc__�loggingr~ r� Z xml.etreer Z salt.configr! Zsalt.utils.cloudrF Zsalt.exceptionsr r r r r r r � ImportErrorr: r� r � getLogger�__name__r r ZregisterErrorHandlerr r r r' rD rE rI rK r; r[ r� r� r� r� r� r� r� r� r� r r r r �<module> sb 7 �� + y -D
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings