astronomer.providers.amazon.aws.hooks.redshift_data

Module Contents

Classes

RedshiftDataHook

RedshiftDataHook inherits from AwsBaseHook to connect with AWS redshift

class astronomer.providers.amazon.aws.hooks.redshift_data.RedshiftDataHook(*args, **kwargs)

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

RedshiftDataHook inherits from AwsBaseHook to connect with AWS redshift by using boto3 client_type as redshift-data we can interact with redshift cluster database and execute the query

Parameters

• aws_conn_id – The Airflow connection used for AWS credentials. If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then default boto3 configuration would be used (and must be maintained on each worker node).

• verify – Whether or not to verify SSL certificates. https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

• region_name – AWS region_name. If not specified then the default boto3 behaviour is used.

• client_type – boto3.client client_type. Eg ‘s3’, ‘emr’ etc

• resource_type – boto3.resource resource_type. Eg ‘dynamodb’ etc

• config – Configuration for botocore client. (https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html)

get_conn_params(self)

Helper method to retrieve connection args

execute_query(self, sql, params)

Runs an SQL statement, which can be data manipulation language (DML) or data definition language (DDL)

Parameters

sql (Union[Dict[Any, Any], Iterable[Any]]) – list of query ids