Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1714)

Unified Diff: third_party/gsutil/gslib/tracker_file.py

Issue 1377933002: [catapult] - Copy Telemetry's gsutilz over to third_party. (Closed) Base URL: https://github.com/catapult-project/catapult.git@master
Patch Set: Rename to gsutil. Created 5 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/gsutil/gslib/tracker_file.py
diff --git a/third_party/gsutil/gslib/tracker_file.py b/third_party/gsutil/gslib/tracker_file.py
new file mode 100644
index 0000000000000000000000000000000000000000..4fddc8a13d5d81336fdc73d7e4077e3b68cb0690
--- /dev/null
+++ b/third_party/gsutil/gslib/tracker_file.py
@@ -0,0 +1,318 @@
+# -*- coding: utf-8 -*-
+# Copyright 2015 Google Inc. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Helper functions for tracker file functionality."""
+
+import errno
+import hashlib
+import os
+import re
+
+from boto import config
+from gslib.exception import CommandException
+from gslib.util import CreateDirIfNeeded
+from gslib.util import GetGsutilStateDir
+from gslib.util import ResumableThreshold
+from gslib.util import UTF8
+
+# The maximum length of a file name can vary wildly between different
+# operating systems, so we always ensure that tracker files are less
+# than 100 characters in order to avoid any such issues.
+MAX_TRACKER_FILE_NAME_LENGTH = 100
+
+
+TRACKER_FILE_UNWRITABLE_EXCEPTION_TEXT = (
+ 'Couldn\'t write tracker file (%s): %s. This can happen if gsutil is '
+ 'configured to save tracker files to an unwritable directory)')
+
+
+class TrackerFileType(object):
+ UPLOAD = 'upload'
+ DOWNLOAD = 'download'
+ PARALLEL_UPLOAD = 'parallel_upload'
+ REWRITE = 'rewrite'
+
+
+def _HashFilename(filename):
+ """Apply a hash function (SHA1) to shorten the passed file name.
+
+ The spec for the hashed file name is as follows:
+
+ TRACKER_<hash>_<trailing>
+
+ where hash is a SHA1 hash on the original file name and trailing is
+ the last 16 chars from the original file name. Max file name lengths
+ vary by operating system so the goal of this function is to ensure
+ the hashed version takes fewer than 100 characters.
+
+ Args:
+ filename: file name to be hashed.
+
+ Returns:
+ shorter, hashed version of passed file name
+ """
+ if isinstance(filename, unicode):
+ filename = filename.encode(UTF8)
+ else:
+ filename = unicode(filename, UTF8).encode(UTF8)
+ m = hashlib.sha1(filename)
+ return 'TRACKER_' + m.hexdigest() + '.' + filename[-16:]
+
+
+def CreateTrackerDirIfNeeded():
+ """Looks up or creates the gsutil tracker file directory.
+
+ This is the configured directory where gsutil keeps its resumable transfer
+ tracker files. This function creates it if it doesn't already exist.
+
+ Returns:
+ The pathname to the tracker directory.
+ """
+ tracker_dir = config.get(
+ 'GSUtil', 'resumable_tracker_dir',
+ os.path.join(GetGsutilStateDir(), 'tracker-files'))
+ CreateDirIfNeeded(tracker_dir)
+ return tracker_dir
+
+
+def GetRewriteTrackerFilePath(src_bucket_name, src_obj_name, dst_bucket_name,
+ dst_obj_name, api_selector):
+ """Gets the tracker file name described by the arguments.
+
+ Args:
+ src_bucket_name: Source bucket (string).
+ src_obj_name: Source object (string).
+ dst_bucket_name: Destination bucket (string).
+ dst_obj_name: Destination object (string)
+ api_selector: API to use for this operation.
+
+ Returns:
+ File path to tracker file.
+ """
+ # Encode the src and dest bucket and object names into the tracker file
+ # name.
+ res_tracker_file_name = (
+ re.sub('[/\\\\]', '_', 'rewrite__%s__%s__%s__%s__%s.token' %
+ (src_bucket_name, src_obj_name, dst_bucket_name,
+ dst_obj_name, api_selector)))
+
+ return _HashAndReturnPath(res_tracker_file_name, TrackerFileType.REWRITE)
+
+
+def GetTrackerFilePath(dst_url, tracker_file_type, api_selector, src_url=None):
+ """Gets the tracker file name described by the arguments.
+
+ Args:
+ dst_url: Destination URL for tracker file.
+ tracker_file_type: TrackerFileType for this operation.
+ api_selector: API to use for this operation.
+ src_url: Source URL for the source file name for parallel uploads.
+
+ Returns:
+ File path to tracker file.
+ """
+ if tracker_file_type == TrackerFileType.UPLOAD:
+ # Encode the dest bucket and object name into the tracker file name.
+ res_tracker_file_name = (
+ re.sub('[/\\\\]', '_', 'resumable_upload__%s__%s__%s.url' %
+ (dst_url.bucket_name, dst_url.object_name, api_selector)))
+ elif tracker_file_type == TrackerFileType.DOWNLOAD:
+ # Encode the fully-qualified dest file name into the tracker file name.
+ res_tracker_file_name = (
+ re.sub('[/\\\\]', '_', 'resumable_download__%s__%s.etag' %
+ (os.path.realpath(dst_url.object_name), api_selector)))
+ elif tracker_file_type == TrackerFileType.PARALLEL_UPLOAD:
+ # Encode the dest bucket and object names as well as the source file name
+ # into the tracker file name.
+ res_tracker_file_name = (
+ re.sub('[/\\\\]', '_', 'parallel_upload__%s__%s__%s__%s.url' %
+ (dst_url.bucket_name, dst_url.object_name,
+ src_url, api_selector)))
+ elif tracker_file_type == TrackerFileType.REWRITE:
+ # Should use GetRewriteTrackerFilePath instead.
+ raise NotImplementedError()
+
+ return _HashAndReturnPath(res_tracker_file_name, tracker_file_type)
+
+
+def _HashAndReturnPath(res_tracker_file_name, tracker_file_type):
+ resumable_tracker_dir = CreateTrackerDirIfNeeded()
+ hashed_tracker_file_name = _HashFilename(res_tracker_file_name)
+ tracker_file_name = '%s_%s' % (str(tracker_file_type).lower(),
+ hashed_tracker_file_name)
+ tracker_file_path = '%s%s%s' % (resumable_tracker_dir, os.sep,
+ tracker_file_name)
+ assert len(tracker_file_name) < MAX_TRACKER_FILE_NAME_LENGTH
+ return tracker_file_path
+
+
+def DeleteTrackerFile(tracker_file_name):
+ if tracker_file_name and os.path.exists(tracker_file_name):
+ os.unlink(tracker_file_name)
+
+
+def HashRewriteParameters(
+ src_obj_metadata, dst_obj_metadata, projection, src_generation=None,
+ gen_match=None, meta_gen_match=None, canned_acl=None, fields=None,
+ max_bytes_per_call=None):
+ """Creates an MD5 hex digest of the parameters for a rewrite call.
+
+ Resuming rewrites requires that the input parameters are identical. Thus,
+ the rewrite tracker file needs to represent the input parameters. For
+ easy comparison, hash the input values. If a user does a performs a
+ same-source/same-destination rewrite via a different command (for example,
+ with a changed ACL), the hashes will not match and we will restart the
+ rewrite from the beginning.
+
+ Args:
+ src_obj_metadata: apitools Object describing source object. Must include
+ bucket, name, and etag.
+ dst_obj_metadata: apitools Object describing destination object. Must
+ include bucket and object name
+ projection: Projection used for the API call.
+ src_generation: Optional source generation.
+ gen_match: Optional generation precondition.
+ meta_gen_match: Optional metageneration precondition.
+ canned_acl: Optional canned ACL string.
+ fields: Optional fields to include in response.
+ max_bytes_per_call: Optional maximum bytes rewritten per call.
+
+ Returns:
+ MD5 hex digest Hash of the input parameters, or None if required parameters
+ are missing.
+ """
+ if (not src_obj_metadata or
+ not src_obj_metadata.bucket or
+ not src_obj_metadata.name or
+ not src_obj_metadata.etag or
+ not dst_obj_metadata or
+ not dst_obj_metadata.bucket or
+ not dst_obj_metadata.name or
+ not projection):
+ return
+ md5_hash = hashlib.md5()
+ for input_param in (
+ src_obj_metadata, dst_obj_metadata, projection, src_generation,
+ gen_match, meta_gen_match, canned_acl, fields, max_bytes_per_call):
+ md5_hash.update(str(input_param))
+ return md5_hash.hexdigest()
+
+
+def ReadRewriteTrackerFile(tracker_file_name, rewrite_params_hash):
+ """Attempts to read a rewrite tracker file.
+
+ Args:
+ tracker_file_name: Tracker file path string.
+ rewrite_params_hash: MD5 hex digest of rewrite call parameters constructed
+ by HashRewriteParameters.
+
+ Returns:
+ String rewrite_token for resuming rewrite requests if a matching tracker
+ file exists, None otherwise (which will result in starting a new rewrite).
+ """
+ # Check to see if we already have a matching tracker file.
+ tracker_file = None
+ if not rewrite_params_hash:
+ return
+ try:
+ tracker_file = open(tracker_file_name, 'r')
+ existing_hash = tracker_file.readline().rstrip('\n')
+ if existing_hash == rewrite_params_hash:
+ # Next line is the rewrite token.
+ return tracker_file.readline().rstrip('\n')
+ except IOError as e:
+ # Ignore non-existent file (happens first time a rewrite is attempted.
+ if e.errno != errno.ENOENT:
+ print('Couldn\'t read Copy tracker file (%s): %s. Restarting copy '
+ 'from scratch.' %
+ (tracker_file_name, e.strerror))
+ finally:
+ if tracker_file:
+ tracker_file.close()
+
+
+def WriteRewriteTrackerFile(tracker_file_name, rewrite_params_hash,
+ rewrite_token):
+ """Writes a rewrite tracker file.
+
+ Args:
+ tracker_file_name: Tracker file path string.
+ rewrite_params_hash: MD5 hex digest of rewrite call parameters constructed
+ by HashRewriteParameters.
+ rewrite_token: Rewrite token string returned by the service.
+ """
+ _WriteTrackerFile(tracker_file_name, '%s\n%s\n' % (rewrite_params_hash,
+ rewrite_token))
+
+
+def ReadOrCreateDownloadTrackerFile(src_obj_metadata, dst_url,
+ api_selector):
+ """Checks for a download tracker file and creates one if it does not exist.
+
+ Args:
+ src_obj_metadata: Metadata for the source object. Must include
+ etag and size.
+ dst_url: Destination file StorageUrl.
+ api_selector: API mode to use (for tracker file naming).
+
+ Returns:
+ True if the tracker file already exists (resume existing download),
+ False if we created a new tracker file (new download).
+ """
+ if src_obj_metadata.size < ResumableThreshold():
+ # Don't create a tracker file for a small downloads; cross-process resumes
+ # won't work, but restarting a small download is inexpensive.
+ return False
+
+ assert src_obj_metadata.etag
+ tracker_file_name = GetTrackerFilePath(
+ dst_url, TrackerFileType.DOWNLOAD, api_selector)
+ tracker_file = None
+
+ # Check to see if we already have a matching tracker file.
+ try:
+ tracker_file = open(tracker_file_name, 'r')
+ etag_value = tracker_file.readline().rstrip('\n')
+ if etag_value == src_obj_metadata.etag:
+ return True
+ except IOError as e:
+ # Ignore non-existent file (happens first time a download
+ # is attempted on an object), but warn user for other errors.
+ if e.errno != errno.ENOENT:
+ print('Couldn\'t read URL tracker file (%s): %s. Restarting '
+ 'download from scratch.' %
+ (tracker_file_name, e.strerror))
+ finally:
+ if tracker_file:
+ tracker_file.close()
+
+ # Otherwise, create a new tracker file and start from scratch.
+ _WriteTrackerFile(tracker_file_name, '%s\n' % src_obj_metadata.etag)
+
+
+def _WriteTrackerFile(tracker_file_name, data):
+ """Creates a tracker file, storing the input data."""
+ try:
+ with os.fdopen(os.open(tracker_file_name,
+ os.O_WRONLY | os.O_CREAT, 0600), 'w') as tf:
+ tf.write(data)
+ return False
+ except (IOError, OSError) as e:
+ raise RaiseUnwritableTrackerFileException(tracker_file_name, e.strerror)
+
+
+def RaiseUnwritableTrackerFileException(tracker_file_name, error_str):
+ """Raises an exception when unable to write the tracker file."""
+ raise CommandException(TRACKER_FILE_UNWRITABLE_EXCEPTION_TEXT %
+ (tracker_file_name, error_str))

Powered by Google App Engine
This is Rietveld 408576698