`airflow.providers.amazon.aws.hooks.redshift_cluster`¶

Module Contents¶

Interact with AWS Redshift, using the boto3 library

class airflow.providers.amazon.aws.hooks.redshift_cluster.RedshiftHook(*args, **kwargs)[source]¶

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(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, and ra3.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(cluster_identifier)[source]¶

Return status of a cluster

Parameters

delete_cluster(cluster_identifier, skip_final_cluster_snapshot=True, final_cluster_snapshot_identifier=None)[source]¶

Delete a cluster and optionally create a snapshot

Parameters

cluster_identifier (str) – unique identifier of a cluster
skip_final_cluster_snapshot (bool) – determines cluster snapshot creation
final_cluster_snapshot_identifier (Optional[str]) – name of final cluster snapshot

describe_cluster_snapshots(cluster_identifier)[source]¶

Gets a list of snapshots for a cluster

restore_from_cluster_snapshot(cluster_identifier, snapshot_identifier)[source]¶

Restores a cluster from its snapshot

Parameters

create_cluster_snapshot(snapshot_identifier, cluster_identifier)[source]¶

Creates a snapshot of a cluster

Parameters