Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/__pycache__/ecs.cpython-39.pyc
Ðазад
a q�h�P � @ s� z d dl ZW n ey& d dlZY n0 d dlmZmZmZmZ d dlm Z d dl m Z d dl m Z mZ dgZdZdZd Zd Zd Zd e�d d� Zde�d d� ZG dd� de �ZG dd� de �ZG dd� de�ZdS )� N)�ContainerDriver� Container�ContainerCluster�ContainerImage)�ContainerState)�RegistryClient)�SignedAWSConnection�AWSJsonResponse�ElasticContainerDriverz 2014-11-13z 2015-09-21zecs.%s.amazonaws.comzecr.%s.amazonaws.com�/z AmazonEC2ContainerServiceV%s�-� z AmazonEC2ContainerRegistry_V%sc @ s e Zd ZeZeZeZdZ dS )�ECSJsonConnectionZecsN) �__name__� __module__� __qualname__� ECS_VERSION�version�ECS_HOST�hostr � responseCls� service_name� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/ecs.pyr + s r c @ s e Zd ZeZeZeZdZ dS )�ECRJsonConnectionZecrN) r r r � ECR_VERSIONr �ECR_HOSTr r r r r r r r r 2 s r c s< e Zd ZdZdZdZeZeZ dZ de j iZ � fdd�Zdd � Zd d � Zd d � ZdIdd�Zdd� ZdJdd�ZdKdd�Zdd� ZdLd d �Zd d � Zd!d"� Zd#d$� ZdMd%d&�Zd'd(� Z dNd)d*�Z dOd+d,�Z d-d.� Z d/d0� Z d1d2� Z!d3d4� Z"d5d6� Z#d7d8� Z$d9d:� Z%d;d<� Z&d=d>� Z'd?d@� Z(dAdB� Z)dCdD� Z*dEdF� Z+dGdH� Z,� Z-S )Pr z Amazon Elastic Container Servicez#https://aws.amazon.com/ecs/details/z%s.dkr.ecr.%s.amazonaws.comF�RUNNINGc sj t t| ��||� || _|| _t| | j_| �� }| j ||fi |��| _ t | | j _| | j _ | j � � d S �N)�superr �__init__�regionZ region_namer � connectionr �_ex_connection_class_kwargs�ecrConnectionClass�ecr_connectionr �driver�connect)�selfZ access_id�secretr! Z conn_kwargs�� __class__r r r D s �� z ElasticContainerDriver.__init__c C s ddiS )NZsignature_version�4r )r( r r r r# R s z2ElasticContainerDriver._ex_connection_class_kwargsc C sT i }||d< | j jtdt�|�| �d�d�j}| �|�}| �|�}| � |d ||�S )aJ List the images in an ECR repository :param ex_repository_name: The name of the repository to check defaults to the default repository. :type ex_repository_name: ``str`` :return: a list of images :rtype: ``list`` of :class:`libcloud.container.base.ContainerImage` ZrepositoryName�POSTZ ListImages��method�data�headersZimageIds) r% �request�ROOT�json�dumps�_get_ecr_headers�object�ex_get_repository_id� _get_ecr_host� _to_images)r( Zex_repository_namer2 � list_response� repository_idr r r r � list_imagesU s � �z"ElasticContainerDriver.list_imagesc C sZ | j jtdt�i �| �d�d�j}d|d i}| j jtdt�|�| �d�d�j}| �|�S )a Get a list of potential locations to deploy clusters into :param location: The location to search in :type location: :class:`libcloud.container.base.ClusterLocation` :rtype: ``list`` of :class:`libcloud.container.base.ContainerCluster` r- Z ListClustersr. �clustersZ clusterArnsZDescribeClusters)r" r2 r3 r4 r5 � _get_headersr7 � _to_clusters)r( Zlistdatar2 r0 r r r � list_clustersn s � �z$ElasticContainerDriver.list_clustersNc C s8 d|i}| j jtdt�|�| �d�d�j}| �|d �S )aH Create a container cluster :param name: The name of the cluster :type name: ``str`` :param location: The location to create the cluster in :type location: :class:`libcloud.container.base.ClusterLocation` :rtype: :class:`libcloud.container.base.ContainerCluster` � clusterNamer- Z CreateClusterr. �cluster)r" r2 r3 r4 r5 r? r7 � _to_cluster)r( �name�locationr2 �responser r r �create_cluster� s �z%ElasticContainerDriver.create_clusterc C s< d|j i}| jjtdt�|�| �d�d�j}|d d dkS )z� Delete a cluster :return: ``True`` if the destroy was successful, otherwise ``False``. :rtype: ``bool`` rC r- Z DeleteClusterr. �statusZINACTIVE��idr" r2 r3 r4 r5 r? r7 )r( rC r2 r0 r r r �destroy_cluster� s �z&ElasticContainerDriver.destroy_clusterc C st ddi}|dur|j |d< |dur,|j|d< | jjtdt�|�| �d�d�j}t |d �d krbg S | � |d �}|S ) a� List the deployed container images :param image: Filter to containers with a certain image :type image: :class:`libcloud.container.base.ContainerImage` :param cluster: Filter to containers in a cluster :type cluster: :class:`libcloud.container.base.ContainerCluster` :rtype: ``list`` of :class:`libcloud.container.base.Container` rC �defaultN�familyr- Z ListTasksr. ZtaskArnsr ) rK rE r" r2 r3 r4 r5 r? r7 �len�ex_list_containers_for_task)r( �imagerC r2 r; � containersr r r �list_containers� s" ��z&ElasticContainerDriver.list_containersT� �� c C s� i } |du r| du rg } n || d�g} g ||j |g || dg d� g| d< || d< | jjtdt�| �| �d�d �j} |r�| �| d d �d S t d||t j g d | d d i| jj d �S dS )a� Creates a task definition from a container image that can be run in a cluster. :param name: The name of the new container :type name: ``str`` :param image: The container image to deploy :type image: :class:`libcloud.container.base.ContainerImage` :param cluster: The cluster to deploy to, None is default :type cluster: :class:`libcloud.container.base.ContainerCluster` :param parameters: Container Image parameters :type parameters: ``str`` :param start: Start the container on deployment :type start: ``bool`` :rtype: :class:`libcloud.container.base.Container` N)Z containerPortZhostPortT) Z mountPointsrE rQ �cpu� environmentZmemoryZ portMappingsZ essentialZ volumesFromZcontainerDefinitionsrN r- ZRegisterTaskDefinitionr. �taskDefinition�taskDefinitionArnr )rK rE rQ �state� ip_addresses�extrar& ) rE r" r2 r3 r4 r5 r? r7 � ex_start_taskr r r r& ) r( rE rQ rC � parameters�startZex_cpuZ ex_memoryZex_container_portZ ex_host_portr0 Z port_mapsrG r r r �deploy_container� sT ���� � �� ��z'ElasticContainerDriver.deploy_containerc C s | � |g�}|d S )z� Get a container by ID :param id: The ID of the container to get :type id: ``str`` :rtype: :class:`libcloud.container.base.Container` r )rP )r( rK rR r r r � get_container s z$ElasticContainerDriver.get_container� c C s | � |jd |�S )a- Start a deployed task :param container: The container to start :type container: :class:`libcloud.container.base.Container` :param count: Number of containers to start :type count: ``int`` :rtype: :class:`libcloud.container.base.Container` rY )r] r\ )r( � container�countr r r �start_container s z&ElasticContainerDriver.start_containerc C sT d|j d i}| jjtdt�|�| �d�d�j}g }|�| � |d |j d �� |S )z� Stop a deployed container :param container: The container to stop :type container: :class:`libcloud.container.base.Container` :rtype: :class:`libcloud.container.base.Container` �task�taskArnr- ZStopTaskr. rY ) r\ r" r2 r3 r4 r5 r? r7 �extend�_to_containers)r( rc r2 rG rR r r r �stop_container) s ��z%ElasticContainerDriver.stop_containerc C s | � |� | �|�S )z� Restart a deployed container :param container: The container to restart :type container: :class:`libcloud.container.base.Container` :rtype: :class:`libcloud.container.base.Container` )rj re �r( rc r r r �restart_container? s z(ElasticContainerDriver.restart_containerc C s | � |�S )z� Destroy a deployed container :param container: The container to destroy :type container: :class:`libcloud.container.base.Container` :rtype: :class:`libcloud.container.base.Container` )rj rk r r r �destroy_containerK s z(ElasticContainerDriver.destroy_containerc C sX d}||d�}| j jtdt�|�| �d�d�j}g }|d D ]}|�| �||�� q<|S )a, Run a task definition and get the containers :param task_arn: The task ARN to Run :type task_arn: ``str`` :param count: The number of containers to start :type count: ``int`` :rtype: ``list`` of :class:`libcloud.container.base.Container` N)rd rX r- ZRunTaskr. �tasks� r" r2 r3 r4 r5 r? r7 rh ri )r( Ztask_arnrd r2 rG rR rf r r r r] V s �� z$ElasticContainerDriver.ex_start_taskc C sV d|i}| j jtdt�|�| �d�d�j}g }|d D ]}|�| �||d �� q6|S )z� Get a list of containers by ID collection (ARN) :param task_arns: The list of ARNs :type task_arns: ``list`` of ``str`` :rtype: ``list`` of :class:`libcloud.container.base.Container` rn r- Z DescribeTasksr. rY ro )r( Z task_arnsZdescribe_requestZdescripe_responserR rf r r r rP p s � �z2ElasticContainerDriver.ex_list_containers_for_taskc C s: ||||j d�}| jjtdt�|�| �d�d�j}|d S )a$ Runs and maintains a desired number of tasks from a specified task definition. If the number of tasks running in a service drops below desired_count, Amazon ECS spawns another instantiation of the task in the specified cluster. :param name: the name of the service :type name: ``str`` :param cluster: The cluster to run the service on :type cluster: :class:`libcloud.container.base.ContainerCluster` :param task_definition: The task definition name or ARN for the service :type task_definition: ``str`` :param desired_count: The desired number of tasks to be running at any one time :type desired_count: ``int`` :rtype: ``object`` The service object )Z serviceNamerX Z desiredCountrC r- Z CreateServicer. �servicerJ )r( rE rC Ztask_definitionZ desired_countr2 rG r r r �ex_create_service� s ��z(ElasticContainerDriver.ex_create_servicec C s@ i }|dur|j |d< | jjtdt�|�| �d�d�j}|d S )z� List the services :param cluster: The cluster hosting the services :type cluster: :class:`libcloud.container.base.ContainerCluster` :rtype: ``list`` of ``str`` NrC r- Z ListServicesr. Z serviceArnsrJ )r( rC r2 rG r r r �ex_list_service_arns� s �z+ElasticContainerDriver.ex_list_service_arnsc C s8 d|gi}| j jtdt�|�| �d�d�j}|d d S )aF Get the details of a service :param cluster: The hosting cluster :type cluster: :class:`libcloud.container.base.ContainerCluster` :param service_arn: The service ARN to describe :type service_arn: ``str`` :return: The service object :rtype: ``object`` Zservicesr- ZDescribeServicesr. r �r" r2 r3 r4 r5 r? r7 �r( Z service_arnr2 rG r r r �ex_describe_service� s �z*ElasticContainerDriver.ex_describe_servicec C s2 d|i}| j jtdt�|�| �d�d�j}|d S )z� Deletes a service :param cluster: The target cluster :type cluster: :class:`libcloud.container.base.ContainerCluster` :param service_arn: The service ARN to destroy :type service_arn: ``str`` rp r- Z DeleteServicer. rs rt r r r �ex_destroy_service� s ��z)ElasticContainerDriver.ex_destroy_servicec C s, | � |�}| �|�}| �|�}t|d|d�S )a Get a client for an ECR repository :param repository_name: The unique name of the repository :type repository_name: ``str`` :return: a docker registry API client :rtype: :class:`libcloud.container.utils.docker.RegistryClient` ZAWS)r �username�password)r8 �ex_get_repository_tokenr9 r )r( �repository_namer< �tokenr r r r �ex_get_registry_client� s �z-ElasticContainerDriver.ex_get_registry_clientc C s< d|gi}| j jtdt�|�| �d�d�j}|d d d S )z� Get the authorization token (12 hour expiry) for a repository :param repository_id: The ID of the repository :type repository_id: ``str`` :return: A token for login :rtype: ``str`` Z RegistryIdsr- ZGetAuthorizationTokenr. ZauthorizationDatar ZauthorizationToken�r% r2 r3 r4 r5 r6 r7 )r( r< r2 rG r r r ry � s �z.ElasticContainerDriver.ex_get_repository_tokenc C s@ d|gi}| j jtdt�|�| �d�d�j}|d d d }|S )z� Get the ID of a repository :param repository_name: The unique name of the repository :type repository_name: ``str`` :return: The repository ID :rtype: ``str`` ZrepositoryNamesr- ZDescribeRepositoriesr. Z repositoriesr Z registryIdr} )r( rz r2 r; r< r r r r8 s �z+ElasticContainerDriver.ex_get_repository_idc C s | j || jf S r )�ecr_repository_hostr! )r( r< r r r r9 # s �z$ElasticContainerDriver._get_ecr_hostc C s dt |f dd�S )zF Get the default headers for a request to the ECS API �%s.%s�application/x-amz-json-1.1�z x-amz-targetz Content-Type)�ECS_TARGET_BASE�r( �actionr r r r? ( s ��z#ElasticContainerDriver._get_headersc C s dt |f dd�S )zF Get the default headers for a request to the ECR API r r� r� )�ECR_TARGET_BASEr� r r r r6 1 s ��z'ElasticContainerDriver._get_ecr_headersc C s& g }|d D ]}|� | �|�� q |S )Nr> )�appendrD )r( r0 r> rC r r r r@ : s z#ElasticContainerDriver._to_clustersc C s t |d |d | jjd�S )NZ clusterArnrB )rK rE r& )r r" r& )r( r0 r r r rD @ s �z"ElasticContainerDriver._to_clusterc C s( g }|d D ]}|� | �||�� q |S )NrR )r� � _to_container)r( r0 �task_definition_arnr> rC r r r ri G s z%ElasticContainerDriver._to_containersc C sP t |d |d td |d d d | jjd�d | j�|d d �|d |d�| jjd�S )NZ containerArnrE �rK rE �pathr r& Z lastStatusrg )rg rY )rK rE rQ r[ rZ r\ r& )r r r" r& � status_map�get)r( r0 r� r r r r� M s" ���z$ElasticContainerDriver._to_containerc C s& g }|D ]}|� | �|||�� q|S r )r� � _to_image)r( r0 r rz ZimagesrQ r r r r: a s z!ElasticContainerDriver._to_imagesc C s, d|||d f }t d |||d | jjd�S )Nz%s/%s:%sZimageTagr� )r r" r& )r( r0 r rz r� r r r r� g s ��z ElasticContainerDriver._to_image)N)NN)NNTrT rU NN)rb )rb )rb )N).r r r rE Zwebsiter~ r Z connectionClsr r$ Zsupports_clustersr r r� r r# r= rA rH rL rS r` ra re rj rl rm r] rP rq rr ru rv r| ry r8 r9 r? r6 r@ rD ri r� r: r� � __classcell__r r r* r r 9 sV � � G � % )Z simplejsonr4 � ImportErrorZlibcloud.container.baser r r r Zlibcloud.container.typesr Z libcloud.container.utils.dockerr Zlibcloud.common.awsr r �__all__r r r r r3 �replacer� r� r r r r r r r �<module> s. � � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка