Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/digitalocean.cpython-39.pyc
Ðазад
a q�h�i � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddl m Z ddl m Z mZ dd lmZmZmZmZ dd lmZmZ dd lmZmZ d d gZG dd � d e�ZG dd� de�ZG dd � d e e�Z G dd� de�Z dS )z DigitalOcean Driver � N)� parse_date)�httplib)�DigitalOcean_v1_Error)�DigitalOcean_v2_BaseDriver)�InvalidCredsError)�Provider� NodeState)� NodeImage�NodeSize� NodeLocation�KeyPair)�Node� NodeDriver)� StorageVolume�VolumeSnapshot�DigitalOceanNodeDriver�DigitalOcean_v2_NodeDriverc s0 e Zd ZdZejZdZdZd� fdd� Z � Z S ) r a� DigitalOcean NodeDriver defaulting to using APIv2. :keyword key: Personal Access Token required for authentication. :type key: ``str`` :keyword secret: Previously used with API version ``v1``. (deprecated) :type secret: ``str`` :keyword api_version: Specifies the API version to use. Defaults to using ``v2``, currently the only valid option. (optional) :type api_version: ``str`` Z DigitalOceanz https://www.digitalocean.comN�v2c sj | t u rR|dks|d ur8|d ur0|dkr0td��t� �n|dkrFt} n td| ��tt | �j| fi |��S )NZv1r z)secret not accepted for v2 authenticationzUnsupported API version: %s)r r r r �NotImplementedError�super�__new__)�cls�key�secret� api_version�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/digitalocean.pyr 9 s ��z DigitalOceanNodeDriver.__new__)Nr ) �__name__� __module__� __qualname__�__doc__r Z DIGITAL_OCEAN�type�nameZwebsiter � __classcell__r r r r r & s c @ s e Zd Zdd� Zdd� ZdS )�SSHKeyc C s || _ || _|| _d S �N��idr% �pub_key)�selfr* r% r+ r r r �__init__J s zSSHKey.__init__c C s d| j | j| jf S )Nz$<SSHKey: id=%s, name=%s, pub_key=%s>r) �r, r r r �__repr__O s �zSSHKey.__repr__N)r r! r" r- r/ r r r r r' I s r' c @ s� e Zd ZdZejejejejd�Z g d�Z dd� Z dd� Z dcd d �Z d d � Zdddd�Zdd� Zdedd�Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z d,d-� Z dfd/d0�Z d1d2� Z d3d4� Z!dgd5d6�Z"d7d8� Z#dhd9d:�Z$d;d<� Z%d=d>� Z&d?d@� Z'dAdB� Z(dCdD� Z)dEdF� Z*dGdH� Z+dIdJ� Z,dKdL� Z-dMdN� Z.dOdP� Z/dQdR� Z0dSdT� Z1dUdV� Z2dWdX� Z3dYdZ� Z4d[d\� Z5d]d^� Z6d_d`� Z7dadb� Z8d S )ir z6 DigitalOcean NodeDriver using v2 of the API. )�new�offZactive�archive)ZbackupsZipv6Zprivate_networking�tags�ssh_keysc C s | � dd�}tt| j|��S )Nz /v2/imagesZimages)�_paginated_request�list�map� _to_image�r, �datar r r � list_imagese s z&DigitalOcean_v2_NodeDriver.list_imagesc C s | � dd�}tt| j|��S )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`KeyPair` �/v2/account/keysr4 )r5 r6 r7 � _to_key_pairr9 r r r �list_key_pairsi s z)DigitalOcean_v2_NodeDriver.list_key_pairsTc C sN g }| � dd�}|D ]4}|r8|�d�rH|�| �|�� q|�| �|�� q|S )z� List locations :param ex_available: Only return locations which are available. :type ex_evailable: ``bool`` z /v2/regions�regions� available)r5 �get�append� _to_location)r, Z ex_available� locationsr: �locationr r r �list_locationss s z)DigitalOcean_v2_NodeDriver.list_locationsc C s | � dd�}tt| j|��S )N� /v2/dropletsZdroplets)r5 r6 r7 �_to_noder9 r r r � list_nodes� s z%DigitalOcean_v2_NodeDriver.list_nodesNc s6 | � dd�}tt| j|��}� r2� fdd�|D �}|S )Nz /v2/sizes�sizesc s$ g | ] }� j |j�d g �v r|�qS )r? )r* �extrarA )�.0�size�rE r r � <listcomp>� s �z9DigitalOcean_v2_NodeDriver.list_sizes.<locals>.<listcomp>)r5 r6 r7 �_to_size)r, rE r: rJ r rN r � list_sizes� s z%DigitalOcean_v2_NodeDriver.list_sizesc C s | � dd�}tt| j|��S )N� /v2/volumesZvolumes)r5 r6 r7 � _to_volumer9 r r r � list_volumes� s z'DigitalOcean_v2_NodeDriver.list_volumesc C s� ||j |j|j|d�}|r,t�d� ||d< |p2i }|�� D ]} | | jv r<|| || < q<| jjdt� |�dd�} | j d } | j � dd �} | d kr�| j � d d �} | j � d | �}t d| ��| j | d�S )a� Create a node. The `ex_create_attr` parameter can include the following dictionary key and value pairs: * `backups`: ``bool`` defaults to False * `ipv6`: ``bool`` defaults to False * `private_networking`: ``bool`` defaults to False * `tags`: ``list`` of ``str`` tags * `user_data`: ``str`` for cloud-config data * `ssh_keys`: ``list`` of ``int`` key ids or ``str`` fingerprints `ex_create_attr['ssh_keys']` will override `ex_ssh_key_ids` assignment. :keyword ex_create_attr: A dictionary of optional attributes for droplet creation :type ex_create_attr: ``dict`` :keyword ex_ssh_key_ids: A list of ssh key ids which will be added to the server. (optional) :type ex_ssh_key_ids: ``list`` of ``int`` key ids or ``str`` key fingerprints :keyword ex_user_data: User data to be added to the node on create. (optional) :type ex_user_data: ``str`` :return: The newly created node. :rtype: :class:`Node` )r% rM �image�region� user_datazZThe ex_ssh_key_ids parameter has been deprecated in favor of the ex_create_attr parameter.r4 rG �POST�r: �method�droplet�status�OK�ERROR�messageN� error_messagezFailed to create node: %s�r: )r% r* �warnings�warn�keys�EX_CREATE_ATTRIBUTES� connection�request�json�dumps�objectrA � ValueErrorrH )r, r% rM rU rE Zex_create_attrZex_ssh_key_idsZ ex_user_data�attrr �resr: r\ r_ r` r r r � create_node� s( ! � � z&DigitalOcean_v2_NodeDriver.create_nodec C s" | j jd|j dd�}|jtjkS )Nz/v2/droplets/%s�DELETE�rZ �rf rg r* r\ r � NO_CONTENT)r, �noderm r r r � destroy_node� s �z'DigitalOcean_v2_NodeDriver.destroy_nodec C s2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr$ Zreboot�/v2/droplets/%s/actionsrX rY �rf rg r* rh ri r\ r �CREATED�r, rs rl rm r r r � reboot_node� s �z&DigitalOcean_v2_NodeDriver.reboot_nodec C s4 d|d�}| j jd|j t�|�dd�}|jtjkS )a Create an image from a Node. @inherits: :class:`NodeDriver.create_image` :param node: Node to use as base for image :type node: :class:`Node` :param node: Name for image :type node: ``str`` :rtype: ``bool`` �snapshot�r$ r% ru rX rY rv �r, rs r% rl rm r r r � create_image� s �z'DigitalOcean_v2_NodeDriver.create_imagec C s" | j jd|j dd�}|jtjkS )z�Delete an image for node. @inherits: :class:`NodeDriver.delete_image` :param image: the image to be deleted :type image: :class:`NodeImage` :rtype: ``bool`` � /v2/images/%sro rp rq )r, rU rm r r r � delete_image� s �z'DigitalOcean_v2_NodeDriver.delete_imagec C s | � d| d�}| �|�S )z� Get an image based on an image_id @inherits: :class:`NodeDriver.get_image` :param image_id: Image identifier :type image_id: ``int`` :return: A NodeImage object :rtype: :class:`NodeImage` r~ rU )r5 r8 )r, Zimage_idr: r r r � get_image� s z$DigitalOcean_v2_NodeDriver.get_imagec C s4 d|d�}| j jd|j t�|�dd�}|jtjkS )NZ change_kernel)r$ �kernelru rX rY rv )r, rs Z kernel_idrl rm r r r �ex_change_kernel s �z+DigitalOcean_v2_NodeDriver.ex_change_kernelc C s2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr$ Z enable_ipv6ru rX rY rv rx r r r �ex_enable_ipv6 s �z)DigitalOcean_v2_NodeDriver.ex_enable_ipv6c C s4 d|d�}| j jd|j t�|�dd�}|jtjkS )N�renamer{ ru rX rY rv r| r r r �ex_rename_node s �z)DigitalOcean_v2_NodeDriver.ex_rename_nodec C s2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr$ �shutdownru rX rY rv rx r r r �ex_shutdown_node s �z+DigitalOcean_v2_NodeDriver.ex_shutdown_nodec C s2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr$ Z power_cycleru rX rY rv rx r r r �ex_hard_reboot" s �z)DigitalOcean_v2_NodeDriver.ex_hard_rebootc C s2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr$ Zpower_onru rX rY rv rx r r r �ex_power_on_node( s �z+DigitalOcean_v2_NodeDriver.ex_power_on_nodec C s> d|j d d d�}| jjd|j t�|�dd�}|jtjkS )z� Destroy and rebuild the node using its base image. :param node: Node to rebuild :type node: :class:`Node` :return True if the operation began successfully :rtype ``bool`` ZrebuildrU r* )r$ rU ru rX rY ) rK rf rg r* rh ri r\ r rw rx r r r �ex_rebuild_node. s �z*DigitalOcean_v2_NodeDriver.ex_rebuild_nodec C s6 d|j d�}| jjd|j t�|�dd�}|jtjkS )a� Resize the node to a different machine size. Note that some resize operations are reversible, and others are irreversible. :param node: Node to rebuild :type node: :class:`Node` :param size: New size for this machine :type node: :class:`NodeSize` :return True if the operation began successfully :rtype ``bool`` �resize)r$ rM ru rX rY ) r% rf rg r* rh ri r\ r rw )r, rs rM rl rm r r r �ex_resize_node= s �z)DigitalOcean_v2_NodeDriver.ex_resize_node� c C s8 ||d�}| j jddt�|�d�}|jd }| j|d�S )z� Create a new SSH key. :param name: Key name (required) :type name: ``str`` :param public_key: Valid public key string (required) :type public_key: ``str`` )r% � public_keyr< rX )rZ r: �ssh_keyra )rf rg rh ri rj r= )r, r% r� rl rm r: r r r �create_key_pairP s � z*DigitalOcean_v2_NodeDriver.create_key_pairc C s* |j d }| jjd| dd�}|jtjkS )z� Delete an existing SSH key. :param key: SSH key (required) :type key: :class:`KeyPair` r* �/v2/account/keys/%sro rp )rK rf rg r\ r rr )r, r Zkey_idrm r r r �delete_key_pairb s �z*DigitalOcean_v2_NodeDriver.delete_key_pairc sB � fdd�| � � D �d }| j�d|jd �jd }| j|d�S )z� Retrieve a single key pair. :param name: Name of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` c s g | ]}|j � kr|�qS r �r% )rL �kr� r r rO w � z;DigitalOcean_v2_NodeDriver.get_key_pair.<locals>.<listcomp>r r� r* r� ra )r> rf rg rK rj r= )r, r% Zqkeyr: r r� r � get_key_pairn s ��z'DigitalOcean_v2_NodeDriver.get_key_pairc C sz |||j d�}| jjdt�|�dd�}|jd }|j�dd�}|dkrn|j�d d �} |j�d | �} td | ��| j|d �S )a� Create a new volume. :param size: Size of volume in gigabytes (required) :type size: ``int`` :param name: Name of the volume to be created :type name: ``str`` :param location: Which data center to create a volume in. If empty, undefined behavior will be selected. (optional) :type location: :class:`.NodeLocation` :param snapshot: Snapshot from which to create the new volume. (optional) :type snapshot: :class:`.VolumeSnapshot` :return: The newly created volume. :rtype: :class:`StorageVolume` )r% �size_gigabytesrV rR rX rY �volumer\ r] r^ r_ Nr` zFailed to create volume: %sra ) r* rf rg rh ri rj rA rk rS ) r, rM r% rE rz rl rm r: r\ r_ r` r r r � create_volume| s � z(DigitalOcean_v2_NodeDriver.create_volumec C s" | j jd|j dd�}|jtjkS )z� Destroys a storage volume. :param volume: Volume to be destroyed :type volume: :class:`StorageVolume` :rtype: ``bool`` z/v2/volumes/%sro rp rq )r, r� rm r r r �destroy_volume� s �z)DigitalOcean_v2_NodeDriver.destroy_volumec C s< d|j |j|jd d�}| jjdt�|�dd�}|jtj kS )aR Attaches volume to node. :param node: Node to attach volume to. :type node: :class:`.Node` :param volume: Volume to attach. :type volume: :class:`.StorageVolume` :param device: Where the device is exposed, e.g. '/dev/sdb' :type device: ``str`` :rytpe: ``bool`` �attach� region_slug)r$ � droplet_id� volume_namerV �/v2/volumes/actionsrX rY ) r* r% rK rf rg rh ri r\ r �ACCEPTED)r, rs r� Zdevicerl rm r r r � attach_volume� s � �z(DigitalOcean_v2_NodeDriver.attach_volumec C sd d|j |jd d�}g }|jd D ].}||d< | jjdt�|�dd�}|�|� q"td d � |D ��S ) z� Detaches a volume from a node. :param volume: Volume to be detached :type volume: :class:`.StorageVolume` :rtype: ``bool`` �detachr� )r$ r� rV � droplet_idsr� r� rX rY c S s g | ]}|j tjk�qS r )r\ r r� )rL �rr r r rO � r� z<DigitalOcean_v2_NodeDriver.detach_volume.<locals>.<listcomp>)r% rK rf rg rh ri rB �all)r, r� rl � responsesr� rm r r r � detach_volume� s � � z(DigitalOcean_v2_NodeDriver.detach_volumec C s< d|i}| j jd|j t�|�dd�}|jd }| j|d�S )z� Create a new volume snapshot. :param volume: Volume to create a snapshot for :type volume: class:`StorageVolume` :return: The newly created volume snapshot. :rtype: :class:`VolumeSnapshot` r% �/v2/volumes/%s/snapshotsrX rY rz ra )rf rg r* rh ri rj �_to_volume_snapshot)r, r� r% rl rm r: r r r �create_volume_snapshot� s � � z1DigitalOcean_v2_NodeDriver.create_volume_snapshotc C s" | � d|j d�}tt| j|��S )z� List snapshots for a volume. :param volume: Volume to list snapshots for :type volume: class:`StorageVolume` :return: List of volume snapshots. :rtype: ``list`` of :class: `StorageVolume` r� Z snapshots)r5 r* r6 r7 r� )r, r� r: r r r �list_volume_snapshots� s ��z0DigitalOcean_v2_NodeDriver.list_volume_snapshotsc C s" | j jd|j dd�}|jtjkS )z� Delete a volume snapshot :param snapshot: volume snapshot to delete :type snapshot: class:`VolumeSnapshot` :rtype: ``bool`` zv2/snapshots/%sro rp rq )r, rz rm r r r �delete_volume_snapshot� s �z1DigitalOcean_v2_NodeDriver.delete_volume_snapshotc C s | � d�|�d�}| �|�S )z� Lists details of the specified server. :param node_id: ID of the node which should be used :type node_id: ``str`` :rtype: :class:`Node` z/v2/droplets/{}r[ )r5 �formatrH )r, �node_idr: r r r �ex_get_node_details s �z.DigitalOcean_v2_NodeDriver.ex_get_node_detailsc C s2 d|j i}| jjdt�|�dd�}| �|jd �S )a� Create new floating IP reserved to a region. The newly created floating IP will not be associated to a Droplet. See https://developers.digitalocean.com/documentation/v2/#floating-ips :param location: Which data center to create the floating IP in. :type location: :class:`.NodeLocation` :rtype: :class:`DigitalOcean_v2_FloatingIpAddress` rV �/v2/floating_ipsrX rY Z floating_ip)r* rf rg rh ri �_to_floating_iprj )r, rE rl �respr r r �ex_create_floating_ip s �z0DigitalOcean_v2_NodeDriver.ex_create_floating_ipc C s$ | j jd�|j�dd�}|jtjkS )z� Delete specified floating IP :param ip: floating IP to remove :type ip: :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` z/v2/floating_ips/{}ro rp )rf rg r� r* r\ r rr )r, �ipr� r r r �ex_delete_floating_ip$ s �z0DigitalOcean_v2_NodeDriver.ex_delete_floating_ipc C s | � | �dd��S )zk List floating IPs :rtype: ``list`` of :class:`DigitalOcean_v2_FloatingIpAddress` r� � floating_ips)�_to_floating_ipsr5 r. r r r �ex_list_floating_ips1 s �z/DigitalOcean_v2_NodeDriver.ex_list_floating_ipsc s2 | � � }� fdd�|D �}|s*td� ��|d S )z� Get specified floating IP :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`DigitalOcean_v2_FloatingIpAddress` c s g | ]}|j � kr|�qS r )� ip_address)rL �x�r� r r rO E r� zADigitalOcean_v2_NodeDriver.ex_get_floating_ip.<locals>.<listcomp>zFloating ip %s not foundr )r� rk )r, r� r� Z matching_ipsr r� r �ex_get_floating_ip; s z-DigitalOcean_v2_NodeDriver.ex_get_floating_ipc C s6 d|j d�}| jjd|j t�|�dd�}|jtjkS )a Attach the floating IP to the node :param node: node :type node: :class:`Node` :param ip: floating IP to attach :type ip: ``str`` or :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` Zassign)r$ r� �/v2/floating_ips/%s/actionsrX rY ) r* rf rg r� rh ri r\ r rw �r, rs r� r: r� r r r � ex_attach_floating_ip_to_nodeJ s � �z8DigitalOcean_v2_NodeDriver.ex_attach_floating_ip_to_nodec C s2 ddi}| j jd|j t�|�dd�}|jtjkS )a? Detach a floating IP from the given node Note: the 'node' object is not used in this method but it is added to the signature of ex_detach_floating_ip_from_node anyway so it conforms to the interface of the method of the same name for other drivers like for example OpenStack. :param node: Node from which the IP should be detached :type node: :class:`Node` :param ip: Floating IP to detach :type ip: :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` r$ Zunassignr� rX rY )rf rg r� rh ri r\ r rw r� r r r � ex_detach_floating_ip_from_node` s � �z:DigitalOcean_v2_NodeDriver.ex_detach_floating_ip_from_nodec C s� g d�}d|v r&| j �|d tj�}ntj}t|d �}|d }g }g }|r�|d D ]0}|d dkrn|d g}|d d krT|d g}qTi } |D ]} | |v r�|| | | < q�|�d i ��d �| d < t|d |d ||||| | d �} | S )N)�memory�vcpus�diskrU rM Z size_slug�locked� created_at�networksr� Z backup_idsZ snapshot_ids�featuresr3 r\ r� r� Zv4r$ �privater� �publicrV r% r* )r* r% �state� public_ips� private_ipsr� �driverrK )�NODE_STATE_MAPrA r �UNKNOWNr r ) r, r: Z extra_keysr� �createdr� r� r� �netrK r rs r r r rH z s0 �z#DigitalOcean_v2_NodeDriver._to_nodec C sB |d |d |d |d |d |d d�}t |d |d | |d �S ) N� distributionr� �slugr? � min_disk_sizer� )r� r� r� r? r� r� r* r% )r* r% r� rK )r �r, r: rK r r r r8 � s ��z$DigitalOcean_v2_NodeDriver._to_imagec C s@ |d |d |d |d d d�}t |d |d |d | |d �S ) Nr� r� rV r� )r� r� rV r� r* r% r� �r* r% rM r� rK )r r� r r r rS � s ��z%DigitalOcean_v2_NodeDriver._to_volumec C s& |� dg �}t|d |d d || d�S )Nr� r� r% )r* r% ZcountryrK r� )rA r r� r r r rC � s �z'DigitalOcean_v2_NodeDriver._to_locationc C sH |d |d |d d�}t |d |d |d |d |d |d | |d �S ) Nr� r? � price_monthly)r� r? r� r� r� r� ZtransferZ price_hourly)r* r% �ramr� � bandwidthZpricer� rK )r r� r r r rP � s � �z#DigitalOcean_v2_NodeDriver._to_sizec C s, d|d i}t |d |d |d d | |d�S )Nr* r% � fingerprintr� )r% r� r� Z private_keyr� rK )r r� r r r r= � s �z'DigitalOcean_v2_NodeDriver._to_key_pairc C s< |d |d |d |d d�}t |d |d |d | |d �S ) Nr� � resource_idr? r� )r� r� r? r� r* r% r� r� )r r� r r r r� � s ��z.DigitalOcean_v2_NodeDriver._to_volume_snapshotc s � fdd�|D �S )Nc s g | ]}� � |��qS r )r� )rL r� r. r r rO � r� z?DigitalOcean_v2_NodeDriver._to_floating_ips.<locals>.<listcomp>r �r, �objr r. r r� � s z+DigitalOcean_v2_NodeDriver._to_floating_ipsc C s6 t |d |d |d r"|d d nd d|d i| d�S )Nr� r[ r* rV )r* r� r� rK r� )�!DigitalOcean_v2_FloatingIpAddressr� r r r r� � s ��z*DigitalOcean_v2_NodeDriver._to_floating_ip)T)N)NNN)r� )NN)N)9r r! r" r# r ZPENDINGZSTOPPEDZRUNNINGZ TERMINATEDr� re r; r> rF rI rQ rT rn rt ry r} r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rH r8 rS rC rP r= r� r� r� r r r r r T sn � � ; # c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r� z Floating IP info. Nc C s& t |�| _|| _|| _|| _|| _d S r( )�strr* r� rK r� r� )r, r* r� r� rK r� r r r r- � s z*DigitalOcean_v2_FloatingIpAddress.__init__c C s | j �| �S )zC Delete this floating IP :rtype: ``bool`` )r� r� r. r r r �delete� s z(DigitalOcean_v2_FloatingIpAddress.deletec C s d| j | j| jf S )NzA<DigitalOcean_v2_FloatingIpAddress: id=%s, ip_addr=%s, driver=%s>)r* r� r� r. r r r r/ � s �z*DigitalOcean_v2_FloatingIpAddress.__repr__)NNN)r r! r" r# r- r� r/ r r r r r� � s r� ) r# rh rb Zlibcloud.utils.iso8601r Zlibcloud.utils.py3r Z libcloud.common.digitaloceanr r Zlibcloud.common.typesr Zlibcloud.compute.typesr r Zlibcloud.compute.baser r r r r r r r �__all__r rj r' r r� r r r r �<module> s2 �# �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка