dlt.destinations.impl.athena.athena
LfTagsManager Objects
class LfTagsManager()
Class used to manage lakeformation tags on glue/athena database.
Heavily inspired by dbt-athena implementation: https://github.com/dbt-labs/dbt-athena/blob/main/dbt-athena/src/dbt/adapters/athena/lakeformation.py
process_lf_tags_database
def process_lf_tags_database() -> None
Add or remove lf tags from athena database.
AthenaClient Objects
class AthenaClient(SqlJobClientWithStagingDataset, SupportsStagingDestination)
manage_lf_tags
def manage_lf_tags() -> None
Manage Lakeformation tags on the glue database.
create_load_job
def create_load_job(table: PreparedTableSchema,
file_path: str,
load_id: str,
restore: bool = False) -> LoadJob
Starts SqlLoadJob for files ending with .sql or returns None to let derived classes to handle their specific jobs
should_load_data_to_staging_dataset_on_staging_destination
def should_load_data_to_staging_dataset_on_staging_destination(
table_name: str) -> bool
iceberg table data goes into staging on staging destination