airflow.providers.amazon.aws.hooks.redshift_cluster
¶
Module Contents¶
Classes¶
Interact with AWS Redshift, using the boto3 library |
- class airflow.providers.amazon.aws.hooks.redshift_cluster.RedshiftHook(*args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
Interact with AWS Redshift, using the boto3 library
Additional arguments (such as
aws_conn_id
) may be specified and are passed down to the underlying AwsBaseHook.See also
- Parameters
aws_conn_id – The Airflow connection used for AWS credentials.
- create_cluster(self, cluster_identifier, node_type, master_username, master_user_password, params)[source]¶
Creates a new cluster with the specified parameters
- Parameters
cluster_identifier (str) – A unique identifier for the cluster.
node_type (str) – The node type to be provisioned for the cluster. Valid Values:
ds2.xlarge
,ds2.8xlarge
,dc1.large
,dc1.8xlarge
,dc2.large
,dc2.8xlarge
,ra3.xlplus
,ra3.4xlarge
, andra3.16xlarge
.master_username (str) – The username associated with the admin user account for the cluster that is being created.
master_user_password (str) – password associated with the admin user account for the cluster that is being created.
params (Dict[str, Any]) – Remaining AWS Create cluster API params.
- cluster_status(self, cluster_identifier)[source]¶
Return status of a cluster
- Parameters
cluster_identifier (str) – unique identifier of a cluster
skip_final_cluster_snapshot – determines cluster snapshot creation
final_cluster_snapshot_identifier – Optional[str]
- delete_cluster(self, cluster_identifier, skip_final_cluster_snapshot=True, final_cluster_snapshot_identifier=None)[source]¶
Delete a cluster and optionally create a snapshot
- describe_cluster_snapshots(self, cluster_identifier)[source]¶
Gets a list of snapshots for a cluster
- Parameters
cluster_identifier (str) – unique identifier of a cluster