destinations.impl.athena.factory

athena Objects

class athena(Destination[AthenaClientConfiguration, "AthenaClient"])

[view_source]

__init__

def __init__(query_result_bucket: t.Optional[str] = None,
             credentials: t.Union[AwsCredentials, t.Dict[str, t.Any],
                                  t.Any] = None,
             athena_work_group: t.Optional[str] = None,
             aws_data_catalog: t.Optional[str] = "awsdatacatalog",
             force_iceberg: bool = False,
             destination_name: t.Optional[str] = None,
             environment: t.Optional[str] = None,
             **kwargs: t.Any) -> None

[view_source]

Configure the Athena destination to use in a pipeline.

All arguments provided here supersede other configuration sources such as environment variables and dlt config files.

Arguments:

• query_result_bucket - S3 bucket to store query results in
• credentials - AWS credentials to connect to the Athena database.
• athena_work_group - Athena work group to use
• aws_data_catalog - Athena data catalog to use
• force_iceberg - Force iceberg tables
• **kwargs - Additional arguments passed to the destination config