golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
171 B
Del
OK
aliyun.cpython-310.pyc
19.81 KB
Del
OK
azurearm.cpython-310.pyc
39.67 KB
Del
OK
clc.cpython-310.pyc
8.91 KB
Del
OK
cloudstack.cpython-310.pyc
10.87 KB
Del
OK
digitalocean.cpython-310.pyc
27.39 KB
Del
OK
dimensiondata.cpython-310.pyc
12.62 KB
Del
OK
ec2.cpython-310.pyc
92.28 KB
Del
OK
gce.cpython-310.pyc
48.78 KB
Del
OK
gogrid.cpython-310.pyc
11.07 KB
Del
OK
hetzner.cpython-310.pyc
11.82 KB
Del
OK
joyent.cpython-310.pyc
22.78 KB
Del
OK
libvirt.cpython-310.pyc
16.69 KB
Del
OK
linode.cpython-310.pyc
59.17 KB
Del
OK
lxc.cpython-310.pyc
10.9 KB
Del
OK
msazure.cpython-310.pyc
71.44 KB
Del
OK
oneandone.cpython-310.pyc
18.39 KB
Del
OK
opennebula.cpython-310.pyc
90.2 KB
Del
OK
openstack.cpython-310.pyc
23.53 KB
Del
OK
packet.cpython-310.pyc
12.06 KB
Del
OK
parallels.cpython-310.pyc
11.89 KB
Del
OK
profitbricks.cpython-310.pyc
25.34 KB
Del
OK
proxmox.cpython-310.pyc
27.25 KB
Del
OK
pyrax.cpython-310.pyc
2.59 KB
Del
OK
qingcloud.cpython-310.pyc
16.64 KB
Del
OK
saltify.cpython-310.pyc
11.91 KB
Del
OK
scaleway.cpython-310.pyc
9.36 KB
Del
OK
softlayer.cpython-310.pyc
13.26 KB
Del
OK
softlayer_hw.cpython-310.pyc
13.5 KB
Del
OK
tencentcloud.cpython-310.pyc
20.55 KB
Del
OK
vagrant.cpython-310.pyc
8.32 KB
Del
OK
virtualbox.cpython-310.pyc
9.57 KB
Del
OK
vmware.cpython-310.pyc
94.14 KB
Del
OK
vultrpy.cpython-310.pyc
12.8 KB
Del
OK
xen.cpython-310.pyc
25.66 KB
Del
OK
Edit: libvirt.cpython-310.pyc
o �xe�_ � @ 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 Z 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 rZ 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�|�t d d| g d��td td d� tj d| tdd d �}|d ur�t j �|�s�td �|���|| d < || d< g }�z| d }t| d �}z|�|�} W �n� t�yR } �z�|�|�} | �d!�} ||d"�} t d dd#d$�|�d%t d d&| t| ��itd td d� t�d'| � t�| �}||�d(�_|�d)�d u �rt�d*�}|�d!|� |�d)�}d+�|�|_|� |�d,�� |� d-�D ] }|� |�d.�� |dk�rF|�d/�d u �rF|� t�t �� �q'|� d0�D ]5}|�d1�d u�r�|�d2�}|�r�d3|j v �r�|j d3 }|�!d4�|�d4�|��}t�d5|� ||j d3< �qM|� d6�D ]�}|�d7�}|d u �r�t"d8��|j � d9�}t�d:|j � |d;k�r�|�d<�j d= }t#||�\}}|d>k�r�|�$t%|�d!�} n |�&t'|�|d!�} |� d?| d@�� | � � |�d<�j d=< �q�|dAk�r|�d<�j d= }t#||�\}}|�&t'|�|d!�} |� d?| d@�� | � � |�d<�j d=< �q�t"dB�|���t(j)j*�+t�,|��} t�dC| � |�r2t-j.nd!} |�/| | �} |� dD| d@�� | �0t-j1� W Y d } ~ nd } ~ ww t�dE| � |dFk�rbt-j2}n|dk�rjt-j3}t(j)j4j5t6| d!|ftj dG| tdHdI�tj dJ| tdKdI�tj dL| tdMdI�dN�} t�dO| � | | dP< t dQ | t�} t d ddRdS�|�t d dT| g d��td td d� | W S t7�y� t8|� � w )Uz$ 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 createzsalt/cloud/{}/creatingzcloud.filter_eventZcreating)r= ra rA �driver�sock_dir� transport��argsre rf Z private_key)Z search_global�defaultz,The defined key_filename '{}' does not exist� key_filename� base_domainr r )r= rk zrequesting instancezsalt/cloud/{}/requesting�kwargsZ requestingzSource machine XML '%s'z./namez ./description� descriptionzCloned 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 '{}' not supportedzClone XML '%s'rB zVM '%s'r_ Zwait_for_ip_timeoutiX )ri Zwait_for_ip_interval� Z wait_for_ip_interval_multiplierr )Z update_args�timeout�intervalZinterval_multiplierz Address = %sZssh_hostzcloud.bootstrapzcreated instancezsalt/cloud/{}/createdZcreated)9r2 r r% r rO r! Zis_profile_configuredr" r r � __utils__Zget_cloud_config_value�osrn �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_iprZ r$ � do_cleanup)!Zvm_r[ rR r` r= rj �cleanup�baser& Z clone_domain�erB �xmlrl Z domain_xmlZdescription_elemrm Z iface_xmlZ agent_xmlZsource_elementrn �new_path�diskrd Z disk_type�source�poolrr Z new_volumeZ clone_xmlZvalidate_flags�addressr? r r r �create sz ���������� � �� �� � ��� ����� � �� � � � �� �� z ���� �� �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 exceptionrs rt rB zCleaning up %s %sz%s %s forced offz%s %s undefinedrr 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� �leftoverrs rt r r r r� sB ���� � ���r� c C s4 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 |sVd � | �S t |�d krad � | �S t d ddd� | �d| itd td d� t |d d |d d � t d ddd� | �d| itd td d� dS ) 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 z3{} doesn't identify a unique machine leaving thingsrb rc zdestroying instancezsalt/cloud/{}/destroyingr= re rf rg r r& rB zdestroyed instancezsalt/cloud/{}/destroyedN)r rO r r" r2 r9 r' r| rQ r r% rX ry �destroy_domain)r= r> �foundr) r@ rA r& rB r r r r� B 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 �volumesrr 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 rn rF rG r� r� r� �rr �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 {})ZlistAllStoragePoolsZlistAllVolumesrn r r% )r& rn �sp�vr r r r� � s ��r� c C s: d| vr d� | t�� �S | �dd�\}}d� |t�� |�S )N�.z{}-{}r z{}-{}.{})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 ro z%./driver[@name='qemu'][@type='qcow2']rp rq zDisk not found '%s') r r r} r� r� r� r� rQ r r �warning)r& rB r� r� r� r� r� rr r r r r� � s ��r� r )T).�__doc__Zloggingrz r� Z xml.etreer Z salt.configr! Zsalt.utils.cloudrF Zsalt.exceptionsr r r r r r r � ImportErrorr: r� r Z getLogger�__name__r r ZregisterErrorHandlerr r r r' rD rE rI rK r; rZ r� r� r� r� r� r� r� r� r� r r r r �<module> sb 7 �� + { -D
Save