File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/backup/drivers/__pycache__/ebs.cpython-310.pyc
Back
o ;j�2 � @ s� d gZ ddlmZmZ ddlmZmZ ddlmZm Z m Z m Z ddl m Z mZ ddlmZ dZdZd e Zd �e�ZG d d � d e�ZG d d� de�ZG dd � d e�ZdS )�EBSBackupDriver� )�findall�findtext)�AWSGenericResponse�SignedAWSConnection)� BackupDriver� BackupTarget�BackupTargetJob�BackupTargetRecoveryPoint)�BackupTargetType�BackupTargetJobStatusType)� parse_datez 2015-10-01zec2.amazonaws.comz/%s/z http://ec2.amazonaws.com/doc/{}/c @ s e Zd ZdZeZi ZdZdS )� EBSResponsez$ Amazon EBS response class. �ErrorN)�__name__� __module__� __qualname__�__doc__�NS� namespace� exceptions�xpath� r r �O/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/backup/drivers/ebs.pyr $ s r c @ s e Zd ZeZeZeZdZ dS )� EBSConnectionZbackupN) r r r �VERSION�version�HOST�hostr Z responseClsZ service_namer r r r r . s r c s� e Zd ZdZdZeZ� fdd�Zdd� Zdd� Z e j d fd d �Z e j d fd d �Ze jd fdd�Zdd� Zdd� Zd2dd�Zd3dd�Zd3dd�Zdd� Zd d � Zd3d d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Z d(d)� Z d*d+� Z d,d-� Z d.d/� Z d0d1� Z!� Z"S )4r zAmazon EBS Backup Driverzhttp://aws.amazon.com/ebs/c s$ t � �||� || _t| | j_d S �N)�super�__init__�regionr � connectionr )�selfZ access_idZsecretr" �� __class__r r r! : s zEBSBackupDriver.__init__c C s t jgS )z� Get a list of backup target types this driver supports :return: ``list`` of :class:``BackupTargetType`` )r �VOLUME�r$ r r r �get_supported_target_types? � z*EBSBackupDriver.get_supported_target_typesc C � t d��)z[ List all backuptargets :rtype: ``list`` of :class:`BackupTarget` z,list_targets not implemented for this driver��NotImplementedErrorr( r r r � list_targetsG r* z EBSBackupDriver.list_targetsNc C s | � |�S )a� Creates a new backup target :param name: Name of the target :type name: ``str`` :param address: The volume ID. :type address: ``str`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` ��ex_get_target_by_volume_id)r$ �name�address�type�extrar r r � create_targetO � z EBSBackupDriver.create_targetc C s< |j d }|dur| j|j|d d d tjdd�S td��)a� Creates a new backup target from an existing node :param node: The Node to backup :type node: ``Node`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` Zblock_device_mappingNZebsr � volume_id)r1 r2 r3 r4 z$Node does not have any block devices)r4 r5 r1 r r' � RuntimeError)r$ �noder3 r4 Zdevice_mappingr r r �create_target_from_noded s �z'EBSBackupDriver.create_target_from_nodec C r+ )a� Creates a new backup target from an existing storage container :param node: The Container to backup :type node: ``Container`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` z<create_target_from_container not implemented for this driverr, )r$ � containerr3 r4 r r r � create_target_from_container � z,EBSBackupDriver.create_target_from_containerc C s | � |�S )a� Update the properties of a backup target :param target: Backup target to update :type target: Instance of :class:`BackupTarget` :param name: Name of the target :type name: ``str`` :param address: Hostname, FQDN, IP, file path etc. :type address: ``str`` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` r/ )r$ �targetr1 r2 r4 r r r � update_target� r6 z EBSBackupDriver.update_targetc C r+ )z� Delete a backup target :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` �-delete_target not implemented for this driverr, �r$ r> r r r � delete_target� s z EBSBackupDriver.delete_targetc C s0 dd|j d d�}| jjt|d�j}| �||�S )a� List the recovery points available for a target :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` :param start_date: The start date to show jobs between (optional) :type start_date: :class:`datetime.datetime` :param end_date: The end date to show jobs between (optional) :type end_date: :class:`datetime.datetime`` :rtype: ``list`` of :class:`BackupTargetRecoveryPoint` �DescribeSnapshots� volume-id)�Action� Filter.1.Name�Filter.1.Value��params)r4 r# �request�ROOT�object�_to_recovery_points)r$ r> Z start_dateZend_daterI �datar r r �list_recovery_points� s � z$EBSBackupDriver.list_recovery_pointsc C r+ )a� Recover a backup target to a recovery point :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` :param recovery_point: Backup target with the backup data :type recovery_point: Instance of :class:`BackupTarget` :param path: The part of the recovery point to recover (optional) :type path: ``str`` :rtype: Instance of :class:`BackupTargetJob` r@ r, )r$ r> �recovery_point�pathr r r �recover_target� r= z EBSBackupDriver.recover_targetc C r+ )am Recover a backup target to a recovery point out-of-place :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param recovery_point: Backup target with the backup data :type recovery_point: Instance of :class:`BackupTarget` :param recovery_target: Backup target with to recover the data to :type recovery_target: Instance of :class:`BackupTarget` :param path: The part of the recovery point to recover (optional) :type path: ``str`` :rtype: Instance of :class:`BackupTargetJob` r@ r, )r$ r> rP Zrecovery_targetrQ r r r �recover_target_out_of_place� s z+EBSBackupDriver.recover_target_out_of_placec s$ | � |�}tt� fdd�|��d S )a; Get a specific backup job by ID :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param id: Backup target with the backup data :type id: Instance of :class:`BackupTarget` :rtype: :class:`BackupTargetJob` c s | j � kS r ��id)�xrT r r �<lambda>� s z0EBSBackupDriver.get_target_job.<locals>.<lambda>r )�list_target_jobs�list�filter)r$ r> rU Zjobsr rT r �get_target_job� s z EBSBackupDriver.get_target_jobc C s2 dd|j d ddd�}| jjt|d�j}| �|�S )z� List the backup jobs on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :rtype: ``list`` of :class:`BackupTargetJob` rC rD �status�pending)rE rF rG z Filter.2.NamezFilter.2.ValuerH )r4 r# rJ rK rL �_to_jobs)r$ r> rI rN r r r rX � s � z EBSBackupDriver.list_target_jobsc C s> d|j d d�}| jjt|d�j}d}| �t||td�d �S )aC Create a new backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTargetJob` ZCreateSnapshotrD )rE ZVolumeIdrH ZCreateSnapshotResponse��elementr r r )r4 r# rJ rK rL �_to_jobr r )r$ r> r4 rI rN r r r r �create_target_job s z!EBSBackupDriver.create_target_jobc C r+ )z� Resume a suspended backup job on a target :param job: Backup target job to resume :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/resume_target_job not supported for this driverr, �r$ �jobr r r �resume_target_job � z!EBSBackupDriver.resume_target_jobc C r+ )z� Suspend a running backup job on a target :param job: Backup target job to suspend :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z0suspend_target_job not supported for this driverr, rc r r r �suspend_target_job( rf z"EBSBackupDriver.suspend_target_jobc C r+ )z� Cancel a backup job on a target :param job: Backup target job to cancel :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/cancel_target_job not supported for this driverr, rc r r r �cancel_target_job3 rf z!EBSBackupDriver.cancel_target_jobc s" d}� �fdd�t ||td�D �S )N�*DescribeSnapshotsResponse/snapshotSet/itemc s g | ]}� � |���qS r )�_to_recovery_point��.0�elrA r r � <listcomp>@ s ��z7EBSBackupDriver._to_recovery_points.<locals>.<listcomp>r_ �r r )r$ rN r> r r rA r rM > s �z#EBSBackupDriver._to_recovery_pointsc C sJ t |dtd�}tt |dtd��}| �|�}t|||| jj||d�d�}|S )N� snapshotIdr_ Z startTime)z snapshot-id�tags)rU �dater> �driverr4 )r r r �_get_resource_tagsr r# rs )r$ rm r> rU rr rq Zpointr r r rj E s �z"EBSBackupDriver._to_recovery_pointc s d}� fdd�t ||td�D �S )Nri c s g | ]}� � |��qS r )ra rk r( r r rn T s z,EBSBackupDriver._to_jobs.<locals>.<listcomp>r_ ro )r$ rN r r r( r r^ R s zEBSBackupDriver._to_jobsc C s^ t |dtd�}t |dtd��dd�}t |dtd�}| �|�}t|tjt|�|| jj i d�}|S )Nrp r_ �progress�%� ZvolumeId)rU r\ ru r> rs r4 ) r r �replacer0 r r ZPENDING�intr# rs )r$ rm rU ru r7 r> rd r r r ra V s �zEBSBackupDriver._to_jobc C s t |||tj| jjd|id�S )NrD )rU r1 r2 r3 rs r4 )r r r' r# rs )r$ r7 r r r r0 e s �z*EBSBackupDriver.ex_get_target_by_volume_idc C sD i }t |dtd�}|D ]}t|dtd�}t|dtd�}|||< q |S )z� Parse tags from the provided element and return a dictionary with key/value pairs. :rtype: ``dict`` z tagSet/itemr_ �key�value)r r r )r$ r` rq Ztag_set�tagrz r{ r r r rt o s z"EBSBackupDriver._get_resource_tags)NNr )#r r r r1 Zwebsiter Z connectionClsr! r) r. r r' r5 ZVIRTUALr: ZOBJECTr< r? rB rO rR rS r[ rX rb re rg rh rM rj r^ ra r0 rt � __classcell__r r r% r r 5 s6 N)�__all__Zlibcloud.utils.xmlr r Zlibcloud.common.awsr r Zlibcloud.backup.baser r r r Zlibcloud.backup.typesr r Zlibcloud.utils.iso8601r r r rK �formatr r r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings