CURRENT PATH:
/
opt
/
gsutil
/
gslib
/
commands
/
__pycache__
/
[ ⬅ KEMBALI ]
|
[ HOME ]
Upload File:
Upload Ke Sini
Dir Baru
File Baru
Editing:
rm.cpython-39.pyc
a +(Wg@ � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlmZ ddlm Z dd lm Z dd lm Z dd l m Z dd l mZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl m Z ddl!m"Z" ddl#m$Z$ ddl%m&Z& ddl%m'Z' dd l(m)Z) dd l*m+Z+ e j,Z-d Z.d e. d Z/d!d"� Z0d#d$� Z1d+d%d&�Z2d'd(� Z3G d)d*� d*e �Z4dS ),zCImplementation of Unix-like rm command for cloud storage providers.� )�absolute_import)�print_function)�division)�unicode_literalsN)�BucketNotFoundException)�NotEmptyException)�NotFoundException)�ServiceException)�Command)�DecrementFailureCount)�CommandArgument)� ApiSelector)�CommandException)�NO_URLS_MATCHED_PREFIX)�NO_URLS_MATCHED_TARGET)�NameExpansionIterator)� SeekAheadNameExpansionIterator)�StorageUrlFromString)�MetadataMessage)� constants)�parallelism_framework_util)�GetCloudApiInstance)�Retry)�GcloudStorageFlag)�GcloudStorageMap)� StdinIterator)�PreconditionsFromHeadersz7 gsutil rm [-f] [-r] url... gsutil rm [-f] [-r] -I z <B>SYNOPSIS</B> aU <B>DESCRIPTION</B> NOTE: As part of verifying the existence of objects prior to deletion, ``gsutil rm`` makes ``GET`` requests to Cloud Storage for object metadata. These requests incur `network and operations charges <https://cloud.google.com/storage/pricing>`_. The gsutil rm command removes objects and/or buckets. For example, the following command removes the object ``kitten.png``: gsutil rm gs://bucket/kitten.png Use the -r option to specify recursive object deletion. For example, the following command removes gs://bucket/subdir and all objects and subdirectories under it: gsutil rm -r gs://bucket/subdir When working with versioning-enabled buckets, note that the -r option removes all object versions in the subdirectory. To remove only the live version of each object in the subdirectory, use the `** wildcard <https://cloud.google.com/storage/docs/wildcards>`_. The following command removes all versions of all objects in a bucket, and then deletes the bucket: gsutil rm -r gs://bucket To remove all objects and their versions from a bucket without deleting the bucket, use the ``-a`` option: gsutil rm -a gs://bucket/** If you have a large number of objects to remove, use the ``gsutil -m`` option, which enables multi-threading/multi-processing: gsutil -m rm -r gs://my_bucket/subdir You can pass a list of URLs (one per line) to remove on stdin instead of as command line arguments by using the -I option. This allows you to use gsutil in a pipeline to remove objects identified by a program, such as: some_program | gsutil -m rm -I The contents of stdin can name cloud URLs and wildcards of cloud URLs. Note that ``gsutil rm`` refuses to remove files from the local file system. For example, this fails: gsutil rm *.txt WARNING: Object removal cannot be undone. Cloud Storage is designed to give developers a high amount of flexibility and control over their data, and Google maintains strict controls over the processing and purging of deleted data. If you have concerns that your application software or your users may at some point erroneously delete or replace data, see `Options for controlling data lifecycles <https://cloud.google.com/storage/docs/control-data-lifecycles>`_ for ways to protect your data from accidental data deletion. <B>OPTIONS</B> -f Continues silently (without printing error messages) despite errors when removing multiple objects. If some of the objects could not be removed, gsutil's exit status will be non-zero even if this flag is set. Execution will still halt if an inaccessible bucket is encountered. This option is implicitly set when running "gsutil -m rm ...". -I Causes gsutil to read the list of objects to remove from stdin. This allows you to run a program that generates the list of objects to remove. -R, -r The -R and -r options are synonymous. Causes bucket or bucket subdirectory contents (all objects and subdirectories that it contains) to be removed recursively. If used with a bucket-only URL (like gs://bucket), after deleting objects and subdirectories gsutil deletes the bucket. This option implies the -a option and deletes all object versions. If you only want to delete live object versions, use the `** wildcard <https://cloud.google.com/storage/docs/wildcards>`_ instead of -r. -a Delete all versions of an object. c C sf | j s| j�t|�� t|t�r@| jd7 _| j�t|�� n"t| j|�rTt � n| j d7 _ dS )z9Simple exception handler to allow post-completion status.� N) �continue_on_error�logger�error�str� isinstancer �bucket_not_found_count� _ExceptionMatchesBucketToDelete�bucket_strings_to_deleter �op_failure_count��cls�e� r* � /opt/gsutil/gslib/commands/rm.py�_RemoveExceptionHandler� s r, c C s. t |t�rt|jv s t |t�r&t� n|�dS )z3When removing folders, we don't mind if none exist.N)r" r r �reasonr r r' r* r* r+ � _RemoveFoldersExceptionHandler� s �r. c C s | j ||d� d S )N�� thread_state)� RemoveFunc)r( �name_expansion_resultr0 r* r* r+ �_RemoveFuncWrapper� s r3 c C sB | r>t d }|t|�v r>t|��|�}t|�dko<|d | v S dS )a� Returns True if the exception matches a bucket slated for deletion. A recursive delete call on an empty bucket will raise an exception when listing its objects, but if we plan to delete the bucket that shouldn't result in a user-visible error. Args: bucket_strings_to_delete: Buckets slated for recursive deletion. e: Exception to check. Returns: True if the exception was a no-URLs-matched exception and it matched one of bucket_strings_to_delete, None otherwise. � � r N)r r! �split�len)r% r) �msg�partsr* r* r+ r$ � s r$ c @ s� e Zd ZdZejdg d�edejdddde j e j ge j e � � gd� Zejdg d�dd ei d �Zed dged �ed �ed �ed�ed�d�d�Zdd� Zddd�ZdS )� RmCommandz$Implementation of gsutil rm command.�rm)�del�delete�remover ZafIrRF) �command_name_aliases�usage_synopsis�min_args�max_args�supported_sub_args� file_url_ok�provider_url_ok�urls_start_arg�gs_api_support�gs_default_api�argparse_arguments� command_helpzRemove objects)� help_name�help_name_aliases� help_type�help_one_line_summary� help_text�subcommand_help_text�storage�-r�-a�-Iz--continue-on-error)rR �-RrS rT �-f)�gcloud_command�flag_mapc sr � j � _d� _d� _� jrv� jD ]T\}}|dkr8d� _q |dkrHd� _q |dkrXd� _q |dksh|dkr d� _d� _q � jr�� jr�td��t� }n� js�td ��� j}d � _ d � _ g }g � _ � j�r d g}|D ]L}t |���� � s��� rΈ �|�j|d �D ] }|�|j� � j �|� q�q�t� j�p(i �� _z�t� j� j� j� j|� j� j� j� j�p\� j d � }d} � j�s�t � j� j� � � |� j� j� jd�} � j t |t � j ddg| d� W nl t�y� } z$t!� j | ��r�t"� n� W Y d} ~ n8d} ~ 0 t#�y } z� j�s � W Y d} ~ n d} ~ 0 0 � j �r0td��� j �rH� j�sHtd��� j�rg } |D ],}t |����$� �rX| �|�%d�d � �qX| �rd� _z<t� j� j� j� j| � j� j� jd�}� j t |t&dd� W n6 t�y } z | j'�(t)��s� W Y d} ~ n d} ~ 0 0 |D ]6�� j�*d�� t+t,ddd �� �fd d ��} | � �q � j �rn� j �rVd nd } td!� j | | f ��d S )"z'Command entry point for the rm command.FrS TrV rT rR rU z&No arguments allowed with the -I flag.z5The rm command (without -I) expects at least one URL.r �id)� bucket_fields)� project_id� all_versionsr N)r\ r[ r& r# )� fail_on_error� shared_attrs�seek_ahead_iteratorz.Encountered non-existent bucket during listingz Some files could not be removed.�*z *_$folder$)r[ r\ )r] �Removing %s...� r )�tries� timeout_secsc s � j j�j�jd� d S )N)�provider)� gsutil_api� DeleteBucket� bucket_name�schemer* ��self�urlr* r+ �BucketDeleteWithRetry~ s z3RmCommand.RunCommand.<locals>.BucketDeleteWithRetry�sr4 z(%d file%s/object%s could not be removed.)-�parallel_operationsr �read_args_from_stdinr\ �sub_opts�recursion_requested�argsr r r& r# r% r �IsBucket� IsProvider�WildcardIterator� IterBuckets�append� storage_urlr �headers� preconditionsr � command_name�debugr rf r[ r �GetSeekAheadGsutilApi�Applyr3 r, r$ r r �IsObject�rstripr. r- � startswithr �infor r )rk �o�unused_a�url_strsZbucket_urls_to_deleterZ �url_str�blr�name_expansion_iteratorr_ r) Zfolder_object_wildcardsrm � plural_strr* rj r+ � RunCommand� s� � � � � � � �zRmCommand.RunCommandNc C s� t | |d�}|j}| j�d|� z"|j|j|j| j|j|j d� W n8 t yz } z | j�d|� t � W Y d }~n d }~0 0 t |j tt�� d�� d S )Nr/ ra )r{ � generationre zCannot find %s)� message_time)r �expanded_storage_urlr r� � DeleteObjectrh � object_namer{ r� ri r r �_PutToQueueWithTimeout� status_queuer �time)rk r2 r0 rf � exp_src_urlr) r* r* r+ r1 � s � �zRmCommand.RemoveFunc)N)�__name__� __module__� __qualname__�__doc__r �CreateCommandSpec� _SYNOPSISr �NO_MAXr �XML�JSONr � MakeZeroOrMoreCloudURLsArgument� command_spec�HelpSpec�_DETAILED_HELP_TEXT� help_specr r �gcloud_storage_mapr� r1 r* r* r* r+ r: � sF �� �� r: )N)5r� � __future__r r r r r� �gslib.cloud_apir r r r � gslib.commandr r �gslib.command_argumentr �gslib.cs_api_mapr �gslib.exceptionr r r �gslib.name_expansionr r �gslib.storage_urlr �gslib.thread_messager Z gslib.utilsr r � gslib.utils.cloud_api_helperr �gslib.utils.retry_utilr �gslib.utils.shim_utilr r Zgslib.utils.system_utilr � gslib.utils.translation_helperr �PutToQueueWithTimeoutr� r� r� r, r. r3 r$ r: r* r* r* r+ �<module> sP ��[
SIMPAN
[ BATAL ]