cloudmesh-storage.cloudmesh.storage.provider.awss3.Provider

Module Contents

Classes

Provider

class cloudmesh-storage.cloudmesh.storage.provider.awss3.Provider.Provider(service=None, parallelism=4)

Bases: cloudmesh.storage.provider.StorageQueue.StorageQueue

kind = awss3
sample
status = ['completed', 'waiting', 'inprogress', 'canceled']
output
mkdir_run(self, specification)

function to create a directory the function will first check if the bucket exists or not, if the bucket doesn’t exist it will create the bucket and it will create the directory specified. the name of the bucket will come from YAML specifications and the directory name comes from the arguments.

Parameters

specification

Returns

get_s3_resource_client(self)
list_run(self, specification)

function to list file or directory lists the information as dict :return: dict

delete_run(self, specification)

deletes the source :param specification: :return: dict

get_run(self, specification)

function to download file or directory gets the source from the service :param: specification: :return: dict

put_run(self, specification)

function to upload file or directory puts the source on the service :param: specification :return: dict

search_run(self, specification)
cancel_run(self, specification)
bucket_create(self, name=None)

gets the source name from the put function :param name: the bucket name which needs to be created :return: dict,Boolean

bucket_exists(self, name=None)

gets the source from the put function :param name: the bucket name which needs to be checked for exists :return: Boolean

cloudmesh-storage.cloudmesh.storage.provider.awss3.Provider.p