Resume an AWS Redshift Cluster

import boto3 creds = _get_creds(cred_label)['creds'] access_key = creds['username'] secret_key = creds['password'] # Check if 'cluster_identifier' has been provided from the parent task. If not, initialize it to an empty string. cluster_identifier = cluster_identifier if 'cluster_identifier' in locals() else "" def resume_redshift_cluster(cluster_id, region): # Check if the cluster_id is empty or not if not cluster_id: print("No Redshift Cluster provided for resuming.") return try: redshift = boto3.client('redshift',aws_access_key_id=access_key,aws_secret_access_key=secret_key, region_name = region) # Attempt to resume the specified Redshift cluster response = redshift.resume_cluster(ClusterIdentifier=cluster_id) # Check the cluster status to confirm the resume operation if response['Cluster']['ClusterStatus'] == 'resuming': print(f"Resuming cluster {cluster_id}.") return True else: print(f"Unexpected status {response['Cluster']['ClusterStatus']} for cluster {cluster_id}.") return False # Handle specific exceptions except redshift.exceptions.ClusterNotFoundFault: print(f"Cluster {cluster_id} not found.") return False except redshift.exceptions.InvalidClusterStateFault: print(f"Cluster {cluster_id} is in an invalid state for resuming. Ensure it is currently paused.") return False except redshift.exceptions.UnauthorizedOperation: print(f"Unauthorized to resume cluster {cluster_id}. Check your AWS IAM permissions.") return False # Handle general exceptions except Exception as e: print(f"Error resuming cluster {cluster_id}: {e}") return False # Try resuming the cluster and print feedback success = resume_redshift_cluster(cluster_identifier, resume_cluster_region) if success is not None: if success: print("Resume operation initiated successfully.") else: print("Failed to initiate resume operation.")