dataio.utils.hsut package

Submodules

dataio.utils.hsut.io module

class dataio.utils.hsut.io.DataReader(source: Path | str)

Bases: object

read(*args, **kwargs) → DataFrame

class dataio.utils.hsut.io.DataWriter(conn: Path | str)

Bases: object

write(data: DataFrame, **kwargs) → None

class dataio.utils.hsut.io.TableColumn(value)

Bases: Enum

CODE = 'code'

DESCRIPTION = 'description'

class dataio.utils.hsut.io.TableType(value)

Bases: Enum

DIMENSION = 'dim'

FACT = 'fact'

dataio.utils.hsut.resources_hsut module

class dataio.utils.hsut.resources_hsut.CSVResourceRepository(db_path: str)

Bases: ResourceRepository

add(resource: Resource) → None

add_from_dataframe(data: DataFrame, loc: Path | str, task_name: str | None = None, task_relation: str = 'output', last_update: date = datetime.date(2025, 5, 16), **kwargs) → Resource

add_or_update(resource: Resource, **kwargs) → None

comment_res(resource: Resource, comment: str) → Resource

get(**filters: dict) → Resource

get_dataframe_for_task(name: str = None, loc: Path = None, task_name: str = None, task_relation='input', **kwargs) → DataFrame

list() → list[Resource]

update(resource: Resource) → None

class dataio.utils.hsut.resources_hsut.Resource(name: str | None = None, loc: Path | str = None, task_name: str = None, task_relation: str = None, last_update: date = datetime.date(2025, 5, 16), comment: str = None)

Bases: object

append_comment(comment: str)

classmethod from_dataframe(data: DataFrame, loc: Path | str, task_name: str, task_relation: str, last_update: date = datetime.date(2025, 5, 16), comment: str = None, **kwargs) → Resource

to_dataframe(**kwargs) → DataFrame

class dataio.utils.hsut.resources_hsut.ResourceRepository

Bases: ABC

abstractmethod add(resource: Resource)

abstractmethod add_or_update(resource: Resource)

abstractmethod get(**filters) → Resource

abstractmethod get_dataframe_for_task() → DataFrame

abstractmethod list() → list[Resource]

abstractmethod update(resource: Resource)

class dataio.utils.hsut.resources_hsut.SQLiteResourceRepository(db_path: str)

Bases: ResourceRepository

add(resource: Resource, **kwargs)

add_from_dataframe(data: DataFrame, loc: Path | str, task_name: str | None = None, task_relation: str = 'output', last_update: date = datetime.date(2025, 5, 16), **kwargs) → None

add_or_update(resource: Resource, **kwargs) → None

connect()

get(**filters: dict) → Resource

get_dataframe_for_task(name: str = None, loc: Path = None, task_name: str = None, task_relation='input', **kwargs) → DataFrame

list() → list[Resource]

to_csv(path: Path | str) → None

update(resource: Resource, **kwargs)

Module contents