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

Unified Diff: boto/file/bucket.py

Issue 8386013: Merging in latest boto. (Closed) Base URL: svn://svn.chromium.org/boto
Patch Set: Redoing vendor drop by deleting and then merging. Created 9 years, 2 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
« no previous file with comments | « boto/exception.py ('k') | boto/file/key.py » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: boto/file/bucket.py
diff --git a/boto/file/bucket.py b/boto/file/bucket.py
index 7a1636b9782ee8506ac5297386f48207702e5344..8aec677317ffa1b440878fb6c0da469d6037cc4c 100644
--- a/boto/file/bucket.py
+++ b/boto/file/bucket.py
@@ -1,4 +1,5 @@
# Copyright 2010 Google Inc.
+# Copyright (c) 2011, Nexenta Systems Inc.
#
# Permission is hereby granted, free of charge, to any person obtaining a
# copy of this software and associated documentation files (the
@@ -49,7 +50,7 @@ class Bucket(object):
:type version_id: string
:param version_id: Unused in this subclass.
-
+
:type mfa_token: tuple or list of strings
:param mfa_token: Unused in this subclass.
"""
@@ -67,7 +68,8 @@ class Bucket(object):
key = Key(self.name, self.contained_key)
return SimpleResultSet([key])
- def get_key(self, key_name, headers=None, version_id=None):
+ def get_key(self, key_name, headers=None, version_id=None,
+ key_type=Key.KEY_REGULAR_FILE):
"""
Check to see if a particular key exists within the bucket.
Returns: An instance of a Key object or None
@@ -78,13 +80,19 @@ class Bucket(object):
:type version_id: string
:param version_id: Unused in this subclass.
+ :type stream_type: integer
+ :param stream_type: Type of the Key - Regular File or input/output Stream
+
:rtype: :class:`boto.file.key.Key`
:returns: A Key object from this bucket.
"""
- fp = open(key_name, 'rb')
- return Key(self.name, key_name, fp)
+ if key_name == '-':
+ return Key(self.name, '-', key_type=Key.KEY_STREAM_READABLE)
+ else:
+ fp = open(key_name, 'rb')
+ return Key(self.name, key_name, fp)
- def new_key(self, key_name=None):
+ def new_key(self, key_name=None, key_type=Key.KEY_REGULAR_FILE):
"""
Creates a new key
@@ -94,8 +102,11 @@ class Bucket(object):
:rtype: :class:`boto.file.key.Key`
:returns: An instance of the newly created key object
"""
- dir_name = os.path.dirname(key_name)
- if dir_name and not os.path.exists(dir_name):
- os.makedirs(dir_name)
- fp = open(key_name, 'wb')
- return Key(self.name, key_name, fp)
+ if key_name == '-':
+ return Key(self.name, '-', key_type=Key.KEY_STREAM_WRITABLE)
+ else:
+ dir_name = os.path.dirname(key_name)
+ if dir_name and not os.path.exists(dir_name):
+ os.makedirs(dir_name)
+ fp = open(key_name, 'wb')
+ return Key(self.name, key_name, fp)
« no previous file with comments | « boto/exception.py ('k') | boto/file/key.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698