File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/__pycache__/client.cpython-310.pyc
Back
o ;j� � @ sh d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z e� e �Z G dd� d�ZdS )� N��SaltClientErrorc @ s� e Zd ZdZej�ejj d�ddfdd�Z dd� Z d d d �Z d dd�Z d dd�Zdd� Zd!dd�Z d"dd�Zdd� Zdd � Zd d � ZdS )#� SSHClientzp Create a client object for executing routines via the salt-ssh backend .. versionadded:: 2015.5.0 ZmasterNFc C sf |r|| _ ntj�|�rt�d| jj|� tj � |�| _ || j d< d| j vr1tj� |�| j d< d S d S )NzP%s expects a file path not a directory path(%s) to its 'c_path' keyword argumentZ__disable_custom_rosterZ config_dir) �opts�os�path�isdir�log�warning� __class__�__name__�saltZconfigZ client_config�dirname)�selfZc_pathZmoptsZdisable_custom_roster� r �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/client.py�__init__ s � �zSSHClient.__init__c C s g dt f�dt f�dt f�dtf�dtf�dt f�dt f�dt f�d tf�d t f�d tf�d tf�d tf�dtf�dtf�dt f�dtf�dtf�dt f�dtf�dtf�dt f�dt f�dtf�dtf�dtf�dt f�dt f�d t f�d tf�d tf�d tf�d tf�d!tf�d"tf�d#tf�d$t f�}i }|D ]h\}}||vr�q�z||| �}W n ty� t�d%|� Y q�w |tu s�|tu r�|||< q�|t u r�|�d&�d'kr�t�d(|� q�|||< q�|tu �rg }|D ]}|�d&�d'kr�t�d(|� q�|�|� q�|||< q�|S ))N�hostZssh_userZ ssh_passwdZssh_portZssh_sudoZ ssh_sudo_userZssh_privZssh_priv_passwdZssh_identities_onlyZssh_remote_port_forwardsZ ssh_optionsZ ssh_max_procsZ ssh_askpassZssh_key_deployZssh_update_rosterZssh_scan_portsZssh_scan_timeoutZ ssh_timeoutZ ssh_log_fileZ raw_shellZ refresh_cacheZrosterZ roster_fileZrostersZignore_host_keysZextra_filerefsZmin_extra_modsZthin_extra_mods�verboseZstaticZssh_wipeZ rand_thin_dirZ regen_thinZssh_run_pre_flightZ no_host_keysZsaltfilezUnable to cast kwarg %sZ ProxyCommand���z Filter unsafe value for kwarg %s) �str�int�bool�list� ValueErrorr r �find�append) r �kwargsZ roster_valsZ sane_kwargs�name�kind�valZsane_val�itemr r r �sanitize_kwargs/ s� �������� � � � � ��������������� � � � � �!�"�#�$�%�' � �zSSHClient.sanitize_kwargsr �globc K sp | � |�}t�| j�}|�|� |r||d< tjj�||�}|g| |d< ||d< ||d< ||d< tj j � |�S )z' Prepare the arguments �timeout�argvZselected_target_option�tgt�arg) r" �copy�deepcopyr �updater �utils�argsZcondition_input�client�sshZSSH) r r& �funr' r$ �tgt_type�kwargr r r r r � _prep_sshr s zSSHClient._prep_ssh� c k s< � | j ||||||fi |��} | j|�dd�d�E dH dS )z� Execute a single command via the salt-ssh subsystem and return a generator .. versionadded:: 2015.5.0 �jidN�r4 )r2 �run_iter�get) r r& r/ r' r$ r0 �retr1 r r. r r r �cmd_iter� s � zSSHClient.cmd_iterc K sH | j ||||||fi |��}i } |j|�dd�d�D ]} | �| � q| S )z� Execute a single command via the salt-ssh subsystem and return all routines at once .. versionadded:: 2015.5.0 r4 Nr5 )r2 r6 r7 r* ) r r& r/ r' r$ r0 r1 r r. �finalr8 r r r �cmd� s z SSHClient.cmdc C s` t �|�}dD ] }||v r||= q| j|d |d |�dg �|�d�|�d�|�d�fi |��S )a Execute a salt-ssh call synchronously. .. versionadded:: 2015.5.0 WARNING: Eauth is **NOT** respected .. code-block:: python client.cmd_sync({ 'tgt': 'silver', 'fun': 'test.ping', 'arg': (), 'tgt_type'='glob', 'kwarg'={} }) {'silver': {'fun_args': [], 'jid': '20141202152721523072', 'return': True, 'retcode': 0, 'success': True, 'fun': 'test.ping', 'id': 'silver'}} )r& r/ r' r$ r0 r1 r& r/ r' r$ r0 r1 )r( r) r; r7 )r �lowr �ignorer r r �cmd_sync� s � ��zSSHClient.cmd_syncc C s t �)a� Execute aa salt-ssh asynchronously WARNING: Eauth is **NOT** respected .. code-block:: python client.cmd_sync({ 'tgt': 'silver', 'fun': 'test.ping', 'arg': (), 'tgt_type'='glob', 'kwarg'={} }) {'silver': {'fun_args': [], 'jid': '20141202152721523072', 'return': True, 'retcode': 0, 'success': True, 'fun': 'test.ping', 'id': 'silver'}} r )r r< r$ r r r � cmd_async� s zSSHClient.cmd_async� c K s� | j |dfd|i| ��} t| �} t�| � g } | D ]} || | d v r(| �| � t| �|kr0 nq| j| |||fd||d�| ��S )a� Execute a command on a random subset of the targeted systems The function signature is the same as :py:meth:`cmd` with the following exceptions. :param subset: The number of systems to execute on .. code-block:: python >>> import salt.client.ssh.client >>> sshclient= salt.client.ssh.client.SSHClient() >>> sshclient.cmd_subset('*', 'test.ping', subset=1) {'jerry': True} .. versionadded:: 2017.7.0 zsys.list_functionsr0 �returnr )r0 r8 r1 )r; r �random�shuffler �lenr9 )r r& r/ r' r$ r0 r8 r1 Zsubsetr Z minion_retZminionsZf_tgtZminionr r r � cmd_subset� s" ����zSSHClient.cmd_subsetc C s dS ��G API compatibility method with salt.client.LocalClient Nr �r r r r �destroy s zSSHClient.destroyc C s | S )rG r rH r r r � __enter__ s zSSHClient.__enter__c G s | � � dS rF )rI )r r, r r r �__exit__ s zSSHClient.__exit__)r Nr# N)r Nr# r3 N)N)r Nr# r3 Nr@ )r � __module__� __qualname__�__doc__r r �joinr ZsyspathsZ CONFIG_DIRr r" r2 r9 r; r> r? rE rI rJ rK r r r r r s: �D � � � $ �* r )r( �loggingr rB Zsalt.client.sshr Z salt.configZ salt.syspathsZsalt.utils.argsZsalt.exceptionsr � getLoggerr r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings