dlt.destinations.impl.athena.factory

athena Objects

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

View source on GitHub

__init__

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

View source on GitHub

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 str, optional - S3 bucket to store query results in
• credentials Union[AwsCredentials, Dict[str, Any], Any], optional - AWS credentials to connect to the Athena database. Can be an instance of AwsCredentials or a dict with AWS credentials
• athena_work_group str, optional - Athena work group to use
• aws_data_catalog str, optional - Athena data catalog to use
• destination_name str, optional - Name of the destination, can be used in config section to differentiate between multiple of the same type
• environment str, optional - Environment of the destination
• **kwargs Any - Additional arguments passed to the destination config