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: deriva.transfer.download.processors.query.base_query_processor.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: deriva.transfer.download.processors.base_processor.BaseProcessor

Base class for QueryProcessor classes

HEADERS = {'Connection': 'keep-alive'}
catalogQuery(headers=None, as_file=True)[source]
create_default_paths()[source]
getExternalSession(host)[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: deriva.transfer.download.processors.query.base_query_processor.BaseQueryProcessor

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

Bases: deriva.transfer.download.processors.query.base_query_processor.JSONEnvUpdateProcessor

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

Bases: deriva.transfer.download.processors.query.base_query_processor.BaseQueryProcessor

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

Bases: deriva.transfer.download.processors.query.base_query_processor.BaseQueryProcessor

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

Bases: deriva.transfer.download.processors.query.base_query_processor.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: deriva.transfer.download.processors.query.base_query_processor.BaseQueryProcessor

downloadFiles(input_manifest)[source]
getExternalFile(url, output_path, headers=None)[source]
process()[source]

Module contents