golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
197 B
Del
OK
asam.cpython-310.pyc
7.9 KB
Del
OK
auth.cpython-310.pyc
1.89 KB
Del
OK
bgp.cpython-310.pyc
12.55 KB
Del
OK
cache.cpython-310.pyc
10.98 KB
Del
OK
cloud.cpython-310.pyc
4.16 KB
Del
OK
config.cpython-310.pyc
1.08 KB
Del
OK
ddns.cpython-310.pyc
6.7 KB
Del
OK
digicertapi.cpython-310.pyc
16.23 KB
Del
OK
doc.cpython-310.pyc
1.76 KB
Del
OK
drac.cpython-310.pyc
4.15 KB
Del
OK
error.cpython-310.pyc
771 B
Del
OK
event.cpython-310.pyc
2.32 KB
Del
OK
f5.cpython-310.pyc
8.29 KB
Del
OK
fileserver.cpython-310.pyc
17.12 KB
Del
OK
git_pillar.cpython-310.pyc
3.54 KB
Del
OK
http.cpython-310.pyc
2.55 KB
Del
OK
jobs.cpython-310.pyc
13.26 KB
Del
OK
launchd.cpython-310.pyc
1.49 KB
Del
OK
lxc.cpython-310.pyc
13.3 KB
Del
OK
manage.cpython-310.pyc
21.71 KB
Del
OK
mattermost.cpython-310.pyc
4.21 KB
Del
OK
mine.cpython-310.pyc
1.79 KB
Del
OK
nacl.cpython-310.pyc
8.46 KB
Del
OK
net.cpython-310.pyc
27.7 KB
Del
OK
network.cpython-310.pyc
2.59 KB
Del
OK
pagerduty.cpython-310.pyc
3.96 KB
Del
OK
pillar.cpython-310.pyc
4.25 KB
Del
OK
pkg.cpython-310.pyc
1.37 KB
Del
OK
queue.cpython-310.pyc
8.14 KB
Del
OK
reactor.cpython-310.pyc
4.32 KB
Del
OK
salt.cpython-310.pyc
4.58 KB
Del
OK
saltutil.cpython-310.pyc
15.88 KB
Del
OK
sdb.cpython-310.pyc
2.54 KB
Del
OK
smartos_vmadm.cpython-310.pyc
7.99 KB
Del
OK
spacewalk.cpython-310.pyc
7.54 KB
Del
OK
ssh.cpython-310.pyc
1000 B
Del
OK
state.cpython-310.pyc
8.22 KB
Del
OK
survey.cpython-310.pyc
5.07 KB
Del
OK
test.cpython-310.pyc
2.65 KB
Del
OK
thin.cpython-310.pyc
1.81 KB
Del
OK
vault.cpython-310.pyc
10.01 KB
Del
OK
venafiapi.cpython-310.pyc
5.57 KB
Del
OK
virt.cpython-310.pyc
13.15 KB
Del
OK
vistara.cpython-310.pyc
4.39 KB
Del
OK
winrepo.cpython-310.pyc
5.14 KB
Del
OK
Edit: virt.cpython-310.pyc
o �xeXF � @ s� d Z ddlZddlZddlZddlZddlZddlZddl Zddl m Z e� e �Zd*dd�Zd+dd �Zd,d d �Zd-d d �Zdd� Zd.dd�Z d/dd�Zd+dd�Zd d � Zd d � Zd d!� Zd0d"d#�Zd$d%� Zd&d'� Z d*d(d)�Z dS )1z# Control virtual machines via Salt � N)�SaltClientError� c C sP d}d}| � � D ] \}}||krqt|t�sq|�dd�|kr%|d }|}q|S )zO Determine what the most resource free host is based on the given data r r Zfreemem)�items� isinstance�dict�get)�dataZomit�hostZbestmem�hv_�comps� r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/virt.py�_determine_host s �r Fc C sh |D ]/}t || t�s q| || �di �v r1|| || d | ii}|s-t�|dd�d� | S qi S )z. Scan the query data for the named VM �vm_info�nested�r Z outputter�progress)r r r � __jid_event__� fire_event)�namer �quietr �retr r r �_find_vm& s ��r c C s( |rt �d� i }tj�td ��y}zX|jdddd�D ]M}|s qt|t�s&qi }t t |� � ��}| r7| |kr7qt|| t�s?qd|| vrFqt|| d t�sPq|| d ||< |� |� |sht �|dd �d � qW n ty� } z t|� W Y d }~nd }~ww |W d � S 1 s�w Y d S ) z� Query the virtual machines. When called without options all hosts are detected and a full query is returned. A single host can be passed in to specify an individual host to query. �0'quiet' is deprecated. Please migrate to --quiet� conf_file�virtual:physicalzvirt.full_info�grain�Ztgt_typer Z virt_queryr r N)�log�warning�salt�client�get_local_client�__opts__�cmd_iterr r �next�iter�keys�updater r r �print)r r r r! �info�chunk�id_� client_errorr r r �query8 sJ � �����$�r. c C s: |rt �d� i }tj�td ���}|jdddd�D ]o}|s qt|t�s%qi }t t |� � ��}| r6| |kr6qt|| t�s>qd|| vrEqt|| d t�sOqi }|| d � � D ]\} } | d |v rm|| d � | � qY| g|| d < qY|||< |�|� |s�t�|d d �d � q|W d � S 1 s�w Y d S ) z� List the virtual machines on each host, this is a simplified query, showing only the virtual machine names belonging to each host. A single host can be passed in to specify an individual host to list. r r r z virt.vm_infor r r �stater r r N)r r r r! r" r# r$ r r r% r& r' r �appendr( r r ) r r Zhyperr r! r* r+ r, r �key�valr r r �list` sH � ��$�r3 c C s t tdd��} t| � | S )z� Return the host to use for the next autodeployed VM. This queries the available host and executes some math the determine the most "available" next host. T�r )r r. r) )r r r r � next_host� s r5 c C sF t | dd�}|D ]}d|| v r|| �d� qt�|dd�d� |S )zD Return information about the host connected to this master Tr4 r r r r )r. �popr r )r r r, r r r � host_info� s �r7 �kvmT�default�base� seed.apply�Nonec C sf t �ddid� t|dd�}|D ] }d|| v r.| || d v r.t �dd�| �id� dS q|d u r7t|�}||vs=|sJt �dd �|�id� dS d }d }|r�t �dd id� tjj�� \}}t j � t d d | �}tjj �|d��}|�tjj�|�� W d � n1 s�w Y tj�t d ���}t �dd�| |�id� z |j|d| ||gd|||| | | ||||| | ||d�d�}W n ty� } z t|� W Y d }~nd }~ww t|�}|s�t �dd�| �id� W d � dS |D ] }|| d du �rtd�| || d �� W d � dS q�t �dd�| |�id� W d � dS 1 �s,w Y d S )aX This routine is used to create a new virtual machine. This routines takes a number of options to determine what the newly created virtual machine will look like. name The mandatory name of the new virtual machine. The name option is also the minion id, all minions must have an id. cpu The number of cpus to allocate to this new virtual machine. mem The amount of memory to allocate to this virtual machine. The number is interpreted in megabytes. image The network location of the virtual machine image, commonly a location on the salt fileserver, but http, https and ftp can also be used. hypervisor The hypervisor to use for the new virtual machine. Default is `kvm`. host The host to use for the new virtual machine, if this is omitted Salt will automatically detect what host to use. seed Set to `False` to prevent Salt from seeding the new virtual machine. nic The nic profile to use, defaults to the "default" nic profile which assumes a single network interface per VM associated with the "br0" bridge on the master. install Set to False to prevent Salt from installing a minion on the new VM before it spins up. disk The disk profile to use saltenv The Salt environment to use enable_vnc Whether a VNC screen is attached to resulting VM. Default is `False`. seed_cmd If seed is `True`, use this execution module function to seed new VM. Default is `seed.apply`. enable_qcow Clone disk image as a copy-on-write qcow2 image, using downloaded `image` as backing file. serial_type Enable serial console. Set to 'pty' for serial console or 'tcp' for telnet. Default is 'None' �messagezSearching for hostsr Tr4 r z&Virtual machine {} is already deployed�failNzHost {} was not foundzMinion will be preseededZpki_dirZminions�wr zCreating VM {} on host {}z virt.init�X )�image�nic� hypervisor�start�disk�saltenv�seed�install�pub_key�priv_key�seed_cmd� enable_vnc� enable_qcow� serial_type)�timeout�kwargzVM {} was not initialized.r Fz/VM {} initialization failed. Returned error: {}z VM {} initialized on host {}�good)r r r. �formatr r �utilsZcloudZgen_keys�os�path�joinr# �filesZfopen�writeZ stringutilsZto_strr! r" r$ r r) r% )r ZcpuZmemrA rC r rG rB rH rD rE rF rL rK rM rN r �noderI rJ Z accepted_keyZfp_r! �cmd_retr- r Z minion_idr r r �init� s� O �� � ��� �����& ���'�&�r[ c C s t dd�}t| ||�S )z0 Return the information on the named VM Tr4 )r. r )r r r r r r r F s r c C s� i }t j�td ��f}t| dd�}|s't�dd�| �id� W d � dS tt |� � ��}z!|j |d | gd d �}|D ]}|� |� q<t�dd �| �id� W n t yf } z t|� W Y d}~nd}~ww |W d � S 1 ssw Y dS ) z5 Force power down and restart an existing VM r Tr4 r= z Failed to find VM {} to resetr Nr> z virt.resetr@ �rO z Reset VM {})r r! r" r# r r r rR r% r& r' r$ r( r r) )r r r! r r rZ �compr- r r r �resetN s. �� ���$�r^ c C s: i }t j�td ���}t| dd�}|s't�dd�| �id� W d � dS tt |� � ��}|| | d d krIt d �| �� W d � d S z |j |d | gdd�}W n t yt } zd�| |�W Y d}~W d � S d}~ww |D ]}|�|� qwt�dd�| �id� W d � dS 1 s�w Y dS )z' Start a named virtual machine r Tr4 r= z Failed to find VM {} to startr Nr> r/ ZrunningzVM {} is already running� bad statez virt.startr@ r\ z"Virtual machine {} not started: {}z Started VM {}rQ )r r! r" r# r r r rR r% r& r' r) r$ r r( �r r r! r r rZ r- r] r r r rD g s4 ��� �� $�rD c C s2 i }t j�td ���}t| dd�}|s#td�| �� W d � dS tt|� � ��}|| | d dkrEtd �| �� W d � d S z |j |d | gd d �}W n t yp } zd�| |�W Y d}~W d � S d}~ww |D ]}|� |� qst �dd�| �id� W d � dS 1 s�w Y dS )z4 Force power down the named virtual machine r Tr4 z Failed to find VM {} to destroyNr> r/ �shutdownzVM {} is already shutdownr_ z virt.stopr@ r\ z.Virtual machine {} could not be forced off: {}r= zPowered off VM {}r rQ )r r! r" r# r r) rR r% r& r' r$ r r( r r r` r r r � force_off� s8 �� ��� �$�rb c C sN i }t j�td ���}t| dd�}|s't�dd�| �id� W d � dS tt |� � ��}z |j |d | dgd d �}W n t y[ } zd �| |�W Y d}~W d � S d}~ww |D ]}|� |� q^|r�t�d | � t j�t�� } | �| � W d � n1 s�w Y t�dd�| �id� W d � dS 1 s�w Y dS )z Destroy the named VM r Tr4 �errorz Failed to find VM {} to purger Nr> z virt.purger@ r\ z*Virtual machine {} could not be purged: {}zDeleting key %sr= z Purged VM {}rQ )r r! r" r# r r r rR r% r& r' r$ r r( r �debugr1 ZKey� delete_key) r re r r! r r rZ r- r] Zskeyr r r �purge� s: ����� �$�rf c C sB i }t j�td ���}t| dd�}|s't�dd�| �id� W d � dS tt |� � ��}|| | d d krMt�dd �| �id� W d � d S z |j |d | gdd�}W n t yx } zd�| |�W Y d}~W d � S d}~ww |D ]}|� |� q{t�dd�| �id� W d � dS 1 s�w Y dS )z Pause the named VM r Tr4 rc � Failed to find VM {} to pauser Nr> r/ �pausedzVM {} is already pausedr_ z virt.pauser@ r\ z*Virtual machine {} could not be pasued: {}r= z Paused VM {}rQ �r r! r" r# r r r rR r% r& r' r$ r r( r` r r r �pause� s< ������� $�rj c C sB i }t j�td ���}t| dd�}|s't�dd�| �id� W d � dS tt |� � ��}|| | d d krMt�dd �| �id� W d � d S z |j |d | gdd�}W n t yx } zd�| |�W Y d}~W d � S d}~ww |D ]}|� |� q{t�dd�| �id� W d � dS 1 s�w Y dS )z Resume a paused VM r Tr4 rc rg r Nz not foundr/ rh zVM {} is not pausedr_ z virt.resumer@ r\ z+Virtual machine {} could not be resumed: {}r= z Resumed VM {}rQ ri r` r r r �resume� s< ���� ��� $�rk c C s� t j�td ���}tdd�}t| |dd�}ztt|��}W n ty8 t � dd� | �id� Y W d � dS w || | d }|sWt � dd� | �id� W d � dS |s^t ||�}||vrvt � dd � |�id� W d � dS z|� |d |dg� |j|d | |gtd �}W n ty� } zd� | |�W Y d}~W d � S d}~ww d� | ||�} t � d| id� W d � dS 1 s�w Y dS )z� Migrate a VM from one host to another. This routine will just start the migration and display information on how to look up the progress. r Tr4 rc z$Named VM {} was not found to migrater Nr �diskszTarget host {} not foundz virt.seed_non_shared_migratez virt.migrate)Z copy_storagez,Virtual machine {} could not be migrated: {}z�The migration of virtual machine {} to host {} has begun, and can be tracked via jid {}. The ``salt-run virt.query`` runner can also be used, the target VM will be shown as paused until the migration is complete.r= )r r! r" r# r. r r% r& � StopIterationr r rR r �cmdZ cmd_async�allr ) r �targetr! r Z origin_dataZ origin_hostrl Zjidr- �msgr r r �migrate� s\ �� �� �� ���� �"�rr )r )F)NF)NFN)N) r8 NTr9 TTr9 r: Fr; Fr< )T) �__doc__ZloggingZos.pathrT Z salt.clientr Zsalt.keyZsalt.utils.cloudZsalt.utils.filesZsalt.utils.stringutilsZsalt.exceptionsr Z getLogger�__name__r r r r. r3 r5 r7 r[ r r^ rD rb rf rj rk rr r r r r �<module> sL (- � #
Save