File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/container_resource.cpython-310.pyc
Back
o ;j�3 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl m Z mZ e�e�ZdZdd� Zdd� Zd d � Zd d � Ze ddd��Ze ddd��ZdS )aa Common resources for LXC and systemd-nspawn containers .. versionadded:: 2015.8.0 These functions are not designed to be called directly, but instead from the :mod:`lxc <salt.modules.lxc>`, :mod:`nspawn <salt.modules.nspawn>`, and :mod:`docker <salt.modules.docker>` execution modules. They provide for common logic to be re-used for common actions. � N)�CommandExecutionError�SaltInvocationErrorzJPATH=/bin:/usr/bin:/sbin:/usr/sbin:/opt/bin:/usr/local/bin:/usr/local/sbinc s t �� �� fdd��}|S )z; Decorator for common function argument validation c s� |� d�}|� d�}dddd�}||vr!td�|d�t|�����||| vr3td �d�|| ����|d krBtjj�d �sBtd ��� | i tjj j d i |����S ) N�container_type� exec_driver)� lxc-attach�nsenter� docker-exec)r )r )Zdocker�lxcZnspawnz0Invalid container type '{}'. Valid types are: {}�, z7Invalid command execution driver. Valid drivers are: {}r zmThe 'lxc-attach' execution driver has been chosen, but lxc-attach is not available. LXC may not be installed.� ) �getr �format�join�sorted�salt�utils�path�which�argsZ clean_kwargs)r �kwargsr r Z valid_driver��wrappedr �S/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/container_resource.py�wrapper# s. ��� ��� z_validate.<locals>.wrapper)� functools�wraps)r r r r r � _validate s r c C s d| � d�S )zE Return the nsenter command to attach to the named container �nsenter --target z --mount --uts --ipc --net --pidr )�pidr r r �_nsenterB s r c C sB || dt �|�� �dd�}z |d �� d W S ty Y dS w )z< Get the sha256 checksum of a file from a container z sha256sum T)�ignore_retcode�stdoutr N)�shlex�quote�split� IndexError)�namer Zrun_func�retr r r � _get_sha256I s �r( c C sR z| � d�rtd | �}|std| � ���|W S W | S ty( td| � ���w )z� Wrapper for cp.cache_file which raises an error if the file was unable to be cached. CLI Example: .. code-block:: bash salt myminion container_resource.cache_file salt://foo/bar/baz.txt zsalt://z cp.cache_filezUnable to cache zInvalid source file )� startswith�__salt__r �AttributeErrorr )�sourceZ cached_sourcer r r � cache_fileU s � ��r- FT�debugc C sN d} |du r d}n|| vrt d�d�| ����d}| du s"t| t�r%g }n!t| ttf�sDz| �d�}W n tyC t � d� g }Y nw | }|d kr�d }| rY|d t � | �� d �7 }| d urm|d7 }d|vrm|dt � d �7 }|d �dd� |D ��7 }|dt � | �� d|� �7 }ns|dkr�t|� d� | �}d|� d�}| d ur�|d7 }d|vr�|t � d �7 }|d �dd� |D ��7 }|d |� �7 }n9|dkr�d }|r�|d 7 }|| � d �7 }| d ur�|d7 }d|vr�|t � d �7 }|d �d d� |D ��7 }|d |� �7 }| �s t| ||||| d �}|S d \}}tjjj|||d!k�rd!nd"||d d d#d#d$� }z|zI|j�r_z%|�� \}}|�r9||7 }|�rJ|du �rF||7 }n||7 }t�d%� W n t�yZ Y nw |j�s+|du �rf|n|jd&||d'�}W n$ tjjj�y� t�� }t � |� |du �r�|nd(d&||d'�}Y nw W |� � |S W |� � |S |� � w ))aS Common logic for running shell commands in containers path path to the container parent (for LXC only) default: /var/lib/lxc (system default) CLI Example: .. code-block:: bash salt myminion container_resource.run mycontainer 'ps aux' container_type=docker exec_driver=nsenter output=stdout )r! �stderr�retcode�allN�cmd.runz/'output' param must be one of the following: {}r z cmd.run_all�,z Invalid keep_env value, ignoringr z lxc-attach z-P � Tz --clear-env �PATH� --set-var c S s2 g | ]}|t jv rd |� dt�t j| �� ��qS )r6 �=��os�environr" r# ��.0�xr r r � <listcomp>� s �zrun.<locals>.<listcomp>z -n z -- r �.pidr z$ --mount --uts --ipc --net --pid -- zenv -i c S �0 g | ]}|t jv r|� d t�t j| �� ��qS �r7 r8 r; r r r r> � � 0 r z docker exec z-i c S r@ rA r8 r; r r r r> � rB )�stdin� python_shell�output_loglevelr )� rF �quiet�infoF)�shellZlog_stdin_levelZlog_stdout_levelZlog_stderr_levelZ log_stdoutZ log_stderrZ stream_stdoutZ stream_stderrg �?� )r0 r r! r/ � ) r r r � isinstance�bool�list�tupler$ r+ �log�warningr" r# r5 r* r r ZvtZTerminalZhas_unread_data�recv�time�sleep�KeyboardInterruptZ exitstatusZTerminalException� traceback� format_exc�error� terminate)r& �cmdr r �outputZno_startrC rD rE r r Zuse_vtZkeep_envZ valid_outputZcmd_funcZto_keepZfull_cmdr r' r! r/ �procZcstdoutZcstderrZtracer r r �runm s� �� ��� � ��8�� �� ��� � ���� �r] c s� t � � d� �� �fdd�}i �ddi} � dv r �| d< ��d< ��fdd �} | | �} | d kr7td | � d ���t|�} tj�| �\} }tj�| �sMtd ��tj�| �s[td| � d���tj� | �setd��tj�|�sotd��|| dt � |�� �fi | ��d dkr�tj� ||�}nStj�|�\}}|| dt � |�� �fi | ��d dkr�|r�|| dt � |�� �fi | ��}|d dkr�d� || �}|d r�|d� |d �7 }t|��n td� |� | ���|s�|| dt � |�� �fi | ��d dkr�td� |���t d | d �}|t| ||�k�rt�d || |� dS t�d |� | |� |d k�r:d }��r0|d!t � ��� �7 }d"� | t| ||�}n&|d#k�rSt � � d$� | �}d%� | t|�t|�}n |d&k�r`d'� | | t|�}t d( |dd)d*� |t| ||�kS )+a] Common logic for copying files to containers path path to the container parent (for LXC only) default: /var/lib/lxc (system default) CLI Example: .. code-block:: bash salt myminion container_resource.copy_to mycontainer /local/file/path /container/file/path container_type=docker exec_driver=nsenter z.statec s: t �|�}� dv rd|vr�|d< t� � d� | i |��S )N�r r z.run_all)�copy�deepcopyr* )r Zakwargs)r r r r �run_all% s zcopy_to.<locals>.run_allr Tr^ r c s �r � | fi ���S � | �S )Nr )r& )�state� state_kwargsr r �_state1 s zcopy_to.<locals>._stateZrunningz Container 'z' is not runningz Source path must be absolutez Source file z does not existz Source must be a regular filez!Destination path must be absoluteztest -d r0 r z mkdir -p z;Unable to create destination directory {} in container '{}'r/ z: {}z0Directory {} does not exist on {} container '{}'ztest -e zFDestination path {} already exists. Use overwrite=True to overwrite itz file.get_sum�sha256z-%s and %s:%s are the same file, skipping copyz%Copying %s to %s container '%s' as %sr z -P z=cat "{0}" | {4} --clear-env --set-var {1} -n {2} -- tee "{3}"r r? z cat "{}" | {} env -i {} tee "{}"r z/cat "{}" | docker exec -i {} env -i {} tee "{}"r2 rG )rD rE )r* r r- r9 r r$ �isabsr �exists�isfiler" r# r r r( rP r. r5 r )r& r, �destr r r Z overwrite�makedirsra Z cmd_kwargsrd Zc_stateZ local_fileZ source_dirZ source_nameZdest_dirZ dest_name�resultrX Z source_sha256Z lxcattachZcopy_cmdr r )r r rb rc r �copy_to s� & ��� �� ���&� � �� � �rl ) NNNFNTr. FNFN)NNNFF)�__doc__r_ r �loggingr9 r" rS rV Zsalt.utils.argsr Zsalt.utils.pathZ salt.utils.vtZsalt.exceptionsr r � getLogger�__name__rP r5 r r r( r- r] rl r r r r �<module> sN $ � �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings