'Create a new bucket on S3. bucket_name must be unique, the bucket
namespace is shared by all AWS users'

def create_bucket(self, bucket_name):

    bucket_name = bucket_name.split('/')[0]
    try:
        return self.conn.create_bucket(bucket_name)
    except boto.exception.S3CreateError as e:
        if (e.error_code == 'BucketAlreadyExists'):
            raise exception.BucketAlreadyExists(bucket_name)
        raise
