extract.storage

ExtractorItemStorage Objects

class ExtractorItemStorage(DataItemStorage)

[view_source]

__init__

def __init__(package_storage: PackageStorage,
             writer_spec: FileWriterSpec) -> None

[view_source]

Data item storage using storage to manage load packages

ExtractStorage Objects

class ExtractStorage(NormalizeStorage)

[view_source]

Wrapper around multiple extractor storages with different file formats

create_load_package

def create_load_package(schema: Schema,
                        reuse_exiting_package: bool = True) -> str

[view_source]

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

[view_source]

Deletes temporary extract folder if empty

get_load_package_info

def get_load_package_info(load_id: str) -> LoadPackageInfo

[view_source]

Returns information on temp and extracted packages