File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/__pycache__/ecs.cpython-310.pyc
Back
o ;j�N � @ s� zd dl ZW n ey d dlZY nw d dlmZmZ d dlmZmZm Z m Z d dl m Z d dl mZ dgZdZdZd Zd Zd Zd e�d d� Zde�d d� ZG dd� de�ZG dd� de�ZG dd� de �ZdS )� N)�AWSJsonResponse�SignedAWSConnection)� Container�ContainerImage�ContainerDriver�ContainerCluster)�ContainerState)�RegistryClient�ElasticContainerDriverz 2014-11-13z 2015-09-21zecs.%s.amazonaws.comzecr.%s.amazonaws.com�/z AmazonEC2ContainerServiceV%s�-� z AmazonEC2ContainerRegistry_V%sc @ � e Zd ZeZeZeZdZ dS )�ECSJsonConnectionZecsN) �__name__� __module__� __qualname__� ECS_VERSION�version�ECS_HOST�hostr � responseCls� service_name� r r �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/ecs.pyr & � r c @ r )�ECRJsonConnectionZecrN) r r r � ECR_VERSIONr �ECR_HOSTr r r r r r r r r - r r c sJ e Zd ZdZdZdZeZeZ dZ de j iZ � fdd�Zdd � Zd d � Zd d � ZdIdd�Zdd� ZdJdd�Z dKdd�Zdd� ZdLd d �Zd d � Zd!d"� Zd#d$� ZdLd%d&�Zd'd(� Z dLd)d*�Z dId+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 )Mr z Amazon Elastic Container Servicez#https://aws.amazon.com/ecs/details/z%s.dkr.ecr.%s.amazonaws.comF�RUNNINGc sf t � �||� || _|| _t| | j_| �� }| j||fi |��| _ t | | j _| | j _ | j � � d S �N) �super�__init__�regionZ region_namer � connectionr �_ex_connection_class_kwargs�ecrConnectionClass�ecr_connectionr �driver�connect)�selfZ access_idZsecretr# Z conn_kwargs�� __class__r r r" = s z ElasticContainerDriver.__init__c C s ddiS )NZsignature_version�4r )r* r r r r% J 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_namer3 � list_response� repository_idr r r r � list_imagesM 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$ r3 r4 r5 r6 � _get_headersr8 � _to_clusters)r* Zlistdatar3 r1 r r r � list_clustersd 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$ r3 r4 r5 r6 r@ r8 � _to_cluster)r* �name�locationr3 �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`` rD r. Z DeleteClusterr/ �statusZINACTIVE��idr$ r3 r4 r5 r6 r@ r8 )r* rD r3 r1 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 kr1g 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` rD �defaultN�familyr. Z ListTasksr/ ZtaskArnsr ) rL rF r$ r3 r4 r5 r6 r@ r8 �len�ex_list_containers_for_task)r* �imagerD r3 r< � containersr r r �list_containers� s" ��z&ElasticContainerDriver.list_containersT� �� c C s� i } |du r | du r g } n|| d�g} g ||j |g || dg d� g| d< || d< | jjtdt�| �| �d�d �j} |rE| �| d d �d S t d||t j g d | d d i| jj d �S )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 mountPointsrF rR ZcpuZ environmentZmemoryZ portMappingsZ essentialZ volumesFromZcontainerDefinitionsrO r. ZRegisterTaskDefinitionr/ �taskDefinition�taskDefinitionArnr )rL rF rR �state� ip_addresses�extrar( ) rF r$ r3 r4 r5 r6 r@ r8 � ex_start_taskr r r r( ) r* rF rR rD � parameters�startZex_cpuZ ex_memoryZex_container_portZ ex_host_portr1 Z port_mapsrH r r r �deploy_container� sF ! �� ���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 )rQ )r* rL rS 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` rX )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/ rX ) r[ r$ r3 r4 r5 r6 r@ r8 �extend�_to_containers)r* rb r3 rH rS 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` )ri rd �r* rb r r r �restart_container4 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` )ri rj r r r �destroy_container@ 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)rc rW r. ZRunTaskr/ �tasks� r$ r3 r4 r5 r6 r@ r8 rg rh )r* Ztask_arnrc r3 rH rS re r r r r\ K s �� z$ElasticContainerDriver.ex_start_taskc C sV d|i}| j jtdt�|�| �d�d�j}g }|d D ] }|�| �||d �� q|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` rm r. Z DescribeTasksr/ rX rn )r* Z task_arnsZdescribe_requestZdescripe_responserS re r r r rQ d 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 serviceNamerW Z desiredCountrD r. Z CreateServicer/ �servicerK )r* rF rD Ztask_definitionZ desired_countr3 rH r r r �ex_create_servicey 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`` NrD r. Z ListServicesr/ Z serviceArnsrK )r* rD r3 rH 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$ r3 r4 r5 r6 r@ r8 �r* Z service_arnr3 rH 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`` ro r. Z DeleteServicer/ rr rs 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)r9 �ex_get_repository_tokenr: 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' r3 r4 r5 r6 r7 r8 )r* r= r3 rH r r r rx � 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* ry r3 r< r= r r r r9 � s ��z+ElasticContainerDriver.ex_get_repository_idc C s | j || jf S r )�ecr_repository_hostr# )r* r= r r r r: s z$ElasticContainerDriver._get_ecr_hostc C � d� t|�dd�S )zF Get the default headers for a request to the ECS API �{}.{}�application/x-amz-json-1.1�z x-amz-targetz Content-Type)�format�ECS_TARGET_BASE�r* �actionr r r r@ � �z#ElasticContainerDriver._get_headersc C r~ )zF Get the default headers for a request to the ECR API r r� r� )r� �ECR_TARGET_BASEr� r r r r7 r� z'ElasticContainerDriver._get_ecr_headersc C s& g }|d D ] }|� | �|�� q|S )Nr? )�appendrE )r* r1 r? rD r r r rA & s z#ElasticContainerDriver._to_clustersc C s t |d |d | jjd�S )NZ clusterArnrC )rL rF r( )r r$ r( )r* r1 r r r rE , s �z"ElasticContainerDriver._to_clusterc C s( g }|d D ] }|� | �||�� q|S )NrS )r� � _to_container)r* r1 �task_definition_arnr? rD r r r rh 3 s z%ElasticContainerDriver._to_containersc C sP t |d |d td |d d d | jjd�d | j�|d d �|d |d�| jjd�S )NZ containerArnrF �rL rF �pathr r( Z lastStatusrf )rf rX )rL rF rR rZ rY r[ r( )r r r$ r( � status_map�get)r* r1 r� r r r r� 9 s" ���z$ElasticContainerDriver._to_containerc C s& g }|D ] }|� | �|||�� q|S r )r� � _to_image)r* r1 r ry ZimagesrR r r r r; M s z!ElasticContainerDriver._to_imagesc C s, d� |||d �}td |||d | jjd�S )Nz{}/{}:{}ZimageTagr� )r� r r$ r( )r* r1 r ry r� r r r r� S s �z ElasticContainerDriver._to_imager )NN)NNTrU rV NN)ra ).r r r rF Zwebsiter} r Z connectionClsr r& Zsupports_clustersr r r� r" r% r> rB rI rM rT r_ r` rd ri rk rl r\ rQ rp rq rt ru r{ rx r9 r: r@ r7 rA rE rh r� r; r� � __classcell__r r r+ r r 4 s\ �G % )Z simplejsonr5 � ImportErrorZlibcloud.common.awsr r Zlibcloud.container.baser r r r Zlibcloud.container.typesr Z libcloud.container.utils.dockerr �__all__r r r r r4 �replacer� r� r r r r r r r �<module> s( �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings