Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/__pycache__/docker.cpython-39.pyc
Ðазад
a q�h�h � @ s, d dl Z d dlZd dlZd dlZd dlZz d dlZW n eyN d dlZY n0 d dlm Z d dlm Z d dl m Z m Z d dl mZ d dlmZ d dlmZmZmZ d dlmZ d d lmZ e je je je j gZ G d d � d e �Z G d d � d e�Z G dd� de �Z G dd� de�Z!G dd� de�Z"dd� Z#dS )� N)�httplib)�b)� JsonResponse�ConnectionUserAndKey)�KeyCertificateConnection)�InvalidCredsError)� Container�ContainerDriver�ContainerImage)�Provider)�ContainerStatec @ s8 e Zd ZejejejejgZdd� Z dd� Z dd� Z dS )�DockerResponsec C s� t | j�dkr| js| jS zv| j�dd�}|dks:|dkr�| j�d�dkrzd| jjv rzdd � | j�� �d d�� d �D �}q�t � | j�}n| j}W n@ t y� t �d | j�}|r�|�d �}t|��ntd��Y n0 |S )Nr z content-type�application/json� ztransfer-encoding�chunkedZ fromImagec S s g | ]}t �|��qS � )�json�loads)�.0�chunkr 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/docker.py� <listcomp>= � z-DockerResponse.parse_body.<locals>.<listcomp>� � z Error: (.+?)"� z.ConnectionError: Failed to parse JSON response)�len�bodyZparse_zero_length_body�headers�get�request�url�strip�replace�splitr r � ValueError�re�search�group� Exception)�self� content_typer �m� error_msgr r r � parse_body2 s, �� � zDockerResponse.parse_bodyc C s | j dkrtd��| jS )Ni� zInvalid credentials)�statusr r �r* r r r � parse_errorM s zDockerResponse.parse_errorc C s | j | jv S �N)r/ �valid_response_codesr0 r r r �successR s zDockerResponse.successN) �__name__� __module__� __qualname__r �OK�ACCEPTED�CREATED� NO_CONTENTr3 r. r1 r4 r r r r r - s �r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DockerExceptionc C s || _ || _||f| _d S r2 )�code�message�args)r* r= r> r r r �__init__X s zDockerException.__init__c C s d| j | jf S )Nz%s %s�r= r> r0 r r r �__str__] s zDockerException.__str__c C s d| j | jf S )NzDockerException %s %srA r0 r r r �__repr__` s zDockerException.__repr__N)r5 r6 r7 r@ rB rC r r r r r< V s r< c @ s e Zd ZeZdZdd� ZdS )�DockerConnection�< c C sD d|d< | j r@| jr@t�td| j | jf ��}d|�d� |d< |S )z� Add parameters that are necessary for every request If user and password are specified, include a base http auth header r � Content-Typez%s:%szBasic %szutf-8� Authorization)Zuser_id�key�base64� b64encoder �decode)r* r Zuser_b64r r r �add_default_headersi s z$DockerConnection.add_default_headersN)r5 r6 r7 r � responseCls�timeoutrL r r r r rD d s rD c s* e Zd ZeZd � fdd� Zdd� Z� ZS ) �DockertlsConnectionT� localhost� r c s� t t| �j|||||d d d d d d� |r�tj�|�} tj�| �oJtj�| �} | sXtd��|| _ tj�|�} tj�| �o�tj�| �} | s�td��|| _ d S )N) �key_file� cert_file�secure�host�portr! � proxy_urlrN �backoffZ retry_delayzZYou need an key PEM file to authenticate with Docker tls. This can be found in the server.zbYou need an certificate PEM file to authenticate with Docker tls. This can be found in the server.) �superrO r@ �os�path� expanduser�exists�isfiler rR rS ) r* rH �secretrT rU rV rR rS �kwargsZkeypathZ is_file_pathZcertpath�� __class__r r r@ z s6 � � � ��z DockertlsConnection.__init__c C s d|d< |S )Nr rF r )r* r r r r rL � s z'DockertlsConnection.add_default_headers)TrP rQ r r )r5 r6 r7 r rM r@ rL � __classcell__r r ra r rO v s � rO c s� e Zd ZdZejZdZdZe Z dZ dZ d1� fd d � Z d d � Zdd� Zdd� Zd2dd�Zd3dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd4d'd(�Zd)d*� Zd+d,� Z d-d.� Z d/d0� Z � Z S )5�DockerContainerDrivera] Docker container driver class. >>> from libcloud.container.providers import get_driver >>> driver = get_driver('docker') >>> conn = driver(host='198.61.239.128', port=4243) >>> conn.list_containers() or connecting to http basic auth protected https host: >>> conn = driver('user', 'pass', host='https://198.61.239.128', port=443) connect with tls authentication, by providing a hostname, port, a private key file (.pem) and certificate (.pem) file >>> conn = driver(host='https://198.61.239.128', >>> port=4243, key_file='key.pem', cert_file='cert.pem') �Dockerzhttp://docker.ioFz1.24r rP rQ Nc s� |rt | _|| _|| _d}|�d�r(d}ddg}|D ]} |�| �r4|�| �}q4tt| �j|||||||d� |st|r�|r||s�t d��|| j _ || j _ || j _ | �� | _dS )a7 :param key: API key or username to used (required) :type key: ``str`` :param secret: Secret password to be used (required) :type secret: ``str`` :param secure: Whether to use HTTPS or HTTP. Note: Some providers only support HTTPS, and it is on by default. :type secure: ``bool`` :param host: Override hostname used for connections. :type host: ``str`` :param port: Override port used for connections. :type port: ``int`` :param key_file: Path to private key for TLS connection (optional) :type key_file: ``str`` :param cert_file: Path to public key for TLS connection (optional) :type cert_file: ``str`` :return: ``None`` Tzhttps://zhttp://)rH r_ rT rU rV rR rS zGNeeds both private key file and certificate file for tls authenticationN)rO � connectionClsrR rS � startswithr" rY rd r@ r) � connectionrT rU rV �_get_api_version�version) r* rH r_ rT rU rV rR rS �prefixes�prefixra r r r@ � s4 ��z DockerContainerDriver.__init__c C s0 i }t | d�r| j|d< t | d�r,| j|d< |S )NrR rS )�hasattrrR rS )r* r` r r r �_ex_connection_class_kwargs� s z1DockerContainerDriver._ex_connection_class_kwargsc C s� i }t �|�}| jjd| j|f |dd�}d|jv r@td|j��d}t�d|j�s`t�d|j�r�t�d|j�r�t� d|j�d }|du r�tdd ��t |||d| jj i d �}|S ) z� Install a container image from a remote path. :param path: Path to the container image :type path: ``str`` :rtype: :class:`libcloud.container.base.ContainerImage` z /v%s/images/create?fromImage=%s�POST��data�methodZ errorDetailNzDownloaded newer imagez "Status: Image is up to datezsha256:(?P<id>[a-z0-9]{64})���zfailed to install image��id�namer[ rj �driver�extra) r �dumpsrh r rj r r< r& r' �findallr rw )r* r[ �payloadrq �resultZimage_id�imager r r � install_image s> �� ��� �z#DockerContainerDriver.install_imagec C s� | j �d| j �j}g }|D ]r}z|�d�d }W n tyN |�d�}Y n0 |�t|�d�||d| j j|�d�|�d�|�d�d �d �� q |S ) z� List the installed container images :rtype: ``list`` of :class:`libcloud.container.base.ContainerImage` z/v%s/images/jsonZRepoTagsr �IdN�Created�SizeZ VirtualSize)�created�sizeZ virtual_sizert ) rh r rj �objectr r) �appendr rw )r* r| �imagesr} rv r r r � list_images+ s* � �� z!DockerContainerDriver.list_imagesTc s� |r d}nd}z � j �d� j|f �j}W nD tyn } z,t|dd�}|dkrXt|d��� W Y d}~n d}~0 0 � fdd �|D �}|S ) aa List the deployed container images :param image: Filter to containers with a certain image :type image: :class:`libcloud.container.base.ContainerImage` :param all: Show all container (including stopped ones) :type all: ``bool`` :rtype: ``list`` of :class:`libcloud.container.base.Container` z?all=1r z/v%s/containers/json%s�errnoN�o z>Make sure docker host is accessibleand the API port is correctc s g | ]}� � |��qS r )� _to_container)r �valuer0 r r r d r z9DockerContainerDriver.list_containers.<locals>.<listcomp>)rh r rj r� r) �getattrr< )r* r} �all�exr| �excr� � containersr r0 r �list_containersH s" � �z%DockerContainerDriver.list_containersr �bridgec C sZ t �t|��}|du ri }d|i}||| || |d| ddd| || |j|||||||d|||d�}t�|�}z | jjd| j ||dd�} W nX t y� } z@| j p�t| �} | � d �r�t dd |j ��n t d| ��W Y d} ~ n d} ~ 0 0 | j d } g d|d �}t�|�}|�rPt| �� �d k�r4| jjd| j| f dd�} n | jjd| j| f |dd�} | �| �S )a% Deploy an installed container image For details on the additional parameters see : http://bit.ly/1PjMVKV :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 parameters: Container Image parameters :type parameters: ``str`` :param start: Start the container on deployment :type start: ``bool`` :rtype: :class:`Container` Nrv FT)ZHostnameZ DomainnameZ ExposedPortsZUserZTtyZ OpenStdinZ StdinOnceZMemoryZ AttachStdinZ AttachStdoutZ AttachStderrZEnvZCmdZDns�ImageZVolumesZ VolumesFromZNetworkDisabledZ EntrypointZ CpuSharesZ WorkingDirZ MemorySwap�PublishAllPorts� PortBindingsZ NetworkModeZLabelsz/v%s/containers/createro )rq �paramsrr zNo such image:zNo such image: %sr )�Bindsr� r� ��Q� ��?�/v%s/containers/%s/start�rr rp )�shlexr$ �strrv r ry rh r rj r) r> rg r< r� �floatri � get_container) r* rv r} � parameters�start�command�hostname�userZ stdin_open�ttyZ mem_limit�ports� environmentZdnsZvolumesZ volumes_fromZnetwork_disabled� entrypointZ cpu_sharesZ working_dirZ domainnameZ memswap_limitZ port_bindingsZ network_mode�labelsr� r{ rq r| �er> Zid_r r r �deploy_containerg s� �� �� � ����z&DockerContainerDriver.deploy_containerc C s" | j �d| j|f �j}| �|�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` z/v%s/containers/%s/json)rh r rj r� r� )r* ru r| r r r r� � s �z#DockerContainerDriver.get_containerc C s� t | �� �dkr.| jjd| j|jf dd�}n2g dd�}t�|�}| jjd| j|jf d|d�}|jt v rv| � |j�S t |jd��d S ) a Start a container :param container: The container to be started :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` r� r� ro r� T)r� r� �rr rq zfailed to start containerN) r� ri rh r rj ru r ry r/ �VALID_RESPONSE_CODESr� r< )r* � containerr| r{ rq r r r �start_container� s, ��� �� �z%DockerContainerDriver.start_containerc C sB | j jd| j|jf dd�}|jtv r2| �|j�S t|jd��dS )a Stop a container :param container: The container to be stopped :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` z/v%s/containers/%s/stopro r� zfailed to stop containerN)rh r rj ru r/ r� r� r< �r* r� r| r r r �stop_container� s �� �z$DockerContainerDriver.stop_containerc C sR t �ddi�}| jjd| j|jf |dd�}|jtv rB| �|j�S t |jd��dS )a Restart a container :param container: The container to be stopped :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` �t� z/v%s/containers/%s/restartro rp zfailed to restart containerN) r ry rh r rj ru r/ r� r� r< )r* r� rq r| r r r �restart_container s �� �z'DockerContainerDriver.restart_containerc C s& | j jd| j|jf dd�}|jtv S )a Remove a container :param container: The container to be destroyed :type container: :class:`libcloud.container.base.Container` :return: True if the destroy was successful, False otherwise. :rtype: ``bool`` z/v%s/containers/%s�DELETEr� )rh r rj ru r/ r� r� r r r �destroy_container! s ��z'DockerContainerDriver.destroy_containerc C s | j �d| j|jf �j}|S )z� List processes running inside a container :param container: The container to list processes for. :type container: :class:`libcloud.container.base.Container` :rtype: ``str`` z/v%s/containers/%s/top)rh r rj ru r� r� r r r �ex_list_processes0 s �z'DockerContainerDriver.ex_list_processesc C s8 | j jd| j|j|f dd�}|jtv r4| �|j�S dS )a Rename a container :param container: The container to be renamed :type container: :class:`libcloud.container.base.Container` :param name: The new name :type name: ``str`` :rtype: :class:`libcloud.container.base.Container` z!/v%s/containers/%s/rename?name=%sro r� N)rh r rj ru r/ r� r� )r* r� rv r| r r r �ex_rename_container> s �� z)DockerContainerDriver.ex_rename_containerc C sr i }t �|�}t| �� �dkrD| j�d| j|jt|�f �j }|}n*| jjd| j|jt|�f d|d�}|j }|S )a� Get container logs If stream == True, logs will be yielded as a stream From Api Version 1.11 and above we need a GET request to get the logs Logs are in different format of those of Version 1.10 and below :param container: The container to list logs for :type container: :class:`libcloud.container.base.Container` :param stream: Stream the output :type stream: ``bool`` :rtype: ``bool`` g�������?z3/v%s/containers/%s/logs?follow=%s&stdout=1&stderr=1z</v%s/containers/%s/attach?logs=1&stream=%s&stdout=1&stderr=1ro r� ) r ry r� ri rh r rj ru r� r� r )r* r� �streamr{ rq r| Zlogsr r r � ex_get_logsP s$ ����z!DockerContainerDriver.ex_get_logsc C s� |� dd�}| j�d| j|f �j}g }|D ]N}|�d�}|�t||d|| jj|�d�|�d�|�d�|�d �d �d �� q,|S ) a� Search for an image on Docker.io. Returns a list of ContainerImage objects >>> images = conn.ex_search_images(term='mistio') >>> images [<ContainerImage: id=rolikeusch/docker-mistio...>, <ContainerImage: id=mist/mistio, name=mist/mistio, driver=Docker ...>] :param term: The search term :type term: ``str`` :rtype: ``list`` of :class:`libcloud.container.base.ContainerImage` � �+z/v%s/images/search?term=%srv N� description� is_official� is_trusted� star_count)r� r� r� r� )ru r[ rj rv rw rx ) r# rh r rj r� r r� r rw )r* �termr| r� r} rv r r r �ex_search_imagesr s, � ���z&DockerContainerDriver.ex_search_imagesc C s& | j jd| j|jf dd�}|jtv S )z� Remove image from the filesystem :param image: The image to remove :type image: :class:`libcloud.container.base.ContainerImage` :rtype: ``bool`` z/v%s/images/%sr� r� )rh r rj rv r/ r� )r* r} r| r r r �ex_delete_image� s ��z%DockerContainerDriver.ex_delete_imagec C s� z|� d��d�}W nH ty\ z|� d�d �d�}W n tyV |� d�}Y n0 Y n0 |� d�}t|t�r�|� d|dur�|� d�nd�}n |� d�}d |v r�tj}n(|�d �r�tj}nd |v r�tj}ntj}|� d �}|� d g �}|� d�}t|t ��rt |�}|� d�|� d�||||� d�|� d�|� d�d�}g } |du�rv|D ]&} | � d�du�rN| � | � d�� �qNt |d |t |� dd�||d| jjd�| || jj|d�S )z: Convert container in Container instances �Name�/ZNamesr r �State�StatusNZExitedzUp �runningr� ZPortsr� �CommandZSizeRwZ SizeRootFs)ru r/ r� r} r� r� ZsizerwZ sizerootfsZIPZImageID)ru r[ rv rj rw )ru rv r} Z ip_addresses�staterw rx )r r" r) � isinstance�dictr ZSTOPPEDrg ZRUNNINGr� � ts_to_strr� r r rh rw ) r* rq rv r� r/ r} r� r� rx �ipsrV r r r r� � sr � � � ��z#DockerContainerDriver._to_containerc C s$ | j �d�j}|pi }|�d�}|S )z8 Get the docker API version information z/versionZ ApiVersion)rh r r� r )r* r| � api_versionr r r ri � s z&DockerContainerDriver._get_api_version)r r FrP rQ NN)NT)NTNNr TTr NNNNNFNNr Nr Nr� N)F) r5 r6 r7 �__doc__r ZDOCKER�typerv ZwebsiterD rf Zsupports_clustersrj r@ rn r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� ri rc r r ra r rd � sH �A+ � d "'>rd c C s t j �| �}|�d�}|S )zB Return a timestamp as a nicely formated datetime string. z%d/%m/%Y %H:%M %Z)�datetime� fromtimestamp�strftime)� timestamp�dateZ date_stringr r r r� � s r� )$rI r� r� r& rZ Z simplejsonr r) Zlibcloud.utils.py3r r Zlibcloud.common.baser r r Zlibcloud.common.typesr Zlibcloud.container.baser r r Z libcloud.container.providersr Zlibcloud.container.typesr r8 r9 r: r; r� r r< rD rO rd r� r r r r �<module> s: �)) U
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка