deriva.transfer.download.processors.query package

Submodules

deriva.transfer.download.processors.query.bag_fetch_query_processor module

class deriva.transfer.download.processors.query.bag_fetch_query_processor.BagFetchQueryProcessor(envars=None, **kwargs)[source]

Bases: BaseQueryProcessor

createManifestEntry(entry)[source]

createRemoteFileManifest()[source]

process()[source]

deriva.transfer.download.processors.query.base_query_processor module

class deriva.transfer.download.processors.query.base_query_processor.BaseQueryProcessor(envars=None, **kwargs)[source]

Bases: BaseProcessor

Base class for QueryProcessor classes

HEADERS = {'Connection': 'keep-alive'}

catalogQuery(headers=None, as_file=True)[source]

create_default_paths()[source]

getExternalSession(url)[source]

getExternalUrl(url)[source]

getHatracStore(url)[source]

headForHeaders(url, raise_for_status=False)[source]

process()[source]

class deriva.transfer.download.processors.query.base_query_processor.CSVQueryProcessor(envars=None, **kwargs)[source]: Bases: BaseQueryProcessor

class deriva.transfer.download.processors.query.base_query_processor.CreateDirProcessor(envars=None, **kwargs)[source]

Bases: JSONEnvUpdateProcessor

process()[source]

class deriva.transfer.download.processors.query.base_query_processor.JSONEnvUpdateProcessor(envars=None, **kwargs)[source]

Bases: BaseQueryProcessor

process()[source]

class deriva.transfer.download.processors.query.base_query_processor.JSONQueryProcessor(envars=None, **kwargs)[source]: Bases: BaseQueryProcessor

class deriva.transfer.download.processors.query.base_query_processor.JSONStreamQueryProcessor(envars=None, **kwargs)[source]: Bases: BaseQueryProcessor

deriva.transfer.download.processors.query.file_download_query_processor module

class deriva.transfer.download.processors.query.file_download_query_processor.FileDownloadQueryProcessor(envars=None, **kwargs)[source]

Bases: BaseQueryProcessor

downloadFiles(input_manifest)[source]

getExternalFile(url, output_path, headers=None)[source]

process()[source]

Module contents