mirror of
https://github.com/ceph/s3-tests.git
synced 2024-11-23 13:38:38 +00:00
storageclass: add object put/get with storageclass
put with object with storage class, get storage class of object. Signed-off-by: Jiffin Tony Thottan <thottanjiffin@gmail.com>
This commit is contained in:
parent
e29d6246fc
commit
2853adc3c3
1 changed files with 24 additions and 0 deletions
|
@ -120,6 +120,30 @@ def _create_objects(bucket=None, bucket_name=None, keys=[]):
|
|||
|
||||
return bucket_name
|
||||
|
||||
def upload_object_storage_class(bucket=None, bucket_name=None, key=None, storage_class=None):
|
||||
"""
|
||||
Upload an object with a specified storage class
|
||||
"""
|
||||
if bucket_name is None:
|
||||
bucket_name = get_new_bucket_name()
|
||||
if bucket is None:
|
||||
bucket = get_new_bucket_resource(name=bucket_name)
|
||||
if key is None:
|
||||
key = 'foo'
|
||||
if storage_class is None:
|
||||
storage_class = 'STANDARD'
|
||||
obj = bucket.put_object(Body=key, Key=key, StorageClass=storage_class)
|
||||
return bucket_name
|
||||
|
||||
def get_object_storage_class(bucket_name, key, bucket=None):
|
||||
"""
|
||||
Get the storage class of an object
|
||||
"""
|
||||
if bucket is None:
|
||||
bucket = get_new_bucket_resource(name=bucket_name)
|
||||
obj = bucket.Object(key)
|
||||
return obj.storage_class
|
||||
|
||||
def _get_keys(response):
|
||||
"""
|
||||
return lists of strings that are the keys from a client.list_objects() response
|
||||
|
|
Loading…
Reference in a new issue