Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/ecs.cpython-39.pyc
Ðазад
a q�hJ� � @ s� d Z z ddlZW n ey* ddlZY n0 ddlZddlmZmZ ddlm Z ddl m Z m Z m Z mZmZmZmZ ddlmZmZmZ ddlmZ ddlmZmZm Z g d �Z d Z d Z d Z d d� Z!ded�ded�ded�ded�ded�ded�ded�ded�ded�ded�ded�ded�d ed�d ed�d �d ed�d ed�d!ed�d"ed�d#�d$ed�d%ed�d&e"d�ded�d'�d(d)ed�id*ed�ded�ded�d+ed�d,ed�ded�d-ed�d.ed�d/e!d�d0ed�d1ed�d2e!d�d3e!d�ded�d4ed�d5ed�d6ed�d7�d8ed�ded�d9ed�d:ed�d;e"d�d<ed�d.ed�d=ed�d>�d?ed�d@ed�dAed�dBed�ded�dCe"d�dDed�dEed�d.ed�dFe!d�d9ed�ded�d=ed�dGe!d�dH�dIed�dCe"d�d1ed�dJed�dKed�dLed�dM�dN�Z#G dOdP� dPe�Z$G dQdR� dRe%�Z&G dSdT� dTe%�Z'G dUdV� dVe%�Z(G dWd� de%�Z)G dXdY� dYe%�Z*G dZd[� d[e%�Z+G d\d]� d]e �Z,dS )^z Node driver for Aliyun. � N)�AliyunXmlResponse�SignedAliyunConnection)� LibcloudError)�Node� NodeDriver� NodeImage�NodeSize� StorageVolume�VolumeSnapshot� NodeLocation)� NodeState�StorageVolumeState�VolumeSnapshotState)� _real_unicode)�findall�findattr�findtext)� DiskCategory�InternetChargeType�ECS_API_VERSION� ECSDriver�ECSSecurityGroup�ECSZonez 2014-05-26zecs.aliyuncs.comz1.0c C s& t | t�r| S t| ��� dkr"dS dS )N�trueTF)� isinstance�bool�u�lower)�value� 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/ecs.py� _parse_bool1 s r! � Description)�xpath�transform_func�ImageId�ZoneId� InstanceType�InstanceTypeFamily�HostNameZ SerialNumberr � CreationTimeZInstanceNetworkTypeZInstanceChargeTypeZDeviceAvailable� IoOptimizedZ ExpiredTime)� description�image_id�zone_idZ instance_type�instance_type_family�hostnameZ serial_number�internet_charge_type� creation_timeZinstance_network_typeZinstance_charge_typeZdevice_availableZ io_optimizedZ expired_time�VpcId� VSwitchIdzPrivateIpAddress/IpAddressZ NatIpAddress)�vpc_idZ vswitch_idZprivate_ip_addressZnat_ip_addressZ AllocationId� IpAddressZ Bandwidth)Z allocation_id� ip_address� bandwidthr1 Z lock_reasonZ LockReason�RegionId�Type�CategoryZSourceSnapshotIdZ ProductCodeZPortable� InstanceId�Device�DeleteWithInstanceZEnableAutoSnapshotZ AttachedTimeZ DetachedTimeZDiskChargeType)� region_idr. r, �type�categoryr- Zsource_snapshot_id� product_codeZportable� instance_id�device�delete_with_instanceZenable_auto_snapshotr2 Z attached_timeZ detached_timeZdisk_charge_type� SnapshotName�ProgressZ SourceDiskIdZSourceDiskSizeZSourceDiskType�Usage)Z snapshot_namer, �progressZsource_disk_idZsource_disk_sizeZsource_disk_typerB �usage� ImageVersionZOSType�PlatformZ Architecture�SizeZImageOwnerAliasZOSNameZ IsSubscribedZIsCopied)Z image_versionZos_type�platform� architecturer, �sizeZimage_owner_alias�os_namerB Z is_subscribedrI r2 rJ Z is_copied� SnapshotId�FormatZImportOSSBucketZImportOSSObject)� snapshot_idrP rD �formatZimport_oss_bucketZimport_oss_object)�node�vpc_attributes�eip_address_associate�operation_locks�volume�snapshot�image�disk_device_mappingc @ s e Zd ZdZeZeZeZ dZ dS )� ECSConnectionzD Represents a single connection to the Aliyun ECS Endpoint. ZecsN) �__name__� __module__� __qualname__�__doc__r � api_version�ECS_API_ENDPOINT�hostr Z responseCls� service_namer r r r r^ ` s r^ c @ s" e Zd ZdZddd�Zdd� ZdS )r zS Security group used to control nodes internet and intranet accessibility. Nc C s( || _ || _|| _|| _|| _|| _d S �N)�id�namer, �driverr5 r2 )�selfrh ri r, rj r5 r2 r r r �__init__o s zECSSecurityGroup.__init__c C s d| j | j| jjf S )Nz1<ECSSecurityGroup: id=%s, name=%s, driver=%s ...>�rh ri rj �rk r r r �__repr__x s �zECSSecurityGroup.__repr__)NNNN�r_ r` ra rb rl ro r r r r r k s � r c @ s" e Zd ZdZddd�Zdd� ZdS )�ECSSecurityGroupAttributez# Security group attribute. Nc C s" || _ || _|| _|| _|| _d S rg �� ip_protocol� port_range�source_group_id�policy�nic_type)rk rs rt ru rv rw r r r rl � s z"ECSSecurityGroupAttribute.__init__c C s d| j S )Nz/<ECSSecurityGroupAttribute: ip_protocol=%s ...>)rs rn r r r ro � s �z"ECSSecurityGroupAttribute.__repr__)NNNNNrp r r r r rq } s � rq c @ s" e Zd ZdZddd�Zdd� ZdS )r zE ECSZone used to represent an availability zone in a region. Nc C s( || _ || _|| _|| _|| _|| _d S rg �rh ri rj �available_resource_types�available_instance_types�available_disk_categories)rk rh ri rj ry rz r{ r r r rl � s zECSZone.__init__c C s d| j | j| jf S )Nz$<ECSZone: id=%s, name=%s, driver=%s>rm rn r r r ro � s �zECSZone.__repr__)NNNNrp r r r r r � s � r c @ s e Zd ZdZdZdZdS )r z= Internet connection billing types for Aliyun Nodes. ZPayByBandwidthZ PayByTrafficN)r_ r` ra rb Z BY_BANDWIDTHZ BY_TRAFFICr r r r r � s c @ s e Zd ZdZdZdZdZdZdS )r zL Enum defined disk types supported by Aliyun system and data disks. �cloudZcloud_efficiencyZ cloud_ssdZ ephemeral_ssdN)r_ r` ra rb ZCLOUDZCLOUD_EFFICIENCYZ CLOUD_SSDZ EPHEMERAL_SSDr r r r r � s r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � PaginationzA Pagination used to describe the multiple pages results. c C s || _ || _|| _dS )z� Create a pagination. :param total: the total count of the results :param size: the page size of each page :param current: the current page number, 1-based N��totalrP �current)rk r rP r� r r r rl � s zPagination.__init__c C s2 | j du s | j| j | j kr dS | jd7 _| S )z� Switch to the next page. :return: the new pagination or None when no more page :rtype: ``Pagination`` N� r~ rn r r r �next� s zPagination.nextc C s | j | jd�S )N)� PageNumber�PageSize)r� rP rn r r r �to_dict� s �zPagination.to_dictc C s d| j | j| jf S )Nz/<Pagination total=%d, size=%d, current page=%d>r~ rn r r r ro � s �zPagination.__repr__N)r_ r` ra rb rl r� r� ro r r r r r} � s r} c @ sb e Zd ZdZdZdZeZddgiZdZ dZ e Z e Zejejejejd�Zejejejejejejd �Zejejejd �Z d{d d �Z d|d d�Z dd� Z d}dd�Z d~dd�Z!dd� Z"dd� Z#ddd�Z$d d � Z%d�d d �Z&d�d d!�Z'd�d"d#�Z(d�d$d%�Z)d�d&d'�Z*d�d)d*�Z+d�d+d,�Z,d�d-d.�Z-d�d/d0�Z.d�d1d2�Z/g dfd3d4�Z0d�d5d6�Z1d�d7d8�Z2d�d9d:�Z3d�d;d<�Z4d=d>� Z5d?d@� Z6d�dAdB�Z7d�dCdD�Z8dEdF� Z9d�dGdH�Z:d�dIdJ�Z;dKdL� Z<dMdN� Z=dOdP� Z>dQdR� Z?dSdT� Z@dUdV� ZAdWdX� ZBdYdZ� ZCd[d\� ZDd]d^� ZEd�dadb�ZFdcdd� ZGdedf� ZHdgdh� ZIdidj� ZJdkdl� ZKdmdn� ZLdodp� ZMdqdr� ZNdsdt� ZOdudv� ZPdwdx� ZQdydz� ZRdS )�r z� Aliyun ECS node driver. Used for Aliyun ECS service. TODO: Get guest OS root password Adjust internet bandwidth settings Manage security groups and rules z Aliyun ECSz"https://www.aliyun.com/product/ecs� create_node�passwordN�/)ZStartingZRunningZStoppingZStopped)ZIn_useZ AvailableZ AttachingZ DetachingZCreatingZ ReIniting)Z progressingZ accomplishedZfailedc C sj d| j d�}|r2t|t�r*| �|�|d< ntd��|rTt|t�rL|�|� ntd��| �| j|| j �}|S )a� List all nodes. @inherits: :class:`NodeDriver.create_node` :keyword ex_node_ids: a list of node's ids used to filter nodes. Only the nodes which's id in this list will be returned. :type ex_node_ids: ``list`` of ``str`` :keyword ex_filters: node attribute and value pairs to filter nodes. Only the nodes which matchs all the pairs will be returned. If the filter attribute need a json array value, use ``list`` object, the driver will convert it. :type ex_filters: ``dict`` ZDescribeInstances��Actionr9 Z InstanceIdsz)ex_node_ids should be a list of node ids.z/ex_filters should be a dict of node attributes.) �regionr �list�_list_to_json_array�AttributeError�dict�update�_request_multiple_pages�path� _to_nodes)rk � ex_node_ids� ex_filters�params�nodesr r r � list_nodes s � �zECSDriver.list_nodesc s@ ddi}� j �� j|�j}t|d� jd�}� fdd�|D �}|S )Nr� ZDescribeInstanceTypeszInstanceTypes/InstanceType�� namespacec s g | ]}� � |��qS r )�_to_size��.0Zeachrn r r � <listcomp>0 � z(ECSDriver.list_sizes.<locals>.<listcomp>�� connection�requestr� �objectr r� )rk �locationr� � resp_bodyZ size_elements�sizesr rn r � list_sizes* s �zECSDriver.list_sizesc s@ ddi}� j �� j|�j}t|d� jd�}� fdd�|D �}|S )Nr� ZDescribeRegionszRegions/Regionr� c s g | ]}� � |��qS r )� _to_locationr� rn r r r� 9 r� z,ECSDriver.list_locations.<locals>.<listcomp>r� )rk r� r� Zlocation_elements� locationsr rn r �list_locations3 s �zECSDriver.list_locationsc K s� d| j |j|j|d�}|s"td��||d< |r6||d< | �|| |�}|rR|�|� | r^| |d< |rv| �|�}|j|d< | dur�| }t|t�r�|r�d nd }||d < | r�| � | �}|r�|�|� | r�| � | �}|r�|�|� |r�||d < |r�|s�td ��n||d< |�r ||d< | j j | j |d�}t|jd| jd�}| j|gd�}t|�dk�r\td| | d��|d }| �|� | �|tj� |S )aU @inherits: :class:`NodeDriver.create_node` :param name: The name for this new node (required) :type name: ``str`` :param image: The image to use when creating this node (required) :type image: `NodeImage` :param size: The size of the node to create (required) :type size: `NodeSize` :keyword auth: Initial authentication information for the node (optional) :type auth: :class:`NodeAuthSSHKey` or :class:`NodeAuthPassword` :keyword ex_security_group_id: The id of the security group the new created node is attached to. (required) :type ex_security_group_id: ``str`` :keyword ex_description: A description string for this node (optional) :type ex_description: ``str`` :keyword ex_internet_charge_type: The internet charge type (optional) :type ex_internet_charge_type: a ``str`` of 'PayByTraffic' or 'PayByBandwidth' :keyword ex_internet_max_bandwidth_out: The max output bandwidth, in Mbps (optional) Required for 'PayByTraffic' internet charge type :type ex_internet_max_bandwidth_out: a ``int`` in range [0, 100] a ``int`` in range [1, 100] for 'PayByTraffic' internet charge type :keyword ex_internet_max_bandwidth_in: The max input bandwidth, in Mbps (optional) :type ex_internet_max_bandwidth_in: a ``int`` in range [1, 200] default to 200 in server side :keyword ex_hostname: The hostname for the node (optional) :type ex_hostname: ``str`` :keyword ex_io_optimized: Whether the node is IO optimized (optional) :type ex_io_optimized: ``boll`` :keyword ex_system_disk: The system disk for the node (optional) :type ex_system_disk: ``dict`` :keyword ex_data_disks: The data disks for the node (optional) :type ex_data_disks: a `list` of `dict` :keyword ex_vswitch_id: The id of vswitch for a VPC type node (optional) :type ex_vswitch_id: ``str`` :keyword ex_private_ip_address: The IP address in private network (optional) :type ex_private_ip_address: ``str`` :keyword ex_client_token: A token generated by client to keep requests idempotency (optional) :type keyword ex_client_token: ``str`` ZCreateInstance)r� r9 r% r' � InstanceNamez!ex_security_group_id is mandatory�SecurityGroupIdr" r) ZPasswordN� optimized�noner+ r4 zFmust provide ex_private_ip_address and ex_vswitch_id at the same timeZPrivateIpAddress� ClientToken�r� r< �r# r� �r� r� z0could not find the new created node with id %s. �rj r )r� rh r� � _get_internet_related_paramsr� Z_get_and_check_authr� r r �_get_system_disk�_get_data_disksr� r� r� r r� r� r� �lenr � ex_start_node�_wait_until_stater �RUNNING)rk ri rP r\ �authZex_security_group_id�ex_description�ex_internet_charge_type� ex_internet_max_bandwidth_out� ex_internet_max_bandwidth_inZ ex_hostnameZex_io_optimized�ex_system_disk� ex_data_disksZ ex_vswitch_idZex_private_ip_address�ex_client_token�kwargsr� Z inet_paramsr� Z system_disk� data_disks�respZnode_idr� rV r r r r� < sv L�� ��� zECSDriver.create_nodeFc C s@ d|j t|��� d�}| jj| j|d�}|�� o>| �|gtj �S )aD Reboot the given node @inherits :class:`NodeDriver.reboot_node` :keyword ex_force_stop: if ``True``, stop node force (maybe lose data) otherwise, stop node normally, default to ``False`` :type ex_force_stop: ``bool`` ZRebootInstance�r� r< Z ForceStopr� ) rh r r r� r� r� �successr� r r� �rk rV � ex_force_stopr� r� r r r � reboot_node� s ��zECSDriver.reboot_nodec C s� | j |jgd�}t|�dkr:|j|d jkr:td|j ��|d }|jtjkrf| �|� | �|tj � d|jd�}| j � | j |�}|� � S )Nr� r� r z#could not find the node with id %s.ZDeleteInstance�r� r< )r� rh r� r �stater r� � ex_stop_noder� �STOPPEDr� r� r� r� )rk rV r� r� r� r� r r r � destroy_node� s � �zECSDriver.destroy_nodec C s4 d|j d�}| j�| j|�}|�� o2| �|gtj�S )z� Start node to running state. :param node: the ``Node`` object to start :type node: ``Node`` :return: starting operation result. :rtype: ``bool`` Z StartInstancer� )rh r� r� r� r� r� r r� )rk rV r� r� r r r � start_node� s ��zECSDriver.start_nodec C s> d|j t|��� d�}| j�| j|�}|�� o<| �|gtj �S )a� Stop a running node. :param node: The node to stop :type node: :class:`Node` :keyword ex_force_stop: if ``True``, stop node force (maybe lose data) otherwise, stop node normally, default to ``False`` :type ex_force_stop: ``bool`` :return: stopping operation result. :rtype: ``bool`` Z StopInstancer� ) rh r r r� r� r� r� r� r r� r� r r r � stop_node� s ��zECSDriver.stop_nodec C s | j |d�S )N)rV )r� )rk rV r r r r� s zECSDriver.ex_start_nodec C s | j ||d�S )N)rV r� )r� )rk rV r� r r r r� s zECSDriver.ex_stop_nodec C sF d| j d�}|r||d< |r$||d< | j�| j|�}t|jd| jd�S )a+ Create a new security group. :keyword description: security group description :type description: ``unicode`` :keyword client_token: a token generated by client to identify each request. :type client_token: ``str`` ZCreateSecurityGroupr� r" r� r� r� )r� r� r� r� r r� r� )rk r, Z client_tokenr� r� r r r �ex_create_security_group s ��z"ECSDriver.ex_create_security_groupc C s& d| j |d�}| j�| j|�}|�� S )z| Delete a new security group. :keyword group_id: security group id :type group_id: ``str`` ZDeleteSecurityGroup)r� r9 r� )r� r� r� r� r� )rk �group_idr� r� r r r � ex_delete_security_group_by_id6 s �z(ECSDriver.ex_delete_security_group_by_idc C sP d| j d�}|std��||d< |r,||d< |r8||d< | j�| j|�}|�� S )aC Modify a new security group. :keyword group_id: id of the security group :type group_id: ``str`` :keyword name: new name of the security group :type name: ``unicode`` :keyword description: new description of the security group :type description: ``unicode`` Z ModifySecurityGroupAttributer� �group_id is requiredr� �SecurityGroupNamer" )r� r� r� r� r� r� )rk r� ri r, r� r� r r r � ex_modify_security_group_by_idC s �z(ECSDriver.ex_modify_security_group_by_idc sD d� j d�}|r(t|t�r(|�|� |}� fdd�}� �� j||�S )a List security groups in the current region. :keyword ex_filters: security group attributes to filter results. :type ex_filters: ``dict`` :return: a list of defined security groups :rtype: ``list`` of ``ECSSecurityGroup`` ZDescribeSecurityGroupsr� c s& t | d� jd�}� fdd�|D �}|S )Nz SecurityGroups/SecurityGroupr� c s g | ]}� � |��qS r )�_to_security_group�r� �elrn r r r� t r� zNECSDriver.ex_list_security_groups.<locals>._parse_response.<locals>.<listcomp>�r r� )� resp_objectZ sg_elementsZsgsrn r r �_parse_responseq s �z:ECSDriver.ex_list_security_groups.<locals>._parse_response)r� r r� r� r� r� )rk r� r� r� r rn r �ex_list_security_groups` s � �z!ECSDriver.ex_list_security_groups�internetc sZ d� j |d�}|du r td��||d< � j�� j|�j}t|d� jd�}� fdd �|D �S ) a] List security group attributes in the current region. :keyword group_id: security group id. :type group_id: ``str`` :keyword nic_type: internet|intranet. :type nic_type: ``str`` :return: a list of defined security group Attributes :rtype: ``list`` of ``ECSSecurityGroupAttribute`` Z DescribeSecurityGroupAttribute)r� r9 �NicTypeNr� r� zPermissions/Permissionr� c s g | ]}� � |��qS r )� _to_security_group_attributer� rn r r r� � r� z?ECSDriver.ex_list_security_group_attributes.<locals>.<listcomp>)r� r� r� r� r� r� r r� )rk r� rw r� r� Z sga_elementsr rn r �!ex_list_security_group_attributesy s ��z+ECSDriver.ex_list_security_group_attributesc C s\ |du rt d��|jtjkr6|jtjkr6td|j ��d|j|d�}| j�| j |�}|� � S )a Join a node into security group. :param node: The node to join security group :type node: :class:`Node` :param group_id: security group id. :type group_id: ``str`` :return: join operation result. :rtype: ``bool`` Nr� �VThe node state with id % s need be running or stopped .ZJoinSecurityGroup�r� r< r� � r� r� r r� r� r rh r� r� r� r� �rk rV r� r� r� r r r �ex_join_security_group� s ���z ECSDriver.ex_join_security_groupc C s\ |du rt d��|jtjkr6|jtjkr6td|j ��d|j|d�}| j�| j |�}|� � S )a Leave a node from security group. :param node: The node to leave security group :type node: :class:`Node` :param group_id: security group id. :type group_id: ``str`` :return: leave operation result. :rtype: ``bool`` Nr� r� ZLeaveSecurityGroupr� r� r� r r r �ex_leave_security_group� s ���z!ECSDriver.ex_leave_security_groupc sX ddi}|r||d< n � j |d< � j�� j|�j}t|d� jd�}� fdd�|D �}|S )a List availability zones in the given region or the current region. :keyword region_id: the id of the region to query zones from :type region_id: ``str`` :return: list of zones :rtype: ``list`` of ``ECSZone`` r� Z DescribeZonesr9 z Zones/Zoner� c s g | ]}� � |��qS r )�_to_zoner� rn r r r� � r� z+ECSDriver.ex_list_zones.<locals>.<listcomp>)r� r� r� r� r� r r� )rk r? r� r� Z zone_elementsZzonesr rn r � ex_list_zones� s �zECSDriver.ex_list_zonesc s� d� j d�}|r2t|t�r*� �|�|d< ntd��|rdt|t�sJtd��n|�� D ]}|| ||< qR� fdd�}� �� j||�S )a� List all volumes. @inherits: :class:`NodeDriver.list_volumes` :keyword ex_volume_ids: a list of volume's ids used to filter volumes. Only the volumes which's id in this list will be returned. :type ex_volume_ids: ``list`` of ``str`` :keyword ex_filters: volume attribute and value pairs to filter volumes. Only the volumes which matchs all will be returned. If the filter attribute need a json array value, use ``list`` object, the driver will convert it. :type ex_filters: ``dict`` Z DescribeDisksr� ZDiskIdsz-ex_volume_ids should be a list of volume ids.z1ex_filters should be a dict of volume attributes.c s& t | d� jd�}� fdd�|D �}|S )Nz Disks/Diskr� c s g | ]}� � |��qS r )� _to_volumer� rn r r r� r� zCECSDriver.list_volumes.<locals>._parse_response.<locals>.<listcomp>r� )r� Z disk_elements�volumesrn r r r� s �z/ECSDriver.list_volumes.<locals>._parse_response) r� r r� r� r� r� �keysr� r� )rk � ex_volume_idsr� r� �keyr� r rn r � list_volumes� s � �zECSDriver.list_volumesc sz d� j d�}|r|j|d< |r6t|t�r6� �|�|d< |r^t|t�r^|�� D ]}|| ||< qL� fdd�}� �� j||�S )a� List snapshots for a storage volume. @inherites :class:`NodeDriver.list_volume_snapshots` :keyword ex_snapshot_ids: a list of snapshot ids to filter the snapshots returned. :type ex_snapshot_ids: ``list`` of ``str`` :keyword ex_filters: snapshot attribute and value pairs to filter snapshots. Only the snapshot which matchs all the pairs will be returned. If the filter attribute need a json array value, use ``list`` object, the driver will convert it. :type ex_filters: ``dict`` ZDescribeSnapshotsr� �DiskIdZ SnapshotIdsc s& t | d� jd�}� fdd�|D �}|S )NzSnapshots/Snapshotr� c s g | ]}� � |��qS r )� _to_snapshotr� rn r r r� 0 r� zLECSDriver.list_volume_snapshots.<locals>._parse_response.<locals>.<listcomp>r� )r� �snapshot_elements� snapshotsrn r r r� - s �z8ECSDriver.list_volume_snapshots.<locals>._parse_response) r� rh r r� r� r� r� r� r� )rk rZ �ex_snapshot_idsr� r� r� r� r rn r �list_volume_snapshots s � �z ECSDriver.list_volume_snapshotsc C s� d| j ||d�} |du r td��|| d< |durDt|t�rD|j| d< |rP|| d< |r\|| d< |rh|| d < | j�| j| �j} t | d | j d �} | j | gd �} t | �d kr�t d| | d��| d S )a) Create a new volume. @inherites :class:`NodeDriver.create_volume` :keyword ex_zone_id: the availability zone id (required) :type ex_zone_id: ``str`` :keyword ex_description: volume description :type ex_description: ``unicode`` :keyword ex_disk_category: disk category for data disk :type ex_disk_category: ``str`` :keyword ex_client_token: a token generated by client to identify each request. :type ex_client_token: ``str`` Z CreateDisk)r� r9 �DiskNamerM Nzex_zone_id is requiredr& rR r" r r� r� r� �r� r� z0could not find the new create volume with id %s.r� r )r� r� r r rh r� r� r� r� r r� r� r� r ) rk rP ri r� r[ Z ex_zone_idr� Zex_disk_categoryr� r� r� Z volume_idr� r r r � create_volume6 s4 � ��zECSDriver.create_volumec C s� d|j d�}|r||d< |r$||d< |r0||d< | j�| j|�j}t|d| jd�}| jd|gd �}t|�d kr~t d | | d ��|d S )a� Creates a snapshot of the storage volume. @inherits :class:`NodeDriver.create_volume_snapshot` :keyword ex_description: description of the snapshot. :type ex_description: ``unicode`` :keyword ex_client_token: a token generated by client to identify each request. :type ex_client_token: ``str`` ZCreateSnapshot�r� r� rF r" r� rR r� N)rZ r� r� z/could not find new created snapshot with id %s.r� r ) rh r� r� r� r� r r� r� r� r ) rk rZ ri r� r� r� r� rT r� r r r �create_volume_snapshotd s. ��� ��z ECSDriver.create_volume_snapshotc C sL d|j |j d�}|r ||d< |r4tt|���� |d< | j�| j|�}|�� S )a� Attaches volume to node. @inherits :class:`NodeDriver.attach_volume` :keyword device: device path allocated for this attached volume :type device: ``str`` between /dev/xvdb to xvdz, if empty, allocated by the system :keyword ex_delete_with_instance: if to delete this volume when the instance is deleted. :type ex_delete_with_instance: ``bool`` Z AttachDisk)r� r< r� r= r> )rh �strr r r� r� r� r� )rk rV rZ rD Zex_delete_with_instancer� r� r r r � attach_volume� s ��zECSDriver.attach_volumec C sn d|j d�}|r||d< n<| j|j gd�}t|�dkrDtd|j ��|d jd |d< | j�| j|�}|�� S ) a Detaches a volume from a node. @inherits :class:`NodeDriver.detach_volume` :keyword ex_instance_id: the id of the instance from which the volume is detached. :type ex_instance_id: ``str`` Z DetachDiskr� r< r� r� zUcould not find the instance id the volume %s attached to, ex_instance_id is required.r rC ) rh r� r� r� �extrar� r� r� r� )rk rZ Zex_instance_idr� r� r� r r r � detach_volume� s � �zECSDriver.detach_volumec C sn d|j d�}| j|j gd�}t|�dkr:td|j | d��|d jtjkrVtd| d��| j�| j |�}|� � S ) NZ DeleteDiskr� r� r� z%could not find the volume with id %s.r� r z2only volume in AVAILABLE state could be destroyed.) rh r� r� r r� r � AVAILABLEr� r� r� r� )rk rZ r� r� r� r r r �destroy_volume� s � ���zECSDriver.destroy_volumec C sB ddi}|r"t |t�r"|j|d< ntd��| j�| j|�}|�� S )Nr� ZDeleteSnapshotrR z1snapshot is required and must be a VolumeSnapshot)r r rh r� r� r� r� r� )rk r[ r� r� r r r �destroy_volume_snapshot� s z!ECSDriver.destroy_volume_snapshotc s� |rt |t�r|j}n� j}d|d�}|rLt |t�rDd�|�|d< ntd��|rtt |t�rt|�� D ]}|| ||< qb� fdd�}� � � j ||�S )a� List images on a provider. @inherits :class:`NodeDriver.list_images` :keyword ex_image_ids: a list of image ids to filter the images to be returned. :type ex_image_ids: ``list`` of ``str`` :keyword ex_filters: image attribute and value pairs to filter images. Only the image which matchs all the pairs will be returned. If the filter attribute need a json array value, use ``list`` object, the driver will convert it. :type ex_filters: ``dict`` ZDescribeImagesr� �,r% z*ex_image_ids should be a list of image idsc s& t | d� jd�}� fdd�|D �}|S )Nz Images/Imager� c s g | ]}� � |��qS r )� _to_imager� rn r r r� � r� zBECSDriver.list_images.<locals>._parse_response.<locals>.<listcomp>r� )r� Zimage_elements�imagesrn r r r� � s �z.ECSDriver.list_images.<locals>._parse_response) r r rh r� r� �joinr� r� r� r� r� )rk r� � ex_image_idsr� r� r� r� r� r rn r � list_images� s" � �zECSDriver.list_imagesc C s� d| j d�}|r||d< |r$||d< |r2||d< ntd��|rF||d< |rR||d< | j�| j|�}t|jd | jd �} | j| d �S ) a! Creates an image from a system disk snapshot. @inherits :class:`NodeDriver.create_image` :keyword ex_snapshot_id: the id of the snapshot to create the image. (required) :type ex_snapshot_id: ``str`` :keyword ex_image_version: the version number of the image :type ex_image_version: ``str`` :keyword ex_client_token: a token generated by client to identify each request. :type ex_client_token: ``str`` Z CreateImager� � ImageNamer" rR zex_snapshot_id is requiredrK r� r% r� �r- ) r� r� r� r� r� r r� r� � get_image) rk rV ri r, Zex_snapshot_idZex_image_versionr� r� r� r- r r r � create_image s" � zECSDriver.create_imagec C s( d| j |jd�}| j�| j|�}|�� S )NZ DeleteImage�r� r9 r% )r� rh r� r� r� r� )rk � node_imager� r� r r r � delete_image& s �zECSDriver.delete_imagec C sT |r |}n| j }t|d d | d�}| j||gd�}t|�dkrLtd| | d��|d S )N�rh ri Zcountryrj )r r� z#could not find the image with id %sr� r )r� r r r� r )rk r- Z ex_region_idr� r� r r r r r - s � ��zECSDriver.get_imagec C s| d||j d�}|dur ||d< n | j|d< |r6||d< |rB||d< |rN||d< | j�| j|�}t|jd| jd �} | j| d �S ) a� Copies an image from a source region to the destination region. If not provide a destination region, default to the current region. @inherits :class:`NodeDriver.copy_image` :keyword ex_destination_region_id: id of the destination region :type ex_destination_region_id: ``str`` :keyword ex_client_token: a token generated by client to identify each request. :type ex_client_token: ``str`` Z CopyImager NZDestinationRegionIdZDestinationImageNameZDestinationDescriptionr� r% r� r ) rh r� r� r� r� r r� r� r ) rk Z source_regionr ri r, Zex_destination_region_idr� r� r� r- r r r � copy_image; s � zECSDriver.copy_imagec C s. d|d�}| j j| j|d�}t|jd| jd�S )z� Create public ip. :keyword instance_id: instance id for allocating public ip. :type instance_id: ``str`` :return public ip :rtype ``str`` ZAllocatePublicIpAddressr� r� r6 r� )r� r� r� r r� r� )rk rC r� r� r r r �create_public_ip[ s ��zECSDriver.create_public_ipc s t |d� j�}� fdd�|D �S )z� Convert response to Node object list :param object: parsed response object :return: a list of ``Node`` :rtype: ``list`` zInstances/Instancec s g | ]}� � |��qS r )�_to_noder� rn r r r� u r� z'ECSDriver._to_nodes.<locals>.<listcomp>r� )rk r� Z node_elementsr rn r r� l s zECSDriver._to_nodesc C s� t |d| jd�}t |d| jd�}t |d| jd�}| j�|tj�}dd� }t|d| jd�}||�}t|d| jd�} || �} | �|td �} | � |�| d < | � |�| d < | � |�| d < t ||||| | j j| d �} | S )z� Convert an InstanceAttributesType object to ``Node`` object :param instance: a xml element represents an instance :return: a ``Node`` object :rtype: ``Node`` r< ��elementr# r� r� �Statusc S s dd� | D �S )Nc S s g | ] }|j �qS r ��textr� r r r r� � r� z8ECSDriver._to_node.<locals>._get_ips.<locals>.<listcomp>r )Zip_address_elsr r r �_get_ips� s z$ECSDriver._to_node.<locals>._get_ipszPublicIpAddress/IpAddresszInnerIpAddress/IpAddressrV rW Z eip_addressrY )rh ri r� � public_ips� private_ipsrj r� )r r� �NODE_STATE_MAPPING�getr �UNKNOWNr �_get_extra_dict� RESOURCE_EXTRA_ATTRIBUTES_MAP�_get_vpc_attributes�_get_eip_address�_get_operation_locksr r� rj ) rk �instance�_idri Zinstance_statusr� r Z public_ip_elsr Zprivate_ip_elsr r� rV r r r r w s@ �������zECSDriver._to_nodec C sp i }|� � D ]^\}}|d }t||d | jd�}|rbz||�||< W qj ty^ d||< Y qj0 q |||< q |S )am Extract attributes from the element based on rules provided in the mapping dictionary. :param element: Element to parse the values from. :type element: xml.etree.ElementTree.Element. :param mapping: Dictionary with the extra layout :type node: :class:`Node` :rtype: ``dict`` r$ r# r N)�itemsr r� � Exception)rk r �mappingr� � attribute�valuesr$ r r r r r � s � zECSDriver._get_extra_dictc C sP i }|r@||d< |� � dkr4|r*||d< q@td��n |r@||d< |rL||d< |S )Nr Z paybytrafficZInternetMaxBandwidthOutzQex_internet_max_bandwidth_out is mandatory for PayByTraffic internet charge type.ZInternetMaxBandwidthIn)r r� )rk r� r� r� r� r r r r� � s � ��z&ECSDriver._get_internet_related_paramsc C sX t |t�std��|}d}dddd�}i }|�� D ] }||v r2|| |||| < q2|S )Nz ex_system_disk is not a dictz SystemDisk.r; r� r" )rA � disk_namer, )r r� r� r� )rk r� Z sys_disk_dict�key_base�mappingsr� �attrr r r r� � s � zECSDriver._get_system_diskc C s� t |t�r|g}nt |t�r"|}ntd��dddddddd �}i }t|�D ]^\}}d �|d �}|�� D ]>}||v rh|d kr�t|| ��� } n|| } | |||| < qhqJ|S ) Nz&ex_data_disks should be a list of dictrM r; rR r� r" r= r> )rP rA rT r+ r, rD rE z DataDisk.{0}.r� rE ) r r� r� r� � enumeraterU r� r� r ) rk r� r� r- r� �idx�diskr, r. r r r r r� � s. � zECSDriver._get_data_disksc C s4 t |d| jd�}t|�dkr d S | �|d td �S )NZ VpcAttributesr� r rW �r r� r� r r )rk r$ Zvpcsr r r r! � s � �z ECSDriver._get_vpc_attributesc C s4 t |d| jd�}t|�dkr d S | �|d td �S )NZ EipAddressr� r rX r2 )rk r$ Zeipsr r r r" s � �zECSDriver._get_eip_addressc C s4 t |d| jd�}t|�dkr d S | �|d td �S )NZOperationLocksr� r rY r2 )rk r$ �locksr r r r# s � �z ECSDriver._get_operation_locks� �X c s� t � � }|| }dd� |D �}t � � |k r�| j|d�}t|�t|�krndd� |D �} d|| d� } t| | d��� fdd�|D �} t| �t|�kr�d S t �|� q q td | | d��d S ) am Block until the provided nodes are in the desired state. :param nodes: List of nodes to wait for :type nodes: ``list`` of :class:`.Node` :param state: desired state :type state: ``NodeState`` :param wait_period: How many seconds to wait between each loop iteration. (default is 3) :type wait_period: ``int`` :param timeout: How many seconds to wait before giving up. (default is 600) :type timeout: ``int`` :return: if the nodes are in the desired state. :rtype: ``bool`` c S s g | ] }|j �qS r �rh �r� rV r r r r� ( r� z/ECSDriver._wait_until_state.<locals>.<listcomp>r� c S s g | ] }|j �qS r r6 r7 r r r r� - r� zRfound multiple nodes with same ids, desired ids: %(ids)s, found ids: %(found_ids)s)Zids� found_ids)r rj c s g | ]}|j � kr|�qS r �r� r7 r9 r r r� 2 s �TzTimed out after %s secondsN)�timer� r� r �sleep) rk r� r� Z wait_period�timeout�start�endZnode_idsZ matched_nodesr8 �msgZ desired_nodesr r9 r r� s& � �zECSDriver._wait_until_statec C s� t |d| jd�}t |d| jd�}tt |d| jd��}t |d| jd�}| j�|tj�}| �|td �}| � |�|d< t |||| ||d�S ) Nr� r� r� rM r rZ rY )r� r� ) r r� �int�VOLUME_STATE_MAPPINGr r r r r r# r )rk r r% ri rP � status_str�statusr� r r r r� > s ��zECSDriver._to_volumec C s, z t �|�W S ty& td��Y n0 d S )Nz$could not convert list to json array)�json�dumpsr' r� )rk r r r r r� K s z ECSDriver._list_to_json_arrayc C sb t |d| jd�}t |d| jd�}t |d| jd�}| j�|tj�}| �|td �}t|| |||d�S )NrR r� r* r r[ )rh rj r� �createdr� ) r r� �SNAPSHOT_STATE_MAPPINGr r r r r r )rk r r% rF rB r� r� r r r r� Q s ���zECSDriver._to_snapshotc C sl t |d| jd�}tt |d| jd��}i }tt |d| jd��|d< t |d| jd�|d< t|||d d d | |d�S ) NZInstanceTypeIdr� Z MemorySizeZ CpuCoreCountZcpu_core_countr( r/ )rh ri �ramr1 r8 Zpricerj r� )r r� �floatr@ r )rk r r% rH r� r r r r� \ s � � �zECSDriver._to_sizec C s0 t |d| jd�}t |d| jd�}t||d | d�S )Nr9 r� � LocalNamer )r r� r )rk r r% � localnamer r r r� g s zECSDriver._to_locationc C sT t |d| jd�}t |d| jd�}| �|td �}| �|�d��|d< t||| |d�S )Nr% r� r r\ ZDiskDeviceMappingsZdisk_device_mappings)rh ri rj r� )r r� r r �_get_disk_device_mappings�findr )rk r r% ri r� r r r r l s ��zECSDriver._to_imagec C s2 |d u r d S |� d�}|d ur.| �|td �S d S )NZDiskDeviceMappingr] )rM r r )rk r Zmapping_elementr r r rL u s �z#ECSDriver._get_disk_device_mappingsc C sd t |d| jd�}t |d| jd�}t |d| jd�}t |d| jd�}t |d| jd�}t|||| ||d�S )Nr� r� r� r" r3 r* )r, rj r5 r2 )r r� r )rk r r% ri r, r5 r2 r r r r� s ����z ECSDriver._to_security_groupc C sb t |d| jd�}t |d| jd�}t |d| jd�}t |d| jd�}t |d| jd�}t|||||d�S )NZ IpProtocolr� Z PortRangeZ SourceGroupId�Policyr� rr )r r� rq )rk r rs rt ru rv rw r r r r� � s ��z&ECSDriver._to_security_group_attributec C s� t |d| jd�}t |d| jd�}t|d| jd�}t|d| jd�}t|d| jd�}dd� }t||| tt||��tt||��tt||��d �S ) Nr& r� rJ z'AvailableResourceCreation/ResourceTypesz$AvailableInstanceTypes/InstanceTypesz&AvailableDiskCategories/DiskCategoriesc S s | j S rg r )r r r r �_text� s z!ECSDriver._to_zone.<locals>._textrx )r r� r r r� �map)rk r r% Z local_nameZresource_typesZinstance_types�disk_categoriesrO r r r r� � s4 �������zECSDriver._to_zonec C s8 t t|d��}t t|d��}t t|d��}t|||d�S )Nr� Z TotalCountr� r~ )r@ r r} )rk r Z page_numberZ total_countZ page_sizer r r �_get_pagination� s �zECSDriver._get_paginationc C sP g }| j �||�j}||�}||7 }| �|�}|�� du r<qL|�|�� � q|S )a� Request all resources by multiple pages. :param path: the resource path :type path: ``str`` :param params: the query parameters :type params: ``dict`` :param parse_func: the function object to parse the response body :param type: ``function`` :return: list of resource object, if not found any, return [] :rtype: ``list`` N)r� r� r� rR r� r� r� )rk r� r� Z parse_func�resultsZone_page� resourcesZ paginationr r r r� � s z!ECSDriver._request_multiple_pages)NN)N) NNNNNNNNNNNNN)F)F)F)NN)N)NNN)N)Nr� )N)N)N)NN)NNNNNN)NNN)NN)N)NNN)NNNN)N)NNN)r4 r5 )Sr_ r` ra rb ri Zwebsiter^ Z connectionCls�featuresr� r� r Zinternet_charge_typesr rQ r ZPENDINGr� r� r r ZINUSEr Z ATTACHINGZCREATINGrA r �ERRORrG 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 r r r r r� r r r� r� r� r! r" r# r� r� r� r� r� r� r rL r� r� r� rR r� r r r r r � s� �� � ' � � � ,� & � . � ! � * � % � ( ( r )-rb Z simplejsonrD � ImportErrorr: Zlibcloud.common.aliyunr r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r Zlibcloud.compute.typesr r r Zlibcloud.utils.py3r r Zlibcloud.utils.xmlr r r �__all__r rd ZDEFAULT_SIGNATURE_VERSIONr! r@ r r^ r� r rq r r r r} r r r r r �<module> s� $ ���������������<������������������������������H���������$���������������<�������� � � & $
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка