Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/backup/drivers/__pycache__/gce.cpython-39.pyc
Ðазад
a q�h�A � @ s� d gZ ddlmZ ddlmZmZmZmZ ddlm Z m Z ddl m Z m Z dZdZG dd � d e �ZG d d � d e �ZG d d � d e�Zd S )�GCEBackupDriver� )� parse_date)� BackupDriver�BackupTargetRecoveryPoint�BackupTargetJob� BackupTarget)�BackupTargetType�BackupTargetJobStatusType)�GoogleResponse�GoogleBaseConnectionZv1� c @ s e Zd ZdS )� GCEResponseN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/backup/drivers/gce.pyr ! s r c sB e Zd ZdZdZeZd � fdd� Z� fdd�Z� fdd �Z � Z S ) � GCEConnectiona{ Connection class for the GCE driver. GCEConnection extends :class:`google.GoogleBaseConnection` for 2 reasons: 1. modify request_path for GCE URI. 2. Implement gce_params functionality described below. If the parameter gce_params is set to a dict prior to calling request(), the URL parameters will be updated to include those key/values FOR A SINGLE REQUEST. If the response contains a nextPageToken, gce_params['pageToken'] will be set to its value. This can be used to implement paging in list: >>> params, more_results = {'maxResults': 2}, True >>> while more_results: ... driver.connection.gce_params=params ... driver.ex_list_urlmaps() ... more_results = 'pageToken' in params ... [<GCEUrlMap id="..." name="cli-map">, <GCEUrlMap id="..." name="lc-map">] [<GCEUrlMap id="..." name="web-map">] zwww.googleapis.comNc s: t t| �j||f|||d�|�� dt|f | _d | _d S )N)�secure� auth_type�credential_file�/compute/%s/projects/%s)�superr �__init__� API_VERSION� request_path� gce_params)�self�user_id�keyr r r �project�kwargs�� __class__r r r ? s ���zGCEConnection.__init__c s0 t t| ��||�\}}| jr(|�| j� ||fS )z� Update URL parameters with values from self.gce_params. @inherits: :class:`GoogleBaseConnection.pre_connect_hook` )r r �pre_connect_hookr �update)r �params�headersr" r r r$ I s � z GCEConnection.pre_connect_hookc sT t t| �j|i |��}| jrPd|jv r8|jd | jd< nd| jv rJ| jd= d| _|S )z� Perform request then do GCE-specific processing of URL params. @inherits: :class:`GoogleBaseConnection.request` Z nextPageTokenZ pageTokenN)r r �requestr �object)r �argsr! �responser" r r r( U s zGCEConnection.request)NNN) r r r �__doc__�hostr Z responseClsr r$ r( � __classcell__r r r" r r % s � r c s� e Zd ZdZdZeZd2� fdd� Zdd� Zdd � Z e j dfd d �Z e j dfd d �Ze jdfdd�Zdd� Zdd� Zd3dd�Zd4dd�Zd5dd�Zdd� Zd d � Zd6d 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 )7r z#Google Compute Engine Backup Driverzhttp://cloud.google.com/Nc s\ |s t d��|| _|| _|| _|p*d| j | _tt| �j||fi |�� dt| jf | _ dS )a� :param user_id: The email address (for service accounts) or Client ID (for installed apps) to be used for authentication. :type user_id: ``str`` :param key: The RSA Key (for service accounts) or file path containing key or Client Secret (for installed apps) to be used for authentication. :type key: ``str`` :keyword project: Your GCE project name. (required) :type project: ``str`` :keyword auth_type: Accepted values are "SA" or "IA" or "GCE" ("Service Account" or "Installed Application" or "GCE" if libcloud is being used on a GCE instance with service account enabled). If not supplied, auth_type will be guessed based on value of user_id or if the code is being executed in a GCE instance. :type auth_type: ``str`` :keyword scopes: List of authorization URLs. Default is empty and grants read/write to Compute, Storage, DNS. :type scopes: ``list`` :keyword credential_file: Path to file for caching authentication information used by GCEConnection. :type credential_file: ``str`` z7Project name must be specified using "project" keyword.z~/.gce_libcloud_auth.r N) � ValueErrorr r �scopesr r r r r � base_path)r r r r r r0 r r! r" r r r n s ��zGCEBackupDriver.__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� s z*GCEBackupDriver.get_supported_target_typesc C s t d��dS )z[ List all backuptargets :rtype: ``list`` of :class:`BackupTarget` z,list_targets not implemented for this driverN��NotImplementedErrorr3 r r r � list_targets� s �z GCEBackupDriver.list_targetsc 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_source)r �name�address�type�extrar r r � create_target� s z GCEBackupDriver.create_targetc C s< |j d }|dur0| j|j|d d tjdd�S td��dS )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` �disksNr �source)r: r; r< r= z$Node does not have any block devices)r= r> r: r r2 � RuntimeError)r �noder< r= r? r r r �create_target_from_node� s �z'GCEBackupDriver.create_target_from_nodec C s t d��dS )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 driverNr5 )r � containerr< r= r r r � create_target_from_container� s �z,GCEBackupDriver.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` r8 )r �targetr: r; r= r r r � update_target� s z GCEBackupDriver.update_targetc C s t d��dS )z� Delete a backup target :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` z-delete_target not implemented for this driverNr5 �r rF r r r � delete_target s �z GCEBackupDriver.delete_targetc C s" d}| j j|dd�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` z/global/snapshots�GET��method)� connectionr( r) �_to_recovery_points)r rF Z start_date�end_dater( r+ r r r �list_recovery_points s z$GCEBackupDriver.list_recovery_pointsc C s t d��dS )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` z.recover_target not implemented for this driverNr5 )r rF �recovery_point�pathr r r �recover_target' s �z GCEBackupDriver.recover_targetc C s t d��dS )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` z;recover_target_out_of_place not implemented for this driverNr5 )r rF rQ Zrecovery_targetrR r r r �recover_target_out_of_place9 s �z+GCEBackupDriver.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 )N��id)�xrU r r �<lambda>\ � z0GCEBackupDriver.get_target_job.<locals>.<lambda>r )�list_target_jobs�list�filter)r rF rV �jobsr rU r �get_target_jobO s z GCEBackupDriver.get_target_jobc C s g 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` r rH r r r rZ ^ s z GCEBackupDriver.list_target_jobsc C sN |j }d|jd j |j f }d|jd i}| jj|d|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` z!/zones/%s/disks/%s/createSnapshot�zoner@ �POST)rL �data)r: r= rM Z async_request�_to_job�ex_get_snapshot)r rF r= r: r( Z snapshot_datar r r �create_target_jobi s � � �z!GCEBackupDriver.create_target_jobc C s t d��dS )a3 Resume a suspended backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to resume :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/resume_target_job not supported for this driverNr5 �r rF �jobr r r �resume_target_job s �z!GCEBackupDriver.resume_target_jobc C s t d��dS )a3 Suspend a running backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to suspend :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z0suspend_target_job not supported for this driverNr5 re r r r �suspend_target_job� s �z"GCEBackupDriver.suspend_target_jobc C s t d��dS )a) Cancel a backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to cancel :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/cancel_target_job not supported for this driverNr5 re r r r �cancel_target_job� s �z!GCEBackupDriver.cancel_target_jobc s � �fdd�|j D �S )Nc s g | ]}� � |���qS r )�_to_recovery_point��.0�itemrH r r � <listcomp>� s �z7GCEBackupDriver._to_recovery_points.<locals>.<listcomp>��items�r ra rF r rH r rN � s �z#GCEBackupDriver._to_recovery_pointsc C s. |j }t|j�}t|||| jjd|id�}|S )Nz snapshot-id)rV �daterF �driverr= )rV r ZcreationTimestampr rM rs )r rm rF rV rr �pointr r r rj � s �� z"GCEBackupDriver._to_recovery_pointc s � �fdd�|j D �S )Nc s g | ]}� � |���qS r )rb rk rH r r rn � s �z,GCEBackupDriver._to_jobs.<locals>.<listcomp>ro rq r rH r �_to_jobs� s �zGCEBackupDriver._to_jobsc C s$ |j }t|tjd|| jji d�}|S )Nr )rV �status�progressrF rs r= )rV r r ZPENDINGrM rs )r rm rF rV rf r r r rb � s � zGCEBackupDriver._to_jobc C s d| }| j j|dd�j}|S )Nz/global/snapshots/%srJ rK )rM r( r) )r r: r( r+ r r r rc � s z GCEBackupDriver.ex_get_snapshotc C s t |||tj| jjd|id�S )Nr@ )rV r: r; r< rs r= )r r r2 rM rs )r r@ r r r r9 � s ��z'GCEBackupDriver.ex_get_target_by_source)NNNNN)NN)N)N)N)#r r r r: Zwebsiter Z connectionClsr r4 r7 r r2 r> ZVIRTUALrC ZOBJECTrE rG rI rP rS rT r^ rZ rd rg rh ri rN rj ru rb rc r9 r. r r r" r r i sD �1 � � � � N)�__all__Zlibcloud.utils.iso8601r Zlibcloud.backup.baser r r r Zlibcloud.backup.typesr r Zlibcloud.common.googler r r Z DEFAULT_TASK_COMPLETION_TIMEOUTr r r r r r r �<module> s � D
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка