extract.storage
ExtractorItemStorage Objects
class ExtractorItemStorage(DataItemStorage)
__init__
def __init__(package_storage: PackageStorage,
writer_spec: FileWriterSpec) -> None
Data item storage using storage
to manage load packages
ExtractStorage Objects
class ExtractStorage(NormalizeStorage)
Wrapper around multiple extractor storages with different file formats
create_load_package
def create_load_package(schema: Schema,
reuse_exiting_package: bool = True) -> str
Creates a new load package for given schema
or returns if such package already exists.
You can prevent reuse of the existing package by setting reuse_exiting_package
to False
delete_empty_extract_folder
def delete_empty_extract_folder() -> None
Deletes temporary extract folder if empty
get_load_package_info
def get_load_package_info(load_id: str) -> LoadPackageInfo
Returns information on temp and extracted packages