Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/nephoscale.cpython-39.pyc
Ðазад
a q�hE � @ s d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z m Z ddlmZmZmZ dd lmZmZmZmZmZ dd lmZ d Zejej ej d �Z ej ej ej ej!gZ"d Z#G dd� de$�Z%G dd� de �Z&G dd� de �Z'G dd� de�Z(dS )z� NephoScale Cloud driver (http://www.nephoscale.com) API documentation: http://docs.nephoscale.com Created by Markos Gogoulos (https://mist.io) � N)�httplib)�b)� urlencode)�Provider)� JsonResponse�ConnectionUserAndKey)� NodeState�InvalidCredsError� LibcloudError)�Node� NodeDriver� NodeImage�NodeSize� NodeLocation)�is_private_subnetzapi.nephoscale.com)�on�off�unknown� c @ s e Zd Zddd�Zdd� ZdS )�NodeKeyNc C s" || _ || _|| _|| _|| _d S �N)�id�name� key_group�password� public_key)�selfr r r r r � 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/nephoscale.py�__init__: s zNodeKey.__init__c C s d| j | jf S )Nz<NodeKey: id=%s, name=%s>)r r �r r r r �__repr__B s �zNodeKey.__repr__)NNN)�__name__� __module__� __qualname__r r! r r r r r 9 s � r c @ s e Zd ZdZdd� Zdd� ZdS )�NephoscaleResponsez! Nephoscale API Response c C s. | j tjkrtd��| j tjkr(td��| jS )NzAuthorization Failedz.The resource you are looking for is not found.)�statusr � UNAUTHORIZEDr � NOT_FOUND� Exception�bodyr r r r � parse_errorL s z NephoscaleResponse.parse_errorc C s | j tv S r )r& �VALID_RESPONSE_CODESr r r r �successT s zNephoscaleResponse.successN)r" r# r$ �__doc__r+ r- r r r r r% G s r% c @ s$ e Zd ZdZeZeZdZdd� Z dS )�NephoscaleConnectionz{ Nephoscale connection class. Authenticates to the API through Basic Authentication with username/password Fc C s0 t �td| j| jf ��}d|�d� |d< |S )zE Add parameters that are necessary for every request z%s:%szBasic %szutf-8� Authorization)�base64� b64encoder Zuser_id�key�decode)r �headersZuser_b64r r r �add_default_headersc s z(NephoscaleConnection.add_default_headersN) r" r# r$ r. �API_HOST�hostr% Z responseClsZallow_insecurer6 r r r r r/ X s r/ c @ s� e Zd ZdZejZdZdZdZ e Z ddgiZ dd� Z d d � Zd d � Zd d� Zd.dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd/d d �Zd0d!d"�Zd1d#d$�Zd2d%d&�Zd'd(� Z d)d*� Z d3d,d-�Z dS )4�NephoscaleNodeDriverz� Nephoscale node driver class. >>> from libcloud.compute.providers import get_driver >>> driver = get_driver('nephoscale') >>> conn = driver('nepho_user','nepho_password') >>> conn.list_nodes() Z nephoscaleZ NephoScalezhttp://www.nephoscale.com� create_nodeZssh_keyc C sN | j �d�j}g }|�dg �D ]*}t|�d�|�d�d| d�}|�|� q |S )zh List available zones for deployment :rtype: ``list`` of :class:`NodeLocation` z/datacenter/zone/�datar r ZUS)r r Zcountry�driver)� connection�request�object�getr �append)r �result� locations�value�locationr r r �list_locations} s � z#NephoscaleNodeDriver.list_locationsc C s� | j �d�j}g }|�dg �D ]h}|�d�|�d�|�d�|�d�|�d�|�d�|�d �d �}t|�d �|�d �| |d �}|�|� q |S )zf List available images for deployment :rtype: ``list`` of :class:`NodeImage` z/image/server/r; � architecture�disks� billable_type�pcpus�cores�uri�storage)rG rH rI rJ rK rL rM r � friendly_name)r r r< �extra)r= r> r? r@ r rA )r rB ZimagesrD rO �imager r r � list_images� s$ � � z NephoscaleNodeDriver.list_imagesc C s| | j �d�j}g }|�dg �D ]L}|�d�}t||�d�|�d�|�d�d| jt|�d�| d �}|�|� q t|d d � d �S ) zg List available sizes containing prices :rtype: ``list`` of :class:`NodeSize` z/server/type/cloud/r; r rN �ramrM N)Zsize_id)r r rR Zdisk� bandwidth�pricer< c S s | j S r )rT )�kr r r �<lambda>� � z1NephoscaleNodeDriver.list_sizes.<locals>.<lambda>)r3 ) r= r> r? r@ r Z_get_size_price�strrA �sorted)r rB �sizesrD Zvalue_id�sizer r r � list_sizes� s � z NephoscaleNodeDriver.list_sizesc s, � j �d�j}� fdd�|�dg �D �}|S )zQ List available nodes :rtype: ``list`` of :class:`Node` �/server/cloud/c s g | ]}� � |��qS r )�_to_node��.0rD r r r � <listcomp>� rW z3NephoscaleNodeDriver.list_nodes.<locals>.<listcomp>r; )r= r> r? r@ )r rB �nodesr r r � list_nodes� s z NephoscaleNodeDriver.list_nodesNc C sD d|i}|r||d< t |�}| jjd|j |dd�j}|�d�tv S )z6rename a cloud server, optionally specify hostname toor �hostname�/server/cloud/%s/�PUT�r; �method�response)r r= r> r r? r@ r, )r �noder rd r; �paramsrB r r r � rename_node� s �z NephoscaleNodeDriver.rename_nodec C s& | j jd|j dd�j}|�d�tv S )zreboot a running nodez#/server/cloud/%s/initiator/restart/�POST�rh ri �r= r> r r? r@ r, �r rj rB r r r � reboot_node� s ��z NephoscaleNodeDriver.reboot_nodec C s& | j jd|j dd�j}|�d�tv S )zstart a stopped nodez!/server/cloud/%s/initiator/start/rm rn ri ro rp r r r � start_node� s ��z NephoscaleNodeDriver.start_nodec C s& | j jd|j dd�j}|�d�tv S )zstop a running nodez /server/cloud/%s/initiator/stop/rm rn ri ro rp r r r � stop_node� s ��z NephoscaleNodeDriver.stop_nodec C s& | j jd|j dd�j}|�d�tv S )zdestroy a nodere �DELETErn ri ro rp r r r � destroy_node� s �z!NephoscaleNodeDriver.destroy_nodec C s | j |d�S �N)rj )rr �r rj r r r � ex_start_node� s z"NephoscaleNodeDriver.ex_start_nodec C s | j |d�S rv )rs rw r r r � ex_stop_node� s z!NephoscaleNodeDriver.ex_stop_nodeFc sz |r|rt d��|r$�j�d�j}n"|r8�j�d�j}n�j�d�j}�fdd�|�dg �D �}� rv� fdd�|D �}|S ) a` List available console and server keys There are two types of keys for NephoScale, ssh and password keys. If run without arguments, lists all keys. Otherwise list only ssh keys, or only password keys. Password keys with key_group 4 are console keys. When a server is created, it has two keys, one password or ssh key, and one password console key. :keyword ssh: if specified, show ssh keys only (optional) :type ssh: ``bool`` :keyword password: if specified, show password keys only (optional) :type password: ``bool`` :keyword key_group: if specified, show keys with this key_group only eg key_group=4 for console password keys (optional) :type key_group: ``int`` :rtype: ``list`` of :class:`NodeKey` zKYou can only supply ssh or password. To get all keys call with no arguments� /key/sshrsa/�/key/password/z/key/c s g | ]}� � |��qS r )�_to_keyr_ r r r ra rW z9NephoscaleNodeDriver.ex_list_keypairs.<locals>.<listcomp>r; c s g | ]}|j � kr|�qS r �r )r` r3 r} r r ra s �)r r= r> r? r@ )r �sshr r rB �keysr )r r r �ex_list_keypairs� s z%NephoscaleNodeDriver.ex_list_keypairsc C s� |r6|s d}|||d�}t |�}| jjd|dd�j}n<|s>d}|sV| �� }|||d�}t |�}| jjd|dd�j}|�d i ��d d �S ) z�Creates a key, ssh or password, for server or console The group for the key (key_group) is 1 for Server and 4 for Console Returns the id of the created key � )r r r rz rm rg � )r r r r{ r; r � )r r= r> r? �random_passwordr@ )r r r r r r; rk rB r r r �ex_create_keypair s0 � � � �z&NephoscaleNodeDriver.ex_create_keypairc C s@ |r | j jd| dd�j}n| j jd| dd�j}|�d�tv S )z4Delete an ssh key or password given it's id z/key/sshrsa/%s/rt rn z/key/password/%s/ri )r= r> r? r@ r, )r Zkey_idr~ rB r r r �ex_delete_keypair9 s � �z&NephoscaleNodeDriver.ex_delete_keypairc s |� d� �}|j} |j}t|� dt��} � || ||||d�} t| �} z| jjd| dd�} W n0 ty� } ztd| ��W Y d}~n d}~0 0 td � t j g g | d �} |� d d �}|s�| S d }| d k� r�| � � }� fdd�|D �}|r�|d S t � d� | d } q�| S dS )a� Creates the node, and sets the ssh key, console key NephoScale will respond with a 200-200 response after sending a valid request. If nowait=True is specified in the args, we then ask a few times until the server is created and assigned a public IP address, so that deploy_node can be run >>> from libcloud.compute.providers import get_driver >>> driver = get_driver('nephoscale') >>> conn = driver('nepho_user','nepho_password') >>> conn.list_nodes() >>> name = 'staging-server' >>> size = conn.list_sizes()[0] <NodeSize: id=27, ...name=CS025 - 0.25GB, 10GB, ...> >>> image = conn.list_images()[9] <NodeImage: id=49, name=Linux Ubuntu Server 10.04 LTS 64-bit, ...> >>> server_keys = conn.ex_list_keypairs(key_group=1)[0] <NodeKey: id=71211, name=markos> >>> server_key = conn.ex_list_keypairs(key_group=1)[0].id 70867 >>> console_keys = conn.ex_list_keypairs(key_group=4)[0] <NodeKey: id=71213, name=mistio28434> >>> console_key = conn.ex_list_keypairs(key_group=4)[0].id 70907 >>> node = conn.create_node(name=name, size=size, image=image, console_key=console_key, server_key=server_key) We can also create an ssh key, plus a console key and deploy node with them >>> server_key = conn.ex_create_keypair(name, public_key='123') 71211 >>> console_key = conn.ex_create_keypair(name, key_group=4) 71213 We can increase the number of connect attempts to wait until the node is created, so that deploy_node has ip address to deploy the script We can also specify the location >>> location = conn.list_locations()[0] >>> node = conn.create_node(name=name, >>> ... size=size, >>> ... image=image, >>> ... console_key=console_key, >>> ... server_key=server_key, >>> ... connect_attempts=10, >>> ... nowait=True, >>> ... zone=location.id) rd �connect_attempts)r rd � service_typerP � server_key� console_key�zoner] rm rg zFailed to create node %sNr� )r r �state� public_ips� private_ipsr< Zex_waitFr c s g | ]}|j � kr|�qS r �r )r` Zc_noder� r r ra � s �z4NephoscaleNodeDriver.create_node.<locals>.<listcomp>�< r� )r@ r �int�CONNECT_ATTEMPTSr r= r> r) r r �UNKNOWNrc �time�sleep)r r r[ rP r� r� r� �kwargsrd r� r� r; rk rj �eZnowaitZ created_noderb r r� r r: D sH 1 �� � " � z NephoscaleNodeDriver.create_nodec C s� t �|�d�d�}g }g }|�dd�}|rd|�d�D ].}|�dd�}t|�rX|�|� q4|�|� q4|�d�|�di ��d�|�d i ��d �|�d �|�d �|�d �|�di ��d �|�d�d�}t|�d�|�d�|||| |d�}|S )z'Convert node in Node instances Z power_status�4Z ipaddressesr� �,� r� r rP rN � create_time� network_ports�is_console_enabledr� rd )Z zone_datar� rP r� r� r� r� rd r )r r r� r� r� r< rO )�NODE_STATE_MAPr@ �split�replacer rA r ) r r; r� r� r� Z ip_addresses�iprO rj r r r r^ � s0 � �z NephoscaleNodeDriver._to_nodec C s0 t |�d�|�d�|�d�|�d�|�d�d�S )Nr r r r r )r r r r r )r r@ )r r; r r r r| � s �z NephoscaleNodeDriver._to_key� c C s& t �|�}t�|��d�}|d |� S )N�ascii)�os�urandom�binascii�hexlifyr4 )r r[ rD r r r r r� � s z$NephoscaleNodeDriver.random_password)N)FFN)NNN)F)NNN)r� ) r" r# r$ r. r Z NEPHOSCALE�typeZapi_namer Zwebsiter/ Z connectionCls�featuresrF rQ r\ rc rl rq rr rs ru rx ry r� r� r� r: r^ r| r� r r r r r9 l s: & � ! � \ r9 ))r. r1 r� r� r� Zlibcloud.utils.py3r r r Zlibcloud.compute.providersr Zlibcloud.common.baser r Zlibcloud.compute.typesr r r Zlibcloud.compute.baser r r r r Zlibcloud.utils.networkingr r7 ZRUNNINGr� r� �OK�ACCEPTED�CREATED� NO_CONTENTr, r� r? r r% r/ r9 r r r r �<module> s2 � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка