Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/elasticstack.cpython-39.pyc
Ðазад
a q�h�? � @ s� d Z ddlZddlZddlZddlmZ ddlmZ z ddlZW n e yZ ddlZY n0 ddl m Z m Z ddl mZ ddlmZ ddlmZmZmZ dd lmZ dd lmZmZ dd lmZ ejejejd �Z d Z ddddddd�ddddddd�dddd d dd�d d d d!d"dd�d#d$d%dd&dd�d'd(d)d*d"dd�d+�Z G d,d-� d-e �Z G d.d/� d/e �Z!G d0d1� d1e�Z"G d2d3� d3e �Z#G d4d5� d5e�Z$dS )6za Base driver for the providers based on the ElasticStack platform - http://www.elasticstack.com. � N)�httplib)�b)�ConnectionUserAndKey� JsonResponse)�InvalidCredsError)� NodeState)� NodeDriver�NodeSize�Node)� NodeImage)�ScriptDeployment�SSHKeyDeployment)�MultiStepDeployment)ZactiveZdeadZdumpediX �smallzSmall instancei� i� � )�id�name�cpu�memory�disk� bandwidth�mediumzMedium instancei� i i� �largezLarge instancei� i iR � extra-largezExtra Large instancei@ i i� �high-cpu-mediumzHigh-CPU Medium instancei� i^ �high-cpu-extra-largez High-CPU Extra Large instancei N i )r r r r r r c @ s e Zd Zdd� Zdd� ZdS )�ElasticStackExceptionc C s | j d S )Nr ��args��self� r! ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/elasticstack.py�__str__m s z ElasticStackException.__str__c C s d| j d S )Nz <ElasticStackException '%s'>r r r r! r! r" �__repr__q s z ElasticStackException.__repr__N)�__name__� __module__� __qualname__r# r$ r! r! r! r" r l s r c @ s e Zd Zdd� Zdd� ZdS )�ElasticStackResponsec C s* | j dkrt� �d| j ko$dkS S )Ni� �� i+ )�statusr r r! r! r" �successw s z ElasticStackResponse.successc C s | j �dd�}d|| j�� f S )Nzx-elastic-error� zX-Elastic-Error: %s (%s))�headers�get�body�strip)r Z error_headerr! r! r" � parse_error} s z ElasticStackResponse.parse_errorN)r% r& r' r+ r1 r! r! r! r" r( v s r( c @ s e Zd Zdd� Zdd� ZdS )�ElasticStackNodeSizec C s4 || _ || _|| _|| _|| _|| _|| _|| _d S )N�r r r �ramr r �price�driver) r r r r r4 r r r5 r6 r! r! r" �__init__� s z ElasticStackNodeSize.__init__c C s* d| j | j| j| j| j| j| j| jjf S )NzV<NodeSize: id=%s, name=%s, cpu=%s, ram=%s disk=%s bandwidth=%s price=%s driver=%s ...>r3 r r! r! r" r$ � s ��z ElasticStackNodeSize.__repr__N)r% r& r' r7 r$ r! r! r! r" r2 � s r2 c @ s e Zd ZdZdZeZdd� ZdS )�ElasticStackBaseConnectionz; Base connection class for the ElasticStack driver Nc C s< d|d< d|d< dt �td| j| jf ���d� |d< |S )Nzapplication/json�Acceptz Content-TypezBasic %sz%s:%szutf-8� Authorization)�base64� b64encoder Zuser_id�key�decode)r r- r! r! r" �add_default_headers� s � ��z.ElasticStackBaseConnection.add_default_headers)r% r& r' �__doc__�hostr( Z responseClsr? r! r! r! r" r8 � s r8 c s� e Zd ZdZeZddgiZi Zdd� Zdd� Z d d d �Z d d d �Z d d� Z d dd�Z dd� Z� fdd�Zdd� Zdd� Zd!d d �Z� ZS )"�ElasticStackBaseNodeDriverzhttp://www.elasticstack.com� create_nodeZgenerates_passwordc C s | j jd|j dd�}|jdkS )Nz/servers/%s/reset�POST��action�method�� �� connection�requestr r* �r �node�responser! r! r" � reboot_node� s �z&ElasticStackBaseNodeDriver.reboot_nodec C s | j jd|j dd�}|jdkS )Nz/servers/%s/destroyrD rE rH rI rL r! r! r" � destroy_node� s �z'ElasticStackBaseNodeDriver.destroy_nodeNc C sJ g }| j �� D ]6\}}t|d |d | jjd|d id�}|�|� q|S )N�uuid� descriptionZsize_gunzipped)r r r6 �extra)�_standard_drives�itemsr rJ r6 �append)r �locationZimagesr= �value�imager! r! r" � list_images� s �� z&ElasticStackBaseNodeDriver.list_imagesc C sd g }t �� D ]R\}}t|d |d |d |d |d |d | j|d d�| jjd�}|�|� q |S ) Nr r r r r r )Zsize_idr3 )�INSTANCE_TYPESrU r2 Z_get_size_pricerJ r6 rV )r rW �sizesr= rX �sizer! r! r" � list_sizes� s � z%ElasticStackBaseNodeDriver.list_sizesc C s6 | j jdd�j}g }|D ]}| �|�}|�|� q|S )Nz /servers/info�rF )rJ rK �object�_to_noderV )r rN �nodes�datarM r! r! r" � list_nodes� s z%ElasticStackBaseNodeDriver.list_nodes�auto�e1000�hddc s� |�|dvrt d��i }|�|d|j d�� � jjdt�|�dd�j} | sTt d��| d } � jjd | |jf dd �} | j d vr�t d ��� jjd| d�j} t � � } d| v r� jjd| d�j} t � � | } d| v r�| t kr�t d��t � d� q�i } | �||j |j| d|d�� | �|dd�� |�r6| �d|d�� � jjdt�| �dd�j} t| t��rr� �fdd�| D �}n � �| ��}|S )a@ Creates an ElasticStack instance @inherits: :class:`NodeDriver.create_node` :keyword name: String with a name for this new node (required) :type name: ``str`` :keyword smp: Number of virtual processors or None to calculate based on the cpu speed :type smp: ``int`` :keyword nic_model: e1000, rtl8139 or virtio (if not specified, e1000 is used) :type nic_model: ``str`` :keyword vnc_password: If set, the same password is also used for SSH access with user toor, otherwise VNC access is disabled and no SSH login is possible. :type vnc_password: ``str`` )rf Zrtl8139ZvirtiozInvalid NIC model specifiedz%sG)r r] z/drives/createrD �rF rc rG zDrive creation failed�drivez/drives/%s/image/%s/gunziprE )r) rH zDrive imaging failedz/drives/%s/infor_ ZimagingzDrive imaging timed out� �ide:0:0)r r �memrk �boot�smpre )z nic:0:modelz nic:0:dhcp)Zvnc� vnc:passwordz/servers/createc s g | ]}� � |���qS r! )ra )�.0rM �r � ssh_passwordr! r" � <listcomp>A � z:ElasticStackBaseNodeDriver.create_node.<locals>.<listcomp>)r �updater rJ rK �json�dumpsr` r r* �time�IMAGING_TIMEOUT�sleepr r4 � isinstance�listra )r r r] rY rn Z nic_model� vnc_passwordZ drive_typeZ drive_datarN � drive_uuidZ imaging_startZ elapsed_timeZ node_datarb r! rq r" rC � sf �� � �� � � z&ElasticStackBaseNodeDriver.create_nodec K s� d}g }t |�� �}|D ]4}d}|D ]}t�||�r$d} q>q$|s|�|� q|rdtdd�|� ��| jjd|j t � |�dd�} | j t jko�| jd kS ) a Changes the configuration of the running server :param node: Node which should be used :type node: :class:`Node` :param kwargs: keyword arguments :type kwargs: ``dict`` :rtype: ``bool`` )z^name$z^parent$z^cpu$z^smp$z^mem$z^boot$z ^nic:0:model$z ^nic:0:dhcpz ^nic:1:model$z ^nic:1:vlan$z ^nic:1:mac$z^vnc:ip$z^vnc:password$z^vnc:tlsz^ide:[0-1]:[0-1](:media)?$z^scsi:0:[0-7](:media)?$z^block:[0-7](:media)?$FTz'Invalid configuration key specified: %s�,z/servers/%s/setrD rh r, )r| �keys�re�matchrV r �joinrJ rK r rv rw r* r �OKr/ ) r rM �kwargsZ valid_keysZ invalid_keysr� r= �matches�regexrN r! r! r" �ex_set_node_configurationH s, ���z4ElasticStackBaseNodeDriver.ex_set_node_configurationc s� |d }|� dd�}|� dd�}|s,td��|| jv rR| j| d sRtd|j ��|r�d | }t|d d �}|� d d�}|r�t|t�s�t|t�r�t||g�}q�t|t�r�|}|�|� n|}||d < |� d d�s�d|d < t t | �j f i |��S )ay Create a new node, and start deployment. @inherits: :class:`NodeDriver.deploy_node` :keyword enable_root: If true, root password will be set to vnc_password (this will enable SSH access) and default 'toor' account will be deleted. :type enable_root: ``bool`` rY r} N� enable_rootFzGYou need to provide vnc_password argument if you want to use deploymentZsupports_deploymentz$Image %s does not support deploymentz^unset HISTFILE;echo root:%s | chpasswd;sed -i '/^toor.*$/d' /etc/passwd /etc/shadow;history -cT)�script�delete�deployZ ssh_usernameZtoor) r. � ValueErrorrT r r r{ r r �add�superrB � deploy_node) r r� rY r} r� r� Zroot_enable_scriptr� Z deployment�� __class__r! r" r� s sD ���� �� z&ElasticStackBaseNodeDriver.deploy_nodec C s | j jd|j dd�}|jdkS )z� Sends the ACPI power-down event :param node: Node which should be used :type node: :class:`Node` :rtype: ``bool`` z/servers/%s/shutdownrD rE rH rI rL r! r! r" �ex_shutdown_node� s �z+ElasticStackBaseNodeDriver.ex_shutdown_nodec C s | j jd| dd�}|jdkS )z� Deletes a drive :param drive_uuid: Drive uuid which should be used :type drive_uuid: ``str`` :rtype: ``bool`` z/drives/%s/destroyrD rE rH )rJ rK r* )r r~ rN r! r! r" �ex_destroy_drive� s �z+ElasticStackBaseNodeDriver.ex_destroy_drivec C s, zt |d }W n ty( tj}Y n0 d|v rVt|d t�rJ|d }qZ|d g}ng }|d |d d�}d|v r�|d |d< d|v r�|d |d< d|v r�|d |d< d |v r�|d |d < |d }t|t�r�|D ]}|| ||< q�n || ||< |�r|�d |i� t|d |d ||d | jj |d�}|S )Nr* z nic:0:dhcp:ipr rl )r rl �startedrn zvnc:ipro rm �password�serverr )r r �stateZ public_ipsZ private_ipsr6 rS ) �NODE_STATE_MAP�KeyErrorr �UNKNOWNr{ r| ru r rJ r6 ) r rc rr r� Z public_iprS Z boot_deviceZdevicerM r! r! r" ra � sB � �z#ElasticStackBaseNodeDriver._to_node)N)N)re rf Nrg )N)r% r& r' Zwebsiter8 Z connectionCls�featuresrT rO rP rZ r^ rd rC r� r� r� r� ra � __classcell__r! r! r� r" rB � s" � a+ 2rB )%r@ r� rx r; Zlibcloud.utils.py3r r Z simplejsonrv � ImportErrorZlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.compute.typesr Zlibcloud.compute.baser r r r Zlibcloud.compute.deploymentr r r ZRUNNINGZ TERMINATEDr� ry r[ � Exceptionr r( r2 r8 rB r! r! r! r" �<module> s� � � � � � � ��4
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка