dtool_s3/storagebroker.py
def list_dataset_uris(cls, base_uri, config_path):
        """Return list containing URIs with base URI."""
        uri_list = []

        parse_result = generous_parse_uri(base_uri)
        bucket_name = parse_result.netloc
        bucket = boto3.resource('s3').Bucket(bucket_name)

        for obj in bucket.objects.filter(Prefix='dtool').all():
            uuid = obj.key.split('-', 1)[1]
            uri = cls.generate_uri(None, uuid, base_uri)

            storage_broker = cls(uri, config_path)
            if storage_broker.has_admin_metadata():
                uri_list.append(uri)

        return uri_list
def list_dataset_uris(cls, base_uri, config_path):
        """Return list containing URIs with base URI."""
        uri_list = []

        parse_result = generous_parse_uri(base_uri)
        bucket_name = parse_result.netloc
        bucket = boto3.resource('s3').Bucket(bucket_name)

        for obj in bucket.objects.filter(Prefix='dtool').all():
            uuid = obj.key.split('-', 1)[1]
            uri = cls.generate_uri(None, uuid, base_uri)

            storage_broker = cls(uri, config_path)
            if storage_broker.has_admin_metadata():
                uri_list.append(uri)

        return uri_list
def list_dataset_uris ( cls , base_uri , config_path ) : uri_list = [ ] parse_result = generous_parse_uri ( base_uri ) bucket_name = parse_result . netloc bucket = boto3 . resource ( 's3' ) . Bucket ( bucket_name ) for obj in bucket . objects . filter ( Prefix = 'dtool' ) . all ( ) : uuid = obj . key . split ( '-' , 1 ) [ 1 ] uri = cls . generate_uri ( None , uuid , base_uri ) storage_broker = cls ( uri , config_path ) if storage_broker . has_admin_metadata ( ) : uri_list . append ( uri ) return uri_list
Return list containing URIs with base URI.
Return list containing URIs with base URI .