File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/ecs.cpython-310.pyc
Back
o ;jE� � @ s� d Z zddlZW n ey ddlZY nw ddlZddlmZ ddlm Z m Z m Z ddl m Z ddlmZmZmZmZmZmZmZ ddlmZmZ 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�ii d*d+ed��d,ded��d-ded��d.d/ed��d0d1ed��d2ded��d3d4ed��d5d6ed��d7d8e!d��d9d:ed��d;d<ed��d=d>e!d��d?d@e!d��dAded��dBdCed��dDdEed��dFdGed��dHed�ded�dIed�dJed�dKe"d�dLed�d6ed�dMed�dN�dOed�dPed�dQed�dRed�ded�dSe"d�dTed�dUed�d6ed�dVe!d�dIed�ded�dMed�dWe!d�dX�dYed�dSe"d�d<ed�dZed�d[ed�d\ed�d]�d^�Z#G d_d`� d`e�Z$G dadb� db�Z%G dcdd� dd�Z&G dedf� df�Z'G dgd� d�Z(G dhdi� di�Z)G djdk� dk�Z*G dldm� dme�Z+dS )nz Node driver for Aliyun. � N)� _real_unicode)�findall�findattr�findtext)� LibcloudError)�Node�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume�VolumeSnapshot)�AliyunXmlResponse�SignedAliyunConnection)� NodeState�StorageVolumeState�VolumeSnapshotState)� DiskCategory�InternetChargeType�ECS_API_VERSION� ECSDriver�ECSSecurityGroup�ECSZonez 2014-05-26zecs.aliyuncs.comz1.0c C s& t | t�r| S t| ��� dkrdS dS )N�trueTF)� isinstance�bool�u�lower)�value� r �P/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/ecs.py� _parse_bool8 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� region_id�RegionIdr. r, �type�Type�category�Categoryr- Zsource_snapshot_idZSourceSnapshotId� product_codeZ ProductCodeZportableZPortable� instance_id� InstanceId�device�Device�delete_with_instance�DeleteWithInstanceZenable_auto_snapshotZEnableAutoSnapshotr2 Z attached_timeZ AttachedTimeZ detached_timeZ DetachedTimeZdisk_charge_typeZDiskChargeType� SnapshotNameZProgressZ SourceDiskIdZSourceDiskSizeZSourceDiskTypeZUsage)Z snapshot_namer, �progressZsource_disk_idZsource_disk_sizeZsource_disk_typer? �usage� ImageVersionZOSTypeZPlatformZ Architecture�SizeZImageOwnerAliasZOSNameZ IsSubscribedZIsCopied)Z image_versionZos_type�platform� architecturer, �sizeZimage_owner_alias�os_namer? Z is_subscribedrG r2 rH Z is_copied� SnapshotIdZFormatZImportOSSBucketZImportOSSObject)� snapshot_idrM rB �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 responseClsZ service_namer r r r rZ � � rZ c @ s" e Zd ZdZddd�Zdd� ZdS )r zS Security group used to control nodes internet and intranet accessibility. Nc C �( || _ || _|| _|| _|| _|| _d S �N)�id�namer, �driverr5 r2 )�selfre rf r, rg r5 r2 r r r �__init__� s zECSSecurityGroup.__init__c C s d� | j| j| jj�S )Nz1<ECSSecurityGroup: id={}, name={}, driver={} ...>�rQ re rf rg �rh r r r �__repr__� s �zECSSecurityGroup.__repr__�NNNN�r[ r\ r] r^ ri rl r r r r r � s r c @ s, e Zd ZdZ ddd�Zdd� ZdS )�ECSSecurityGroupAttributez# Security group attribute. Nc C s" || _ || _|| _|| _|| _d S rd �� ip_protocol� port_range�source_group_id�policy�nic_type)rh rq rr rs rt ru r r r ri � s z"ECSSecurityGroupAttribute.__init__c C s d| j S )Nz/<ECSSecurityGroupAttribute: ip_protocol=%s ...>)rq rk r r r rl � s z"ECSSecurityGroupAttribute.__repr__)NNNNNrn r r r r ro � s � ro c @ s* e Zd ZdZ ddd�Zdd� ZdS )r zE ECSZone used to represent an availability zone in a region. Nc C rc rd �re rf rg �available_resource_types�available_instance_types�available_disk_categories)rh re rf rg rw rx ry r r r ri � s zECSZone.__init__c C s d� | j| j| j�S )Nz$<ECSZone: id={}, name={}, driver={}>rj rk r r r rl � s �zECSZone.__repr__rm rn 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\ r] r^ 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. ZcloudZcloud_efficiencyZ cloud_ssdZ ephemeral_ssdN)r[ r\ r] r^ ZCLOUDZCLOUD_EFFICIENCYZ CLOUD_SSDZ EPHEMERAL_SSDr r r r r � rb 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��totalrM �current)rh r| rM r} r r r ri s zPagination.__init__c C s2 | j du s| j| j | j krdS | jd7 _| S )z� Switch to the next page. :return: the new pagination or None when no more page :rtype: ``Pagination`` N� r{ rk r r r �next s zPagination.nextc C s | j | jd�S )N)� PageNumber�PageSize)r} rM rk r r r �to_dict& � zPagination.to_dictc C s d| j | j| jf S )Nz/<Pagination total=%d, size=%d, current page=%d>r{ rk r r r rl ) s �zPagination.__repr__N)r[ r\ r] r^ ri r r� rl r r r r rz s rz c @ s� 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#d~dd�Z$d d � Z%d~d d �Z&d{d d!�Z'd|d"d#�Z(dd$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�Z0 d�d5d6�Z1dd7d8�Z2d{d9d:�Z3d|d;d<�Z4d=d>� Z5d?d@� Z6ddAdB�Z7 d�dCdD�Z8dEdF� Z9d|dGdH�Z: ddIdJ�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�}|rt|t�r| �|�|d< ntd��|r*t|t�r&|�|� 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 matches 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��Actionr: 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)rh � 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 � g | ]}� � |��qS r )�_to_size��.0Zeachrk r r � <listcomp>� � z(ECSDriver.list_sizes.<locals>.<listcomp>�� connection�requestr� �objectr r� )rh �locationr� � resp_bodyZ size_elementsZsizesr rk r � list_sizes� � zECSDriver.list_sizesc s@ ddi}� j �� j|�j}t|d� jd�}� fdd�|D �}|S )Nr� ZDescribeRegionszRegions/Regionr� c r� r )� _to_locationr� rk r r r� � r� z,ECSDriver.list_locations.<locals>.<listcomp>r� )rh r� r� Zlocation_elementsZ locationsr rk r �list_locations� r� zECSDriver.list_locationsc K sz d| j |j|j|d�}|std��||d< |r||d< | �|| |�}|r)|�|� | r/| |d< |r;| �|�}|j|d< | durP| }t|t�rL|rJd nd }||d < | r^| � | �}|r^|�|� | rl| � | �}|rl|�|� |rr||d < |r~|sztd ��||d< |r�||d< | j j | j |d�}t|jd| jd�}| j|gd�}t|�dkr�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� r: 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� rA �r# r� �r� r~ z0could not find the new created node with id %s. �rg r )r� re 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)rh rf rM rX ZauthZex_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� rR r r r r� � st X�� � � 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� rA Z ForceStopr� ) re r r r� r� r� �successr� r r� �rh rR � ex_force_stopr� r� r r r � reboot_node0 s �zECSDriver.reboot_nodec C s� | j |jgd�}t|�dkr |j|d jkr td|j ��|d }|jtjkr3| �|� | �|tj � d|jd�}| j � | j |�}|� � S )Nr� r~ r z#could not find the node with id %s.ZDeleteInstance�r� rA )r� re r� r �stater r� � ex_stop_noder� �STOPPEDr� r� r� r� )rh rR r� r} r� r� r r r � destroy_nodeC s zECSDriver.destroy_nodec C s4 d|j d�}| j�| j|�}|�� o| �|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� )re r� r� r� r� r� r r� )rh rR r� r� r r r � start_nodeP 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� ) re 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)rR )r� )rh rR r r r r� u s zECSDriver.ex_start_nodec C s | j ||d�S )N)rR r� )r� )rh rR 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� )rh 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� r: r� )r� r� r� r� r� )rh �group_idr� r� r r r � ex_delete_security_group_by_id� s �z(ECSDriver.ex_delete_security_group_by_idc C sP d| j d�}|s td��||d< |r||d< |r ||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� )rh r� rf r, r� r� r r r � ex_modify_security_group_by_id� s z(ECSDriver.ex_modify_security_group_by_idc sD d� j d�}|rt|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 �& t | d� jd�}� fdd�|D �}|S )Nz SecurityGroups/SecurityGroupr� c r� r )�_to_security_group�r� �elrk r r r� � r� zNECSDriver.ex_list_security_groups.<locals>._parse_response.<locals>.<listcomp>�r r� )� resp_objectZ sg_elementsZsgsrk r r �_parse_response� s �z:ECSDriver.ex_list_security_groups.<locals>._parse_response)r� r r� r� r� r� )rh r� r� r� r rk r �ex_list_security_groups� s z!ECSDriver.ex_list_security_groups�internetc sZ d� j |d�}|du rtd��||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� r: �NicTypeNr� r� zPermissions/Permissionr� c r� r )� _to_security_group_attributer� rk r r r� � r� z?ECSDriver.ex_list_security_group_attributes.<locals>.<listcomp>)r� r� r� r� r� r� r r� )rh r� ru r� r� Z sga_elementsr rk r �!ex_list_security_group_attributes� s �z+ECSDriver.ex_list_security_group_attributesc C �\ |du rt d��|jtjkr|jtjkrtd|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� rA r� � r� r� r r� r� r re r� r� r� r� �rh rR r� r� r� r r r �ex_join_security_group� � ��z ECSDriver.ex_join_security_groupc C r� )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 r� 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 DescribeZonesr: z Zones/Zoner� c r� r )�_to_zoner� rk r r r� ; r� z+ECSDriver.ex_list_zones.<locals>.<listcomp>)r� r� r� r� r� r r� )rh r9 r� r� Z zone_elementsZzonesr rk r � ex_list_zones* s zECSDriver.ex_list_zonesc s~ d� j d�}|rt|t�r� �|�|d< ntd��|r1t|t�s$td��|�� D ]}|| ||< q(� 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 matches 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 r� )Nz Disks/Diskr� c r� r )� _to_volumer� rk r r r� e r� zCECSDriver.list_volumes.<locals>._parse_response.<locals>.<listcomp>r� )r� Z disk_elements�volumesrk r r r� c � z/ECSDriver.list_volumes.<locals>._parse_response) r� r r� r� r� r� �keysr� r� )rh � ex_volume_idsr� r� �keyr� r rk r � list_volumesB s zECSDriver.list_volumesc sz d� j d�}|r |j|d< |rt|t�r� �|�|d< |r/t|t�r/|�� D ]}|| ||< q&� 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 matches 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 r� )NzSnapshots/Snapshotr� c r� r )� _to_snapshotr� rk r r r� � r� zLECSDriver.list_volume_snapshots.<locals>._parse_response.<locals>.<listcomp>r� )r� �snapshot_elements� snapshotsrk r r r� � r� z8ECSDriver.list_volume_snapshots.<locals>._parse_response) r� re r r� r� r� r� r� r� )rh rV �ex_snapshot_idsr� r� r� r� r rk r �list_volume_snapshotsj s z ECSDriver.list_volume_snapshotsc C s� d| j ||d�} |du rtd��|| d< |dur"t|t�r"|j| d< |r(|| d< |r.|| d< |r4|| d < | j�| j| �j} t | d | j d �} | j | gd �} t | �d krZt 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� r: �DiskNamerJ Nzex_zone_id is requiredr& rO r" r r� r� r� �r� r~ z0could not find the new create volume with id %s.r� r )r� r� r r re r� r� r� r� r r� r� r� r ) rh rM rf r� rW Z ex_zone_idr� Zex_disk_categoryr� r� r� Z volume_idr� r r r � create_volume� s2 � �zECSDriver.create_volumec C s� d|j d�}|r ||d< |r||d< |r||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� rO r� N)rV r� r~ z/could not find new created snapshot with id %s.r� r ) re r� r� r� r� r r� r� r� r ) rh rV rf r� r� r� r� rP r� r r r �create_volume_snapshot� s �z ECSDriver.create_volume_snapshotc C sL d|j |j d�}|r||d< |rtt|���� |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� rA r� rC rE )re �strr r r� r� r� r� )rh rR rV rB 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|�dkr"td|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� rA r� r~ zUcould not find the instance id the volume %s attached to, ex_instance_id is required.r r@ ) re r� r� r� �extrar� r� r� r� )rh rV 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 jtjkr+td| 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.) re r� r� r r� r � AVAILABLEr� r� r� r� )rh rV r� r� r� r r r �destroy_volume s �zECSDriver.destroy_volumec C sB ddi}|rt |t�r|j|d< ntd��| j�| j|�}|�� S )Nr� ZDeleteSnapshotrO z1snapshot is required and must be a VolumeSnapshot)r r re r� r� r� r� r� )rh rW r� r� r r r �destroy_volume_snapshot! s z!ECSDriver.destroy_volume_snapshotc s� |r t |t�r |j}n� j}d|d�}|r&t |t�r"d�|�|d< ntd��|r:t |t�r:|�� D ]}|| ||< q1� 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 matches 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 r� )Nz Images/Imager� c r� r )� _to_imager� rk r r r� Q r� zBECSDriver.list_images.<locals>._parse_response.<locals>.<listcomp>r� )r� Zimage_elements�imagesrk r r r� O r� z.ECSDriver.list_images.<locals>._parse_response) r r re r� r� �joinr� r� r� r� r� )rh r� � ex_image_idsr� r� r� r� r� r rk r � list_images/ s zECSDriver.list_imagesc C s� d| j d�}|r ||d< |r||d< |r||d< ntd��|r#||d< |r)||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" rO zex_snapshot_id is requiredrI r� r% r� �r- ) r� r� r� r� r� r r� r� � get_image) rh rR rf r, Zex_snapshot_idZex_image_versionr� r� r� r- r r r � create_imageV s zECSDriver.create_imagec C s( d| j |jd�}| j�| j|�}|�� S )NZ DeleteImage�r� r: r% )r� re r� r� r� r� )rh � node_imager� r� r r r � delete_image� s �zECSDriver.delete_imagec C sT |r|}n| j }t|d d | d�}| j||gd�}t|�dkr&td| | d��|d S )N�re rf Zcountryrg )r r~ z#could not find the image with id %sr� r )r� r r r� r )rh 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< |r||d< |r!||d< |r'||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 ) re r� r� r� r� r r� r� r ) rh Z source_regionr rf 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� )rh r@ 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 r� r )�_to_noder� rk r r r� � r� z'ECSDriver._to_nodes.<locals>.<listcomp>r� )rh r� Z node_elementsr rk r r� � s zECSDriver._to_nodesc C s� t |d| jd�}t |d| jd�}t |d| jd�}| j�|tj�}dd� }g }dD ]}t||| jd�} |�|| �� q(g } dD ]}t||| jd�} | �|| �� q>| �|t d �} | � |�| d < | � |�| d < | � |�| d < t ||||| | jj| d �} | S )z� Convert an InstanceAttributesType object to ``Node`` object :param instance: a xml element represents an instance :return: a ``Node`` object :rtype: ``Node`` rA ��elementr# r� r� �Statusc S s dd� | D �S )Nc S s g | ]}|j r|j �qS r ��textr� r r r r� � s z8ECSDriver._to_node.<locals>._get_ips.<locals>.<listcomp>r )Zip_address_elsr r r �_get_ips� r� z$ECSDriver._to_node.<locals>._get_ips)zPublicIpAddress/IpAddresszEipAddress/IpAddress)zInnerIpAddress/IpAddressz(VpcAttributes/PrivateIpAddress/IpAddressrR rS Z eip_addressrU )re rf r� � public_ips� private_ipsrg r� )r r� �NODE_STATE_MAPPING�getr �UNKNOWNr �extend�_get_extra_dict� RESOURCE_EXTRA_ATTRIBUTES_MAP�_get_vpc_attributes�_get_eip_address�_get_operation_locksr r� rg )rh �instance�_idrf Zinstance_statusr� r r r# Z public_ip_elsr Zprivate_ip_elsr� rR r r r r � s> �� zECSDriver._to_nodec C sn i }|� � D ].\}}|d }t||d | jd�}|r0z||�||< W q ty/ d||< Y qw |||< 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)rh r �mappingr� Z attribute�valuesr$ r r r r r! s � zECSDriver._get_extra_dictc C sN i }|r ||d< |� � dkr|r||d< n td��|r ||d< |r%||d< |S )Nr Z paybytrafficZInternetMaxBandwidthOutzQex_internet_max_bandwidth_out is mandatory for PayByTraffic internet charge type.ZInternetMaxBandwidthIn)r r� )rh r� r� r� r� r r r r� " s �z&ECSDriver._get_internet_related_paramsc C sX t |t�s td��|}d}dddd�}i }|�� D ]}||v r)|| |||| < q|S )Nz ex_system_disk is not a dictz SystemDisk.r> r� r" )r= � disk_namer, )r r� r� r� )rh r� Z sys_disk_dict�key_base�mappingsr� �attrr r r r� ; s � �zECSDriver._get_system_diskc C s� t |t�r |g}n t |t�r|}ntd��dddddddd �}i }t|�D ]/\}}d �|d �}|�� D ] }||v rS|d krGt|| ��� } n|| } | |||| < q4q%|S ) Nz&ex_data_disks should be a list of dictrJ r> rO r� r" rC rE )rM r= rP r, r, rB rD z DataDisk.{}.r~ rD ) r r� r� r� � enumeraterQ r� r� r ) rh r� r� r. r� �idx�diskr- r/ r r r r r� L s2 � ��zECSDriver._get_data_disksc C �4 t |d| jd�}t|�dkrd S | �|d td �S )NZ VpcAttributesr� r rS �r r� r� r! r" )rh r& Zvpcsr r r r# j � z ECSDriver._get_vpc_attributesc C r3 )NZ EipAddressr� r rT r4 )rh r& Zeipsr r r r$ p r5 zECSDriver._get_eip_addressc C r3 )NZOperationLocksr� r rU r4 )rh r& �locksr r r r% v r5 z ECSDriver._get_operation_locks� �X c s� t � � }|| }dd� |D �}t � � |k rP| j|d�}t|�t|�kr7dd� |D �} d|| d� } t| | d��� fdd�|D �} t| �t|�krJd S t �|� qtd | | d��) 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 � g | ]}|j �qS r �re �r� rR r r r r� � � z/ECSDriver._wait_until_state.<locals>.<listcomp>r� c S r9 r r: r; r r r r� � r< zRfound multiple nodes with same ids, desired ids: %(ids)s, found ids: %(found_ids)s)Zids� found_ids)r rg c s g | ] }|j � kr|�qS r �r� r; r> r r r� � s TzTimed out after %s seconds)�timer� r� r �sleep) rh r� r� Z wait_period�timeout�start�endZnode_idsZ matched_nodesr= �msgZ desired_nodesr r> 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� rJ r rV rU )r� r� ) r r� �int�VOLUME_STATE_MAPPINGr r r r! r" r% r )rh r r' rf rM � status_str�statusr� r r r r� � s zECSDriver._to_volumec C s$ zt �|�W S ty td��w )Nz$could not convert list to json array)�json�dumpsr) r� )rh r r r r r� � s �z ECSDriver._list_to_json_arrayc C sb t |d| jd�}t |d| jd�}t |d| jd�}| j�|tj�}| �|td �}t|| |||d�S )NrO r� r* r rW )re rg r� �createdr� ) r r� �SNAPSHOT_STATE_MAPPINGr r r r! r" r )rh r r' rK rG r� r� r r r r� � 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/ )re rf �ramr2 r8 Zpricerg r� )r r� �floatrE r )rh r r' rM r� r r r r� � s" ��zECSDriver._to_sizec C s0 t |d| jd�}t |d| jd�}t||d | d�S )Nr: r� � LocalNamer )r r� r )rh r r' Z localnamer r r r� � s zECSDriver._to_locationc C sT t |d| jd�}t |d| jd�}| �|td �}| �|�d��|d< t||| |d�S )Nr% r� r rX ZDiskDeviceMappingsZdisk_device_mappings)re rf rg r� )r r� r! r" �_get_disk_device_mappings�findr )rh r r' rf r� r r r r � s �zECSDriver._to_imagec C s2 |d u rd S |� d�}|d ur| �|td �S d S )NZDiskDeviceMappingrY )rQ r! r" )rh r Zmapping_elementr r r rP � 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, rg r5 r2 )r r� r )rh r r' rf 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� rp )r r� ro )rh r rq rr rs rt ru 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� rO z'AvailableResourceCreation/ResourceTypesz$AvailableInstanceTypes/InstanceTypesz&AvailableDiskCategories/DiskCategoriesc S s | j S rd r )r r r r �_text s z!ECSDriver._to_zone.<locals>._textrv )r r� r r r� �map)rh r r' Z local_nameZresource_typesZinstance_types�disk_categoriesrS r r r r� s( ��� �zECSDriver._to_zonec C s8 t t|d��}t t|d��}t t|d��}t|||d�S )Nr� Z TotalCountr� r{ )rE r rz )rh r Z page_numberZ total_countZ page_sizer r r �_get_pagination s zECSDriver._get_paginationc C sR g } | j �||�j}||�}||7 }| �|�}|�� du r! |S |�|�� � q)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`` TN)r� r� r� rV r r� r� )rh r� r� Z parse_func�resultsZone_pageZ resourcesZ paginationr r r r� $ s ��z!ECSDriver._request_multiple_pages)NNrd ) NNNNNNNNNNNNN)F)NNN)Nr� )NNNNNNrm )r7 r8 )Sr[ r\ r] r^ rf ZwebsiterZ Z connectionClsZfeaturesr� r� r Zinternet_charge_typesr rU r ZPENDINGr� r� r r ZINUSEr Z ATTACHINGZCREATINGrF r �ERRORrL 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 rP r� r� r� rV r� r r r r r 1 s� �� � # � ! (& � 9 + �+ �) / ( r ),r^ Z simplejsonrI � ImportErrorr? Zlibcloud.utils.py3r r Zlibcloud.utils.xmlr r r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r Zlibcloud.common.aliyunr r Zlibcloud.compute.typesr r r �__all__r r` ZDEFAULT_SIGNATURE_VERSIONr! rE r" rZ r ro r r r rz r r r r r �<module> s � $ ��� � � � � � � � � � � � � ���� � � � �� ���_ '
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings