Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/__pycache__/ssh.cpython-39.pyc
Ðазад
a q�h�[ � @ sF d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dZzdd l Z d ZW n e yr Y n0 dd l Z dd l Z dd l Z dd lZdd lZdd lmZ dd lmZ dd lmZ ddlmZ ddlmZ g d�ZdZG dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z!G dd� de �Z"e Z#e�sBe"Z#d S ) z. Wraps multiple ways to communicate over SSH. � )�Type)�Optional)�Tuple)�List)�Union)�castFNT)�split)�join)�ExtraLogFormatter)�StringIO)�b)� BaseSSHClient�ParamikoSSHClient�ShellOutSSHClient�SSHCommandTimeoutErrorzahttps://libcloud.readthedocs.io/en/latest/compute/deployment.html#supported-private-ssh-key-typesc s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS ) r zB Exception which is raised when an SSH command times out. Nc s8 || _ || _|| _|| _d| | _tt| ��| j� d S )Nz#Command didn't finish in %s seconds)�cmd�timeout�stdout�stderr�message�superr �__init__)�selfr r r r �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/ssh.pyr C s z SSHCommandTimeoutError.__init__c C s d| j | jf S )Nz.<SSHCommandTimeoutError: cmd="%s",timeout=%s)>)r r �r r r r �__repr__M s �z SSHCommandTimeoutError.__repr__c C s | � � S �N)r r r r r �__str__Q s z SSHCommandTimeoutError.__str__)NN)�__name__� __module__� __qualname__�__doc__r r r � __classcell__r r r r r ? s r c @ sN e Zd ZdZddd�Zdd� Zdd d �Zd d � Zddd�Zdd� Z dd� Z dS )r zM Base class representing a connection over SSH/SCP to a remote node. � �rootNc C sL |dur$d}t �|t� |s |n|}|| _|| _|| _|| _|| _|| _dS )a� :type hostname: ``str`` :keyword hostname: Hostname or IP address to connect to. :type port: ``int`` :keyword port: TCP port to communicate on, defaults to 22. :type username: ``str`` :keyword username: Username to use, defaults to root. :type password: ``str`` :keyword password: Password to authenticate with or a password used to unlock a private key if a password protected key is used. :param key: Deprecated in favor of ``key_files`` argument. :type key_files: ``str`` or ``list`` :keyword key_files: A list of paths to the private key files to use. NzYYou are using deprecated "key" argument which has been replaced with "key_files" argument) �warnings�warn�DeprecationWarning�hostname�port�username�password� key_filesr ) r r+ r, r- r. �keyr/ r r r r r r Z s zBaseSSHClient.__init__c C s t d��dS )z� Connect to the remote node over SSH. :return: True if the connection has been successfully established, False otherwise. :rtype: ``bool`` z+connect not implemented for this ssh clientN��NotImplementedErrorr r r r �connect� s �zBaseSSHClient.connect�wc C s t d��dS )a� Upload a file to the remote node. :type path: ``str`` :keyword path: File path on the remote node. :type contents: ``str`` :keyword contents: File Contents. :type chmod: ``int`` :keyword chmod: chmod file to this after creation. :type mode: ``str`` :keyword mode: Mode in which the file is opened. :return: Full path to the location where a file has been saved. :rtype: ``str`` z'put not implemented for this ssh clientNr1 )r �path�contents�chmod�moder r r �put� s �zBaseSSHClient.putc C s t d��dS )a Delete/Unlink a file on the remote node. :type path: ``str`` :keyword path: File path on the remote node. :return: True if the file has been successfully deleted, False otherwise. :rtype: ``bool`` z*delete not implemented for this ssh clientNr1 )r r5 r r r �delete� s �zBaseSSHClient.deletec C s t d��dS )z� Run a command on a remote node. :type cmd: ``str`` :keyword cmd: Command to run. :return ``list`` of [stdout, stderr, exit_status] z'run not implemented for this ssh clientNr1 �r r r r r r �run� s �zBaseSSHClient.runc C s t d��dS )z� Shutdown connection to the remote node. :return: True if the connection has been successfully closed, False otherwise. :rtype: ``bool`` z)close not implemented for this ssh clientNr1 r r r r �close� s �zBaseSSHClient.closec C sH t �d�}t�d�}|rDt �|�}|�t� � |�|� |�t j � |S )Nzlibcloud.compute.sshZLIBCLOUD_DEBUG) �logging� getLogger�os�getenv� FileHandler� setFormatterr � addHandler�setLevel�DEBUG)r �loggerr5 �handlerr r r �_get_and_setup_logger� s z#BaseSSHClient._get_and_setup_logger)r& r' NNNN)NNr4 )N) r! r" r# r$ r r3 r9 r: r< r= rI r r r r r U s � , r c sx e Zd ZdZdZdZd � fdd� Zd d � Zd d d �Zdd� Z d dd�Z dd� Z dd� Z dd� Z dd� Zd dd�Z� ZS ) r z+ A SSH Client powered by Paramiko. i g�������?r& r' Nc s\ |r|rt d��tt| �j|||||||d� || _t�� | _| j�t� � � | � � | _ dS )a� Authentication is always attempted in the following order: - The key passed in (if key is provided) - Any key we can find through an SSH agent (only if no password and key is provided) - Any "id_rsa" or "id_dsa" key discoverable in ~/.ssh/ (only if no password and key is provided) - Plain username/password auth, if a password was given (if password is provided) z;key_files and key_material arguments are mutually exclusive�r+ r, r- r. r0 r/ r N) � ValueErrorr r r � key_material�paramiko� SSHClient�clientZset_missing_host_key_policyZ AutoAddPolicyrI rG ) r r+ r, r- r. r0 r/ rL r r r r r � s � zParamikoSSHClient.__init__c C s� | j | j| jddd�}| jr&| j|d< | jr6| j|d< | jrR| j| j| jd�|d< | jst| jst| jstd|d< d|d < | jr�| j|d < | j�rFt| jt t f��sFt j � | j��rFt| jd ��}|�� }W d � n1 s�0 Y z| j|| jd�}W n@ tjj�y$ } z|�W Y d }~n*d }~0 t�y6 Y n0 |d= ||d< | j | j| j| jd �}| j�rnd|d < nd|d < | j�r�| j|d< | jjd|d� | jjf i |�� dS )NF)r+ r, r- � allow_agent� look_for_keysr. Z key_filename)r0 r. �pkeyTrP rQ r �r)Z _hostnameZ_portZ _username�_timeoutZ _auth_method�key_fileZ _key_filezConnecting to server��extra)r+ r, r- r. r/ rL �_get_pkey_objectr � isinstance�list�tupler@ r5 �isfile�open�readrM � ssh_exception�PasswordRequiredException� ExceptionrG �debugrO r3 )r Zconninfo�fprL rR �erW r r r r3 s\ � � �&� � zParamikoSSHClient.connectr4 c C s� |||d�}| j jd|d� | j�� }t|�\}}|d dkrJ|�d� n |�d� |�d�D ]8} | dkr^z|�| � W n ty� Y n0 |�| � q^|� � } |j ||d�} | � |� |d ur�| � |� | � � |� � |d dkr�|} n t| |�} | S ) N)�_path�_modeZ_chmodzUploading filerV r �/�.� )r8 )rG rb rO � open_sftp�psplit�chdirr �mkdir�IOError�getcwd�file�writer7 r= �pjoin) r r5 r6 r7 r8 rW �sftp�head�tail�part�cwdZak� file_pathr r r r9 P s2 zParamikoSSHClient.putc C s8 d|i}| j jd|d� | j�� }|�|� |�� dS )Nre z Deleting filerV T)rG rb rO rj �unlinkr= )r r5 rW rs r r r r: x s zParamikoSSHClient.deletec C sh d|i}| j jd|d� d}| j�� }|�� }t�� }|�|� t� }t� } |�d|�} | � � |� � } | r�|� | � |�� � � | � | �|�� � � | �s&t�� } | | } |r�| |kr�|� � |� � }| � � }t||||d��|� | � |�� � � | � | �|�� � � |� � } | �r�q&t�| j� q�|�� }|� � }| � � }|||d�}| j jd|d� |||f}|S ) z� Note: This function is based on paramiko's exec_command() method. :param timeout: How long to wait (in seconds) for the command to finish (optional). :type timeout: ``float`` Z_cmdzExecuting commandrV ����wb)r r r r )Z_statusZ_stdout�_stderrzCommand finished)rG rb rO Z get_transportZ open_session�timeZ exec_commandr �makefiler= �exit_status_readyrq �_consume_stdout�getvalue�_consume_stderrr �sleep� SLEEP_DELAYZrecv_exit_status)r r r Zextra1�bufsize� transport�chan� start_timer r �stdinr � current_timeZ elapsed_time� stdout_str� stderr_str�statusZextra2�resultr r r r< � sR �� zParamikoSSHClient.runc C s | j �d� | j�� dS )NzClosing server connectionT)rG rb rO r= r r r r r= � s zParamikoSSHClient.closec C s | j ||j|jd�}|S )zM Try to consume stdout data from chan if it's receive ready. �r� � recv_method�recv_ready_method)�_consume_data_from_channel�recvZ recv_ready)r r� r r r r r� � s �z!ParamikoSSHClient._consume_stdoutc C s | j ||j|jd�}|S )zM Try to consume stderr data from chan if it's receive ready. r� )r� Z recv_stderrZrecv_stderr_ready)r r� r r r r r� � s �z!ParamikoSSHClient._consume_stderrc C sh t � }t� }|� rP|| j�}|t|�7 }|rP|� }|s8qP|| j�}|t|�7 }q(|�|jddd�� |S )z� Try to consume data from the provided channel. Keep in mind that data is only consumed if the channel is receive ready. zutf-8�ignore)�errors)r � bytearray� CHUNK_SIZEr rq �decode)r r� r� r� r� Z result_bytes�data�readyr r r r� � s z,ParamikoSSHClient._consume_data_from_channelc C sl t jdft jdft jdfg}tt dd�}tdd� |�d�D ��}|d krZ|�t jj d f� |D ]�\}}|� � � � }|d d kr�|d dkr�d| |d < d| |d < d� |�}n|}z|� t|�|�}W n� t jjy� } z| �W Y d} ~ q^d} ~ 0 t jjtf�yH } z6dt| ��� v �r4dt| � } t j�| ��W Y d} ~ q^d} ~ 0 0 | S q^dt } t j�| ��dS )z� Try to detect private key type and return paramiko.PKey object. # NOTE: Paramiko only supports key in PKCS#1 PEM format. ZRSAZDSAZEC� __version__z0.0.0c S s g | ] }t |��qS r )�int)�.0�cr r r � <listcomp> � z6ParamikoSSHClient._get_pkey_object.<locals>.<listcomp>rh )� r� r ZEd25519r z-----BEGIN PRIVATE KEY-----rz z-----END PRIVATE KEY-----z -----BEGIN %s PRIVATE KEY-----z -----END %s PRIVATE KEY-----� Nz'private key file checkints do not matchz?Invalid password provided for encrypted key. Original error: %sz�Invalid or unsupported key type (only RSA, DSS, ECDSA and Ed25519 keys in PEM format are supported). For more information on supported key file types, see %s)rM ZRSAKeyZDSSKeyZECDSAKey�getattrr[ r �appendZ ed25519keyZ Ed25519Key�strip� splitlinesr Zfrom_private_keyr r_ r` Z SSHException�AssertionError�str�lower�SUPPORTED_KEY_TYPES_URL) r r0 r. Z key_typesZparamiko_version�clsZkey_typeZ key_split� key_valuerd �msgr r r rX sB � � � �z"ParamikoSSHClient._get_pkey_object)r& r' NNNNN)NNr4 )N)N)r! r" r# r$ r� r� r r3 r9 r: r< r= r� r� r� rX r% r r r r r � s( �&? ( V r c s^ e Zd ZdZd� fdd� Zdd� Zdd d �Zdd d �Zdd� Zdd� Z dd� Z dd� Z � Z S )r z� This client shells out to "ssh" binary to run commands on the remote server. Note: This client should not be used in production. r& r' Nc sj t t| �j|||||||d� | jr,td��tjdgtjtjd�}|�� |j dkr\td��| � � | _ d S )NrJ z(ShellOutSSHClient only supports key auth�ssh�r r � zssh client is not available) r r r r. rK � subprocess�Popen�PIPE� communicate� returncoderI rG ) r r+ r, r- r. r0 r/ r �childr r r r P s � � zShellOutSSHClient.__init__c C s dS )z� This client doesn't support persistent connections establish a new connection every time "run" method is called. Tr r r r r r3 k s zShellOutSSHClient.connectc C s | � |g�S r ��_run_remote_shell_commandr; r r r r< r s zShellOutSSHClient.runr4 c C sF |dkrd}n|dkr d}n t d| ��d|||f g}| �|� |S )Nr4 �>�az>>zInvalid mode: zecho "%s" %s %s)rK r� )r r5 r6 r7 r8 �redirectr r r r r9 u s zShellOutSSHClient.putc C s dd|g}| � |� dS )NZrmz-rfTr� )r r5 r r r r r: � s zShellOutSSHClient.deletec C s dS )NTr r r r r r= � s zShellOutSSHClient.closec C sX dg}| j r(tt| j �| _ |d| j g7 }| jr>|d| j g7 }|d| j| jf g7 }|S )Nr� z-iz-oConnectTimeout=%sz%s@%s)r/ r r� r r- r+ )r r r r r �_get_base_ssh_command� s z'ShellOutSSHClient._get_base_ssh_commandc C sn | � � }|d�|�g }| j�dd�|� � tj|tjtjd�}|�� \}}tt |�}tt |�}|||j fS )z� Run a command on a remote server. :param cmd: Command to run. :type cmd: ``list`` of ``str`` :return: Command stdout, stderr and status code. :rtype: ``tuple`` � zExecuting command: "%s"r� ) r� r rG rb r� r� r� r� r r� r� ) r r Zbase_cmdZfull_cmdr� r r r� r� r r r r� � s � z+ShellOutSSHClient._run_remote_shell_command)r& r' NNNN)N)NNr4 ) r! r" r# r$ r r3 r< r9 r: r= r� r� r% r r r r r H s � r c @ s e Zd ZdS )� MockSSHClientN)r! r" r# r r r r r� � s r� )$r$ �typingr r r r r r Z have_paramikorM � ImportErrorr@ r} r� r> r( �os.pathr rk r rr Zlibcloud.utils.loggingr Zlibcloud.utils.py3r r �__all__r� ra r �objectr r r r� rN r r r r �<module> sF kj
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка