Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/kamatera.cpython-39.pyc
Ðазад
a q�h�[ � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZm Z ddlm Z m Z m Z ddl mZ ddlmZmZ G dd � d e�ZG d d � d e�ZG d d � d e�ZdS )z Kamatera node driver � N)� basestring)� NodeDriver� NodeLocation�NodeSize)� NodeImage�Node� NodeState)�Provider)�ConnectionUserAndKey� JsonResponsec @ s e Zd ZdZdd� ZdS )�KamateraResponsez+ Response class for KamateraDriver c C s& | � � }d|v r|d S t�|�S d S )N�message)Z parse_body�json�dumps)�self�data� 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/kamatera.py� parse_error" s z KamateraResponse.parse_errorN)�__name__� __module__� __qualname__�__doc__r r r r r r s r c @ s e Zd ZdZdZeZdd� ZdS )�KamateraConnectionz- Connection class for KamateraDriver zcloudcli.cloudwm.comc C s( | j |d< | j|d< d|d< d|d< |S )z-Adds headers that are needed for all requestsZ AuthClientIdZ AuthSecretzapplication/json�Acceptz Content-Type)Zuser_id�key)r �headersr r r �add_default_headers2 s z&KamateraConnection.add_default_headersN)r r r r �hostr Z responseClsr r r r r r * s r c @ s e Zd ZdZejZdZdZe Z dg d�iZ dZ dZ dd � Zd d � Zd d � Zdddde ddfdd�Zd3dd�Zd4dd�Zd5dd�Zd6dd�Zd7dd �Zd8d d �Zd9d d �Zd:d!d"�Zd;d#d$�Zd%d&� Zd<d)d*�Z d+d,� Z dde j ddddddddddddfd-d.�Z d/d0� Z!d1d2� Z"dS )=�KamateraNodeDriverz� Kamatera node driver :keyword key: API Client ID, required for authentication :type key: ``str`` :keyword secret: API Secret, required for authentcaiont :type secret: ``str`` ZKamaterazhttps://www.kamatera.com/� create_node)�passwordZgenerates_passwordZssh_keyZhourlyZmonthlyc s � j �d�}� fdd�|jD �S )zl List available locations for deployment :rtype: ``list`` of :class:`NodeLocation` zservice/server?datacenter=1c s& g | ] }� � |d |d |d ��qS )�idZ subCategory�name)�ex_get_location)�.0� datacenter�r r r � <listcomp>V s ��z5KamateraNodeDriver.list_locations.<locals>.<listcomp>)� connection�request�object)r �responser r' r �list_locationsO s �z!KamateraNodeDriver.list_locationsc s& � j �d|j �}� fdd�|jD �S )z� List predefined sizes for the given location. :param location: Location of the deployment. :type location: :class:`.NodeLocation` @inherits: :class:`NodeDriver.list_sizes` z$service/server?sizes=1&datacenter=%sc s< g | ]4}� j |d |d |d |d g |d |d d��qS )�ramMB� diskSizeGB�cpuType�cpuCores�monthlyTrafficPackager" )�extraDiskSizesGBr2 r" )� ex_get_size)r% �sizer' r r r( e s ��z1KamateraNodeDriver.list_sizes.<locals>.<listcomp>�r) r* r" r+ )r �locationr, r r' r � list_sizesZ s � �z KamateraNodeDriver.list_sizesc C sN | j �d|j �}g }|jD ],}| �d|�}|�| �|d |d |�� q |S )a List available disk images. :param location: Location of the deployement. Available disk images depend on location. :type location: :class:`.NodeLocation` :rtype: ``list`` of :class:`NodeImage` z%service/server?images=1&datacenter=%s)r& �os�codeZ osDiskSizeGBZramMBMinr# r" )r) r* r" r+ � _copy_dict�append� ex_get_image)r r7 r, Zimages�image�extrar r r � list_imageso s � ��z KamateraNodeDriver.list_imagesNFTc C s� d} d} d}t |t�r |} nF| �|�}t|dd�r<d} d}n&t|d�rR|j} d}nt|d�rb|j} |srdd d �g}|| pzd | p�d | p�d |j|jd |jd |jd f |j d� dd� |j g|jd D ��|r�dnd|r�dndd� dd� |D ��d| |jd p�d | �rdndd�}| j j ddt�|�d�}|�rD|jd }|jd }n |j}d}t|�dk�rdtd ��| j||||||| ||d | d � }| �r�d |jv�s�|jtjk�r�td!��| �|jd �}|�d"�|jd#< |j�d$��r�tj|_ntj|_|�d%��rt j � |d% d&�|_ d'd� |jd# � d(�D �}t|�dk�r>td)��|d � d*d �|_!| j j d+dt�d,|j!i�d�}| �"||jd � |S )-a� Creates a Kamatera node. If auth is not given then password will be generated. :param name: String with a name for this new node (required) :type name: ``str`` :param size: The size of resources allocated to this node (required) :type size: :class:`.NodeSize` :param image: OS Image to boot on node. (required) :type image: :class:`.NodeImage` :param location: Which data center to create a node in. (required) :type location: :class:`.NodeLocation` :param auth: Authentication information for the node (optional) :type auth: :class:`.NodeAuthSSHKey` or :class:`.NodeAuthPassword` :param ex_networks: Network configurations (optional) :type ex_networks: ``list`` of ``dict`` :param ex_dailybackup: Whether to create daily backups (optional) :type ex_dailybackup: ``bool`` :param ex_managed: Whether to provide managed support (optional) :type ex_managed: ``bool`` :param ex_billingcycle: billing cycle (hourly / monthly) (optional) :type ex_billingcycle: ``str`` :param ex_poweronaftercreate: power on after creation (optional) :type ex_poweronaftercreate: ``bool`` :param ex_wait: wait for server to be running (optional) :type ex_wait: ``bool`` :return: The newly created node. :rtype: :class:`.Node` NF� generatedZ __generate__Tr! �pubkeyZwan�auto)r# �ip� z%s%sr1 r0 � c S s g | ] }d | �qS )zsize=%dr )r% Zdisksizer r r r( � s z2KamateraNodeDriver.create_node.<locals>.<listcomp>r3 �yes�noc S s$ g | ] }d � dd� |�� D ���qS )�,c S s g | ]\}}d ||f �qS )z%s=%sr )r% �k�vr r r r( � s z=KamateraNodeDriver.create_node.<locals>.<listcomp>.<listcomp>)�join�items)r% �networkr r r r( � s � �� r2 )r# r! ZpasswordValidatezssh-keyr& r> �cpu�ram�disk� dailybackup�managedrN Zquantity� billingcycleZmonthlypackage�poweronaftercreatezservice/server�POST��methodr Z commandIds�invalid responser ) r# r5 r> r7 rS rT rU �generated_password�create_command_idrV r\ z'invalid node for updating create status�logZ create_logrV � completedz%Y-%m-%d %H:%M:%Sc S s g | ]}|� d �r|�qS )�Name: )� startswith)r% �liner r r r( � s �� z Invalid node create log responser_ �/service/server/infor# )#� isinstancer Z_get_and_check_auth�getattr�hasattrr! rB r" r? rQ rL rR r) r* r r r+ �len� RuntimeError� ex_get_node�stater �UNKNOWN� ValueError�ex_wait_command�get�RUNNING�STOPPED�datetime�strptime� created_at�split�replacer# � _update_node_from_server_info)r r# r5 r> r7 �authZ ex_networksZex_dailybackupZ ex_managedZex_billingcycleZex_poweronaftercreate�ex_waitr! rB Zgenerate_passwordZauth_obj� request_datar, Z command_idsr[ �node�commandZ name_linesr r r r � s� . � � � � �� � ���z KamateraNodeDriver.create_nodec s~ |s |s |rZi }|r ||d< n|s&d}||d< � j jddt�|�d�}� fdd�|jD �S � j �d �}� fd d�|jD �S d S ) a� List nodes :param ex_name_regex: Regular expression to match node names if set returns full node details (optional) :type ex_name_regex: ``str`` :param ex_full_details: Whether to return full node details takes longer to complete (optional) :type ex_full_details: ``bool`` :return: List of node objects :rtype: ``list`` of :class:`Node` r" z.*r# rc rW rX c s g | ]}� � � �� |��qS r )rv ri �r% �serverr' r r r( s ��z1KamateraNodeDriver.list_nodes.<locals>.<listcomp>z/service/serversc sD g | ]<}� j |d |d |d dkr*tjntj� �|d �d��qS )r" r# �power�onr& )r" r# rj r7 )ri r ro rp r$ r| r' r r r( # s � �N)r) r* r r r+ )r Z ex_name_regexZex_full_detailsZex_idry r, r r' r � list_nodes s$ � � �z KamateraNodeDriver.list_nodesc C s | � |d|�S )z� Reboot the given node :param node: the node to reboot :type node: :class:`Node` :param ex_wait: wait for reboot to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zreboot��ex_node_operation�r rz rx r r r � reboot_node, s z KamateraNodeDriver.reboot_nodec C s | � |d|�S )z� Destroy the given node :param node: the node to destroy :type node: :class:`Node` :param ex_wait: wait for destroy to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` � terminater� r� r r r � destroy_node: s z KamateraNodeDriver.destroy_nodec C s | � |d|�S )z� Stop the given node :param node: the node to stop :type node: :class:`Node` :param ex_wait: wait for stop to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zpoweroffr� r� r r r � stop_nodeH s z KamateraNodeDriver.stop_nodec C s | � |d|�S )z� Start the given node :param node: the node to start :type node: :class:`Node` :param ex_wait: wait for start to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zpoweronr� r� r r r � start_nodeV s z KamateraNodeDriver.start_nodec C s� |j rd|j i}n |jr$d|ji}n td| ��|dkr@d|d< | jjd| dt�|�d �jd }|rr| �|� n||j d | < dS ) ae Run custom operations on the node :param node: the node to run operation on :type node: :class:`Node` :param operation: the operation to run :type operation: ``str`` :param ex_wait: wait for destroy to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` r" r# z5Invalid node for %s node operation: missing id / namer� T�forcez/service/server/%srW rX r z %s_command_id) r" r# rl r) r* r r r+ rm r? )r rz Z operation�waitry � command_idr r r r� d s& ��� z$KamateraNodeDriver.ex_node_operationc C s t |||| d�S )a~ Get a NodeLocation object to use for other methods :param id: Location ID - uppercase letters code (required) :type id: ``str`` :param name: Location Name (optional) :type name: ``str`` :param name: Location country (optional) :type name: ``str`` :rtype: :class:`.NodeLocation` )r" r# �country�driver)r )r r" r# r� r r r r$ � s z"KamateraNodeDriver.ex_get_locationc C sr |s@t |�| }|dt |� d t |� d 7 }|r@|d| 7 }|sH|}t||||dd| jj||||phg d�d�S )aB Get a NodeSize object to use for other methods :param ramMB: Amount of RAM to allocate in MB (required) :type ramMB: ``int`` :param diskSizeGB: disk size GB for primary hard disk (required) :type diskSizeGB: ``int`` :param cpuType: CPU type ID (single uppercase letter), see ex_list_capabilities (required) :type cpuType: ``str`` :param cpuCores: Number of CPU cores to allocate (required) :type cpuCores: ``int`` :param extraDiskSizesGB: additional disk sizes in GB (optional) :type extraDiskSizesGB: ``list`` of :int: :param monthlyTrafficPackage: ID of monthly traffic package see ex_list_capabilities (optional) :type monthlyTrafficPackage: ``str`` :param id: Size ID (optional) :type id: ``str`` :param name: Size Name (optional) :type name: ``str`` :rtype: :class:`.NodeLocation` �-zMB-�GBr )r0 r1 r2 r3 )r" r# rQ rR � bandwidthZpricer� r? )�strr r) r� ) r r. r/ r0 r1 r3 r2 r" r# r r r r4 � s* " ��z KamateraNodeDriver.ex_get_sizec C s, |s|st d��t|p||p d| |p&i d�S )Nz,either id or name are required for NodeImagerE )r" r# r� r? )rl r )r r# r" r? r r r r= � s �z KamateraNodeDriver.ex_get_imagec C s | j �d|j �jS )z� List capabilities for given location. :param location: Location of the deployment. :type location: :class:`.NodeLocation` :return: ``dict`` z+service/server?capabilities=1&datacenter=%sr6 )r r7 r r r �ex_list_capabilities� s ��z'KamateraNodeDriver.ex_list_capabilities�X � c C s� t j �� }t�|� |t j|d� }|t j �� k rJtdt|�t|�f ��t�|� | �|�}|�d�}|dkrt|S |dkrt d|�d� ��qdS ) a� Wait for command to complete and return the command status details :param command_id: Command ID to wait for. (required) :type command_id: ``int`` :param timeout_seconds: Max seconds to wait for command. (optional) :type timeout_seconds: ``int`` :param poll_interval_seconds: Poll interval in seconds (optional) :type poll_interval_seconds: ``int`` :return: ``dict`` )�secondsz?Timeout waiting for command (timeout_seconds=%s, command_id=%s)�statusZcomplete�errorzCommand failed: r] N) rq �now�time�sleep� timedelta� TimeoutErrorr� �ex_get_command_statusrn rh )r r� Ztimeout_secondsZpoll_interval_seconds� start_timeZmax_timer{ r� r r r rm � s& � ��� z"KamateraNodeDriver.ex_wait_commandc C s4 | j �dt|� �}t|j�dkr*td��|jd S )z� Get Kamatera command status details :param command_id: Command ID to get details for. (required) :type command_id: ``int`` :return: ``dict`` z/service/queue?id=rO rZ r )r) r* r� rg r+ rh )r r� r, r r r r� s �z(KamateraNodeDriver.ex_get_command_statusc C s� i }| r| |d< | dur | |d< | dur0| |d< | dur@| |d< | durP| |d< |dur`||d< |durp||d< t |||||| ||||d � S ) a} Get a Kamatera node object. :param id: Node ID (optional) :type id: ``str`` :param name: Node name (optional) :type name: ``str`` :param state: Node state (optional) :type state: :class:`libcloud.compute.types.NodeState` :param public_ips: Node public IPS. (optional) :type public_ips: ``list`` of :str: :param private_ips: Node private IPS. (optional) :type private_ips: ``list`` of :str: :param size: node size. (optional) :type size: :class:`.NodeSize` :param image: Node OS Image. (optional) :type image: :class:`.NodeImage` :param created_at: Node creation time. (optional) :type created_at: ``datetime.datetime`` :param location: Node datacenter. (optional) :type location: :class:`.NodeLocation` :param dailybackup: create daily backups for the node (optional) :type dailybackup: ``bool`` :param managed: provide managed support for the node (optional) :type managed: ``bool`` :param billingcycle: billing cycle (hourly / monthly) (optional) :type billingcycle: ``str`` :param generated_password: server generated password (optional) :type generated_password: ``str`` :param create_command_id: creation task command ID (optional) :type create_command_id: ``int`` :param poweronaftercreate: power on the node after create (optional) :type poweronaftercreate: ``bool`` :return: The node. :rtype: :class:`.Node` r7 NrS rT rU r[ r\ rV ) r" r# rj � public_ips� private_ipsr� r5 r> rs r? )r )r r" r# rj r� r� r5 r> rs r7 rS rT rU r[ r\ rV r? r r r ri s( 9 �z KamateraNodeDriver.ex_get_nodec C s i }|D ]}|| ||< q|S )Nr )r �keys�dr? r r r r r; ` s z KamateraNodeDriver._copy_dictc C s> |d |_ |d |_|d dkr*tj|_ntj|_|�dg �D ]B}|�d��d�rj| j|�dg �7 _q>| j |�dg �7 _ q>|�d |j �d ��� � }|| j kr�| j |j d < |�d �|j d < |�d �|j d< n,| j |j d < |�d�|j d < |�d�|j d< | �|d �|j d< |�d�dk|j d< |�d�dk|j d< |S )Nr" r# r~ r ZnetworksrN zwan-�ips�billingrU Z priceHourlyOnZpriceOnZpriceHourlyOffZpriceOffZpriceMonthlyOnr& r7 �backup�1rS rT )r" r# r ro rj rp rn r` r� r� r? �lower�EX_BILLINGCYCLE_HOURLY�EX_BILLINGCYCLE_MONTHLYr$ )r rz r} rN r� r r r rv f s. � z0KamateraNodeDriver._update_node_from_server_info)NFN)T)T)T)T)T)NN)NNNN)NNN)r� r� )#r r r r r ZKAMATERA�typer# Zwebsiter Z connectionCls�featuresr� r� r- r8 r@ r r� r� r� r� r� r� r$ r4 r= r� rm r� r rk ri r; rv r r r r r ; sZ � � ( ! � 9 � "� Mr )r r rq r� Zlibcloud.utils.py3r Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr Zlibcloud.common.baser r r r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка