qDood607VHbhjFv6yYZoDelete AWS Redshift Clusters
Delete AWS Redshift Clusters
There was a problem that the LLM was not able to address. Please rephrase your prompt and try again.
This task involves terminating specific Amazon Redshift clusters, effectively removing them from an AWS account. Deleting a Redshift cluster permanently erases all the data within the cluster and cannot be undone. This process might be undertaken to manage costs, decommission outdated data warehouses, or perform clean-up operations. It's crucial to ensure appropriate backups (snapshots) are in place before initiating a deletion to prevent accidental data loss.
inputs
outputs
import boto3
creds = _get_creds(cred_label)['creds']
access_key = creds['username']
secret_key = creds['password']
def delete_redshift_cluster(cluster_id, region):
"""
Attempts to delete a specified Amazon Redshift cluster in a given region.
Parameters:
- cluster_id (str): The unique identifier of the Redshift cluster to be deleted.
- region (str): The AWS region where the Redshift cluster is located.
"""
try:
# Initialize the boto3 client for Amazon Redshift with the appropriate region
redshift = boto3.client('redshift', aws_access_key_id=access_key, aws_secret_access_key=secret_key, region_name=region)
# Initiate the deletion of the specified Redshift cluster.
response = redshift.delete_cluster(ClusterIdentifier=cluster_id, SkipFinalClusterSnapshot=True)
print(f"Redshift cluster {cluster_id} deletion initiated in region {region}.")
except redshift.exceptions.ClusterNotFoundFault:
print(f"Redshift cluster {cluster_id} not found in region {region}.")
except redshift.exceptions.InvalidClusterStateFault:
print(f"Redshift cluster {cluster_id} is in an invalid state for deletion in region {region}.")
except Exception as e:
print(f"Error deleting Redshift cluster {cluster_id} in region {region}: {e}")
# Example usage
#clusters_info = [{'Region': 'us-west-2', 'ClusterID': 'example-cluster-1'}, {'Region': 'us-east-1', 'ClusterID': 'example-cluster-2'}]
clusters_to_delete = clusters_info
# clusters_info passed down from parent task to delete said Redshift Clusters
# Can replace clusters_info with a list of cluster_id to delete any Redshift Cluster using this task
if clusters_to_delete:
for cluster in clusters_to_delete:
delete_redshift_cluster(cluster['ClusterID'], cluster['Region'])
else:
print("No Redshift Clusters provided for deletion")
copied