Supprimer un cluster - Amazon Aurora DSQL

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Supprimer un cluster

Consultez les informations suivantes pour savoir comment supprimer un cluster dans Aurora DSQL.

Python

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

import boto3 def delete_cluster(region, identifier): try: client = boto3.client("dsql", region_name=region) cluster = client.delete_cluster(identifier=identifier) print(f"Initiated delete of {cluster["arn"]}") print("Waiting for cluster to finish deletion") client.get_waiter("cluster_not_exists").wait( identifier=cluster["identifier"], WaiterConfig={ 'Delay': 10, 'MaxAttempts': 30 } ) except: print("Unable to delete cluster " + identifier) raise def main(): region = "us-east-1" cluster_id = "<cluster id>" # Use a placeholder in docs delete_cluster(region, cluster_id) print(f"Deleted {cluster_id}") if __name__ == "__main__": main()

Pour supprimer un cluster multirégional, utilisez l'exemple suivant.

import boto3 def delete_multi_region_clusters(region_1, cluster_id_1, region_2, cluster_id_2): try: client_1 = boto3.client("dsql", region_name=region_1) client_2 = boto3.client("dsql", region_name=region_2) client_1.delete_cluster(identifier=cluster_id_1) print(f"Deleting cluster {cluster_id_1} in {region_1}") # cluster_1 will stay in PENDING_DELETE state until cluster_2 is deleted client_2.delete_cluster(identifier=cluster_id_2) print(f"Deleting cluster {cluster_id_2} in {region_2}") # Now that both clusters have been marked for deletion they will transition # to DELETING state and finalize deletion print(f"Waiting for {cluster_id_1} to finish deletion") client_1.get_waiter("cluster_not_exists").wait( identifier=cluster_id_1, WaiterConfig={ 'Delay': 10, 'MaxAttempts': 30 } ) print(f"Waiting for {cluster_id_2} to finish deletion") client_2.get_waiter("cluster_not_exists").wait( identifier=cluster_id_2, WaiterConfig={ 'Delay': 10, 'MaxAttempts': 30 } ) except: print("Unable to delete cluster") raise def main(): region_1 = "us-east-1" cluster_id_1 = "<cluster 1 id>" region_2 = "us-east-2" cluster_id_2 = "<cluster 2 id>" delete_multi_region_clusters(region_1, cluster_id_1, region_2, cluster_id_2) print(f"Deleted {cluster_id_1} in {region_1} and {cluster_id_2} in {region_2}") if __name__ == "__main__": main()
C++

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

#include <aws/core/Aws.h> #include <aws/core/utils/Outcome.h> #include <aws/dsql/DSQLClient.h> #include <aws/dsql/model/DeleteClusterRequest.h> #include <aws/dsql/model/GetClusterRequest.h> #include <iostream> #include <thread> #include <chrono> using namespace Aws; using namespace Aws::DSQL; using namespace Aws::DSQL::Model; /** * Deletes a single-region cluster in Amazon Aurora DSQL */ void DeleteCluster(const Aws::String& region, const Aws::String& identifier) { // Create client for the specified region DSQL::DSQLClientConfiguration clientConfig; clientConfig.region = region; DSQL::DSQLClient client(clientConfig); // Delete the cluster DeleteClusterRequest deleteRequest; deleteRequest.SetIdentifier(identifier); deleteRequest.SetClientToken(Aws::Utils::UUID::RandomUUID()); auto deleteOutcome = client.DeleteCluster(deleteRequest); if (!deleteOutcome.IsSuccess()) { std::cerr << "Failed to delete cluster " << identifier << " in " << region << ": " << deleteOutcome.GetError().GetMessage() << std::endl; throw std::runtime_error("Unable to delete cluster " + identifier + " in " + region); } auto cluster = deleteOutcome.GetResult(); std::cout << "Initiated delete of " << cluster.GetArn() << std::endl; } int main() { Aws::SDKOptions options; Aws::InitAPI(options); { try { // Define region and cluster ID Aws::String region = "us-east-1"; Aws::String clusterId = "<your cluster id>"; DeleteCluster(region, clusterId); std::cout << "Deleted " << clusterId << std::endl; } catch (const std::exception& e) { std::cerr << "Error: " << e.what() << std::endl; } } Aws::ShutdownAPI(options); return 0; }

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

#include <aws/core/Aws.h> #include <aws/core/utils/Outcome.h> #include <aws/dsql/DSQLClient.h> #include <aws/dsql/model/DeleteClusterRequest.h> #include <aws/dsql/model/GetClusterRequest.h> #include <iostream> #include <thread> #include <chrono> using namespace Aws; using namespace Aws::DSQL; using namespace Aws::DSQL::Model; /** * Deletes multi-region clusters in Amazon Aurora DSQL */ void DeleteMultiRegionClusters( const Aws::String& region1, const Aws::String& clusterId1, const Aws::String& region2, const Aws::String& clusterId2) { // Create clients for each region DSQL::DSQLClientConfiguration clientConfig1; clientConfig1.region = region1; DSQL::DSQLClient client1(clientConfig1); DSQL::DSQLClientConfiguration clientConfig2; clientConfig2.region = region2; DSQL::DSQLClient client2(clientConfig2); // Delete the first cluster std::cout << "Deleting cluster " << clusterId1 << " in " << region1 << std::endl; DeleteClusterRequest deleteRequest1; deleteRequest1.SetIdentifier(clusterId1); deleteRequest1.SetClientToken(Aws::Utils::UUID::RandomUUID()); auto deleteOutcome1 = client1.DeleteCluster(deleteRequest1); if (!deleteOutcome1.IsSuccess()) { std::cerr << "Failed to delete cluster " << clusterId1 << " in " << region1 << ": " << deleteOutcome1.GetError().GetMessage() << std::endl; throw std::runtime_error("Failed to delete multi-region clusters"); } // cluster1 will stay in PENDING_DELETE state until cluster2 is deleted std::cout << "Deleting cluster " << clusterId2 << " in " << region2 << std::endl; DeleteClusterRequest deleteRequest2; deleteRequest2.SetIdentifier(clusterId2); deleteRequest2.SetClientToken(Aws::Utils::UUID::RandomUUID()); auto deleteOutcome2 = client2.DeleteCluster(deleteRequest2); if (!deleteOutcome2.IsSuccess()) { std::cerr << "Failed to delete cluster " << clusterId2 << " in " << region2 << ": " << deleteOutcome2.GetError().GetMessage() << std::endl; throw std::runtime_error("Failed to delete multi-region clusters"); } } int main() { Aws::SDKOptions options; Aws::InitAPI(options); { try { Aws::String region1 = "us-east-1"; Aws::String clusterId1 = "<your cluster id 1>"; Aws::String region2 = "us-east-2"; Aws::String clusterId2 = "<your cluster id 2>"; DeleteMultiRegionClusters(region1, clusterId1, region2, clusterId2); std::cout << "Deleted " << clusterId1 << " in " << region1 << " and " << clusterId2 << " in " << region2 << std::endl; } catch (const std::exception& e) { std::cerr << "Error: " << e.what() << std::endl; } } Aws::ShutdownAPI(options); return 0; }
JavaScript

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

import { DSQLClient, DeleteClusterCommand, waitUntilClusterNotExists } from "@aws-sdk/client-dsql"; async function deleteCluster(region, clusterId) { const client = new DSQLClient({ region }); try { const deleteClusterCommand = new DeleteClusterCommand({ identifier: clusterId, }); const response = await client.send(deleteClusterCommand); console.log(`Waiting for cluster ${response.identifier} to finish deletion`); await waitUntilClusterNotExists( { client: client, maxWaitTime: 300 // Wait for 5 minutes }, { identifier: response.identifier } ); console.log(`Cluster Id ${response.identifier} is now deleted`); return; } catch (error) { if (error.name === "ResourceNotFoundException") { console.log("Cluster ID not found or already deleted"); } else { console.error("Unable to delete cluster: ", error.message); } throw error; } } async function main() { const region = "us-east-1"; const clusterId = "<CLUSTER_ID>"; await deleteCluster(region, clusterId); } main();

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

import { DSQLClient, DeleteClusterCommand, waitUntilClusterNotExists } from "@aws-sdk/client-dsql"; async function deleteMultiRegionClusters(region1, cluster1_id, region2, cluster2_id) { const client1 = new DSQLClient({ region: region1 }); const client2 = new DSQLClient({ region: region2 }); try { const deleteClusterCommand1 = new DeleteClusterCommand({ identifier: cluster1_id, }); const response1 = await client1.send(deleteClusterCommand1); const deleteClusterCommand2 = new DeleteClusterCommand({ identifier: cluster2_id, }); const response2 = await client2.send(deleteClusterCommand2); console.log(`Waiting for cluster1 ${response1.identifier} to finish deletion`); await waitUntilClusterNotExists( { client: client1, maxWaitTime: 300 // Wait for 5 minutes }, { identifier: response1.identifier } ); console.log(`Cluster1 Id ${response1.identifier} is now deleted`); console.log(`Waiting for cluster2 ${response2.identifier} to finish deletion`); await waitUntilClusterNotExists( { client: client2, maxWaitTime: 300 // Wait for 5 minutes }, { identifier: response2.identifier } ); console.log(`Cluster2 Id ${response2.identifier} is now deleted`); return; } catch (error) { if (error.name === "ResourceNotFoundException") { console.log("Some or all Cluster ARNs not found or already deleted"); } else { console.error("Unable to delete multi-region clusters: ", error.message); } throw error; } } async function main() { const region1 = "us-east-1"; const cluster1_id = "<CLUSTER_ID_1>"; const region2 = "us-east-2"; const cluster2_id = "<CLUSTER_ID_2>"; const response = await deleteMultiRegionClusters(region1, cluster1_id, region2, cluster2_id); console.log(`Deleted ${cluster1_id} in ${region1} and ${cluster2_id} in ${region2}`); } main();
Java

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

package org.example; import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider; import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.retries.api.BackoffStrategy; import software.amazon.awssdk.services.dsql.DsqlClient; import software.amazon.awssdk.services.dsql.model.DeleteClusterResponse; import software.amazon.awssdk.services.dsql.model.ResourceNotFoundException; import java.time.Duration; public class DeleteCluster { public static void main(String[] args) { Region region = Region.US_EAST_1; String clusterId = "<your cluster id>"; try ( DsqlClient client = DsqlClient.builder() .region(region) .credentialsProvider(DefaultCredentialsProvider.create()) .build() ) { DeleteClusterResponse cluster = client.deleteCluster(r -> r.identifier(clusterId)); System.out.println("Initiated delete of " + cluster.arn()); // The DSQL SDK offers a built-in waiter to poll for deletion. System.out.println("Waiting for cluster to finish deletion"); client.waiter().waitUntilClusterNotExists( getCluster -> getCluster.identifier(clusterId), config -> config.backoffStrategyV2( BackoffStrategy.fixedDelayWithoutJitter(Duration.ofSeconds(10)) ).waitTimeout(Duration.ofMinutes(5)) ); System.out.println("Deleted " + cluster.arn()); } catch (ResourceNotFoundException e) { System.out.printf("Cluster %s not found in %s%n", clusterId, region); } } }

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

package org.example; import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider; import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.retries.api.BackoffStrategy; import software.amazon.awssdk.services.dsql.DsqlClient; import software.amazon.awssdk.services.dsql.DsqlClientBuilder; import software.amazon.awssdk.services.dsql.model.DeleteClusterRequest; import java.time.Duration; public class DeleteMultiRegionClusters { public static void main(String[] args) { Region region1 = Region.US_EAST_1; String clusterId1 = "<your cluster id 1>"; Region region2 = Region.US_EAST_2; String clusterId2 = "<your cluster id 2>"; DsqlClientBuilder clientBuilder = DsqlClient.builder() .credentialsProvider(DefaultCredentialsProvider.create()); try ( DsqlClient client1 = clientBuilder.region(region1).build(); DsqlClient client2 = clientBuilder.region(region2).build() ) { System.out.printf("Deleting cluster %s in %s%n", clusterId1, region1); DeleteClusterRequest request1 = DeleteClusterRequest.builder() .identifier(clusterId1) .build(); client1.deleteCluster(request1); // cluster1 will stay in PENDING_DELETE until cluster2 is deleted System.out.printf("Deleting cluster %s in %s%n", clusterId2, region2); DeleteClusterRequest request2 = DeleteClusterRequest.builder() .identifier(clusterId2) .build(); client2.deleteCluster(request2); // Now that both clusters have been marked for deletion they will transition // to DELETING state and finalize deletion. System.out.printf("Waiting for cluster %s to finish deletion%n", clusterId1); client1.waiter().waitUntilClusterNotExists( getCluster -> getCluster.identifier(clusterId1), config -> config.backoffStrategyV2( BackoffStrategy.fixedDelayWithoutJitter(Duration.ofSeconds(10)) ).waitTimeout(Duration.ofMinutes(5)) ); System.out.printf("Waiting for cluster %s to finish deletion%n", clusterId2); client2.waiter().waitUntilClusterNotExists( getCluster -> getCluster.identifier(clusterId2), config -> config.backoffStrategyV2( BackoffStrategy.fixedDelayWithoutJitter(Duration.ofSeconds(10)) ).waitTimeout(Duration.ofMinutes(5)) ); System.out.printf("Deleted %s in %s and %s in %s%n", clusterId1, region1, clusterId2, region2); } } }
Rust

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

use aws_config::load_defaults; use aws_sdk_dsql::client::Waiters; use aws_sdk_dsql::{ Client, Config, config::{BehaviorVersion, Region}, }; /// Create a client. We will use this later for performing operations on the cluster. async fn dsql_client(region: &'static str) -> Client { // Load default SDK configuration let sdk_defaults = load_defaults(BehaviorVersion::latest()).await; // You can set your own credentials by following this guide // https://docs.aws.amazon.com/sdk-for-rust/latest/dg/credproviders.html let credentials = sdk_defaults.credentials_provider().unwrap(); let config = Config::builder() .behavior_version(BehaviorVersion::latest()) .credentials_provider(credentials) .region(Region::new(region)) .build(); Client::from_conf(config) } /// Delete a DSQL cluster pub async fn delete_cluster(region: &'static str, identifier: &'static str) { let client = dsql_client(region).await; let delete_response = client .delete_cluster() .identifier(identifier) .send() .await .unwrap(); println!("Initiated delete of {}", delete_response.arn); println!("Waiting for cluster to finish deletion"); client .wait_until_cluster_not_exists() .identifier(identifier) .wait(std::time::Duration::from_secs(300)) // Wait up to 5 minutes .await .unwrap(); } #[tokio::main(flavor = "current_thread")] pub async fn main() -> anyhow::Result<()> { let region = "us-east-1"; let cluster_id = "<cluster to be deleted>"; delete_cluster(region, cluster_id).await; println!("Deleted {cluster_id}"); Ok(()) }

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

use aws_config::{BehaviorVersion, Region, load_defaults}; use aws_sdk_dsql::client::Waiters; use aws_sdk_dsql::{Client, Config}; /// Create a client. We will use this later for performing operations on the cluster. async fn dsql_client(region: &'static str) -> Client { // Load default SDK configuration let sdk_defaults = load_defaults(BehaviorVersion::latest()).await; // You can set your own credentials by following this guide // https://docs.aws.amazon.com/sdk-for-rust/latest/dg/credproviders.html let credentials = sdk_defaults.credentials_provider().unwrap(); let config = Config::builder() .behavior_version(BehaviorVersion::latest()) .credentials_provider(credentials) .region(Region::new(region)) .build(); Client::from_conf(config) } /// Create a cluster without delete protection and a name pub async fn delete_multi_region_clusters( region_1: &'static str, cluster_id_1: &'static str, region_2: &'static str, cluster_id_2: &'static str, ) { let client_1 = dsql_client(region_1).await; let client_2 = dsql_client(region_2).await; println!("Deleting cluster {cluster_id_1} in {region_1}"); client_1 .delete_cluster() .identifier(cluster_id_1) .send() .await .unwrap(); // cluster_1 will stay in PENDING_DELETE state until cluster_2 is deleted println!("Deleting cluster {cluster_id_2} in {region_2}"); client_2 .delete_cluster() .identifier(cluster_id_2) .send() .await .unwrap(); // Now that both clusters have been marked for deletion they will transition // to DELETING state and finalize deletion println!("Waiting for {cluster_id_1} to finish deletion"); client_1 .wait_until_cluster_not_exists() .identifier(cluster_id_1) .wait(std::time::Duration::from_secs(300)) // Wait up to 5 minutes .await .unwrap(); println!("Waiting for {cluster_id_2} to finish deletion"); client_2 .wait_until_cluster_not_exists() .identifier(cluster_id_2) .wait(std::time::Duration::from_secs(300)) // Wait up to 5 minutes .await .unwrap(); } #[tokio::main(flavor = "current_thread")] pub async fn main() -> anyhow::Result<()> { let region_1 = "us-east-1"; let cluster_id_1 = "<cluster 1 to be deleted>"; let region_2 = "us-east-2"; let cluster_id_2 = "<cluster 2 to be deleted>"; delete_multi_region_clusters(region_1, cluster_id_1, region_2, cluster_id_2).await; println!("Deleted {cluster_id_1} in {region_1} and {cluster_id_2} in {region_2}"); Ok(()) }
Ruby

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

equire "aws-sdk-dsql" def delete_cluster(region, identifier) client = Aws::DSQL::Client.new(region: region) cluster = client.delete_cluster(identifier: identifier) puts "Initiated delete of #{cluster.arn}" # The DSQL SDK offers built-in waiters to poll for deletion. puts "Waiting for cluster to finish deletion" client.wait_until(:cluster_not_exists, identifier: cluster.identifier) do |w| # Wait for 5 minutes w.max_attempts = 30 w.delay = 10 end rescue Aws::Errors::ServiceError => e abort "Unable to delete cluster #{identifier} in #{region}: #{e.message}" end def main region = "us-east-1" cluster_id = "<your cluster id>" delete_cluster(region, cluster_id) puts "Deleted #{cluster_id}" end main if $PROGRAM_NAME == __FILE__

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

require "aws-sdk-dsql" def delete_multi_region_clusters(region_1, cluster_id_1, region_2, cluster_id_2) client_1 = Aws::DSQL::Client.new(region: region_1) client_2 = Aws::DSQL::Client.new(region: region_2) puts "Deleting cluster #{cluster_id_1} in #{region_1}" client_1.delete_cluster(identifier: cluster_id_1) # cluster_1 will stay in PENDING_DELETE state until cluster_2 is deleted puts "Deleting #{cluster_id_2} in #{region_2}" client_2.delete_cluster(identifier: cluster_id_2) # Now that both clusters have been marked for deletion they will transition # to DELETING state and finalize deletion puts "Waiting for #{cluster_id_1} to finish deletion" client_1.wait_until(:cluster_not_exists, identifier: cluster_id_1) do |w| # Wait for 5 minutes w.max_attempts = 30 w.delay = 10 end puts "Waiting for #{cluster_id_2} to finish deletion" client_2.wait_until(:cluster_not_exists, identifier: cluster_id_2) do |w| # Wait for 5 minutes w.max_attempts = 30 w.delay = 10 end rescue Aws::Errors::ServiceError => e abort "Failed to delete multi-region clusters: #{e.message}" end def main region_1 = "us-east-1" cluster_id_1 = "<your cluster id 1>" region_2 = "us-east-2" cluster_id_2 = "<your cluster id 2>" delete_multi_region_clusters(region_1, cluster_id_1, region_2, cluster_id_2) puts "Deleted #{cluster_id_1} in #{region_1} and #{cluster_id_2} in #{region_2}" end main if $PROGRAM_NAME == __FILE__
.NET

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

using System; using System.Threading.Tasks; using Amazon; using Amazon.DSQL; using Amazon.DSQL.Model; using Amazon.Runtime.Credentials; namespace DSQLExamples.examples { public class DeleteSingleRegionCluster { /// <summary> /// Create a client. We will use this later for performing operations on the cluster. /// </summary> private static async Task<AmazonDSQLClient> CreateDSQLClient(RegionEndpoint region) { var awsCredentials = await DefaultAWSCredentialsIdentityResolver.GetCredentialsAsync(); var clientConfig = new AmazonDSQLConfig { RegionEndpoint = region }; return new AmazonDSQLClient(awsCredentials, clientConfig); } /// <summary> /// Delete a DSQL cluster. /// </summary> public static async Task Delete(RegionEndpoint region, string identifier) { using (var client = await CreateDSQLClient(region)) { var deleteRequest = new DeleteClusterRequest { Identifier = identifier }; var deleteResponse = await client.DeleteClusterAsync(deleteRequest); Console.WriteLine($"Initiated deletion of {deleteResponse.Arn}"); } } private static async Task Main() { var region = RegionEndpoint.USEast1; var clusterId = "<cluster to be deleted>"; await Delete(region, clusterId); } } }

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

using System; using System.Threading.Tasks; using Amazon; using Amazon.DSQL; using Amazon.DSQL.Model; using Amazon.Runtime.Credentials; using Amazon.Runtime.Endpoints; namespace DSQLExamples.examples { public class DeleteMultiRegionClusters { /// <summary> /// Create a client. We will use this later for performing operations on the cluster. /// </summary> private static async Task<AmazonDSQLClient> CreateDSQLClient(RegionEndpoint region) { var awsCredentials = await DefaultAWSCredentialsIdentityResolver.GetCredentialsAsync(); var clientConfig = new AmazonDSQLConfig { RegionEndpoint = region, }; return new AmazonDSQLClient(awsCredentials, clientConfig); } /// <summary> /// Delete multi-region clusters. /// </summary> public static async Task Delete( RegionEndpoint region1, string clusterId1, RegionEndpoint region2, string clusterId2) { using (var client1 = await CreateDSQLClient(region1)) using (var client2 = await CreateDSQLClient(region2)) { var deleteRequest1 = new DeleteClusterRequest { Identifier = clusterId1 }; var deleteResponse1 = await client1.DeleteClusterAsync(deleteRequest1); Console.WriteLine($"Initiated deletion of {deleteResponse1.Arn}"); // cluster 1 will stay in PENDING_DELETE state until cluster 2 is deleted var deleteRequest2 = new DeleteClusterRequest { Identifier = clusterId2 }; var deleteResponse2 = await client2.DeleteClusterAsync(deleteRequest2); Console.WriteLine($"Initiated deletion of {deleteResponse2.Arn}"); } } private static async Task Main() { var region1 = RegionEndpoint.USEast1; var cluster1 = "<cluster 1 to be deleted>"; var region2 = RegionEndpoint.USEast2; var cluster2 = "<cluster 2 to be deleted>"; await Delete(region1, cluster1, region2, cluster2); } } }
Golang

Pour supprimer un cluster en un seul Région AWS, utilisez l'exemple suivant.

package main import ( "context" "fmt" "log" "time" "github.com/aws/aws-sdk-go-v2/config" "github.com/aws/aws-sdk-go-v2/service/dsql" ) func DeleteSingleRegion(ctx context.Context, identifier, region string) error { cfg, err := config.LoadDefaultConfig(ctx, config.WithRegion(region)) if err != nil { log.Fatalf("Failed to load AWS configuration: %v", err) } // Initialize the DSQL client client := dsql.NewFromConfig(cfg) // Create delete cluster input deleteInput := &dsql.DeleteClusterInput{ Identifier: &identifier, } // Delete the cluster result, err := client.DeleteCluster(ctx, deleteInput) if err != nil { return fmt.Errorf("failed to delete cluster: %w", err) } fmt.Printf("Initiated deletion of cluster: %s\n", *result.Arn) // Create waiter to check cluster deletion waiter := dsql.NewClusterNotExistsWaiter(client, func(options *dsql.ClusterNotExistsWaiterOptions) { options.MinDelay = 10 * time.Second options.MaxDelay = 30 * time.Second options.LogWaitAttempts = true }) // Create the input for checking cluster status getInput := &dsql.GetClusterInput{ Identifier: &identifier, } // Wait for the cluster to be deleted fmt.Printf("Waiting for cluster %s to be deleted...\n", identifier) err = waiter.Wait(ctx, getInput, 5*time.Minute) if err != nil { return fmt.Errorf("error waiting for cluster to be deleted: %w", err) } fmt.Printf("Cluster %s has been successfully deleted\n", identifier) return nil } func DeleteCluster(ctx context.Context) { } // Example usage in main function func main() { // Your existing setup code for client configuration... ctx, cancel := context.WithTimeout(context.Background(), 6*time.Minute) defer cancel() // Example cluster identifier // Need to make sure that cluster does not have delete protection enabled identifier := "<CLUSTER_ID>" region := "us-east-1" err := DeleteSingleRegion(ctx, identifier, region) if err != nil { log.Fatalf("Failed to delete cluster: %v", err) } }

Pour supprimer un cluster multirégional, utilisez l'exemple suivant. La suppression d'un cluster multirégional peut prendre un certain temps.

package main import ( "context" "fmt" "log" "time" "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/config" "github.com/aws/aws-sdk-go-v2/service/dsql" ) func DeleteMultiRegionClusters(ctx context.Context, region1, clusterId1, region2, clusterId2 string) error { // Load the AWS configuration for region 1 cfg1, err := config.LoadDefaultConfig(ctx, config.WithRegion(region1)) if err != nil { return fmt.Errorf("unable to load SDK config for region %s: %w", region1, err) } // Load the AWS configuration for region 2 cfg2, err := config.LoadDefaultConfig(ctx, config.WithRegion(region2)) if err != nil { return fmt.Errorf("unable to load SDK config for region %s: %w", region2, err) } // Create DSQL clients for both regions client1 := dsql.NewFromConfig(cfg1) client2 := dsql.NewFromConfig(cfg2) // Delete cluster in region 1 fmt.Printf("Deleting cluster %s in %s\n", clusterId1, region1) _, err = client1.DeleteCluster(ctx, &dsql.DeleteClusterInput{ Identifier: aws.String(clusterId1), }) if err != nil { return fmt.Errorf("failed to delete cluster in region %s: %w", region1, err) } // Delete cluster in region 2 fmt.Printf("Deleting cluster %s in %s\n", clusterId2, region2) _, err = client2.DeleteCluster(ctx, &dsql.DeleteClusterInput{ Identifier: aws.String(clusterId2), }) if err != nil { return fmt.Errorf("failed to delete cluster in region %s: %w", region2, err) } // Create waiters for both regions waiter1 := dsql.NewClusterNotExistsWaiter(client1, func(options *dsql.ClusterNotExistsWaiterOptions) { options.MinDelay = 10 * time.Second options.MaxDelay = 30 * time.Second options.LogWaitAttempts = true }) waiter2 := dsql.NewClusterNotExistsWaiter(client2, func(options *dsql.ClusterNotExistsWaiterOptions) { options.MinDelay = 10 * time.Second options.MaxDelay = 30 * time.Second options.LogWaitAttempts = true }) // Wait for cluster in region 1 to be deleted fmt.Printf("Waiting for cluster %s to finish deletion\n", clusterId1) err = waiter1.Wait(ctx, &dsql.GetClusterInput{ Identifier: aws.String(clusterId1), }, 5*time.Minute) if err != nil { return fmt.Errorf("error waiting for cluster deletion in region %s: %w", region1, err) } // Wait for cluster in region 2 to be deleted fmt.Printf("Waiting for cluster %s to finish deletion\n", clusterId2) err = waiter2.Wait(ctx, &dsql.GetClusterInput{ Identifier: aws.String(clusterId2), }, 5*time.Minute) if err != nil { return fmt.Errorf("error waiting for cluster deletion in region %s: %w", region2, err) } fmt.Printf("Successfully deleted clusters %s in %s and %s in %s\n", clusterId1, region1, clusterId2, region2) return nil } // Example usage in main function func main() { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute) defer cancel() err := DeleteMultiRegionClusters( ctx, "us-east-1", // region1 "<CLUSTER_ID_1>", // clusterId1 "us-east-2", // region2 "<CLUSTER_ID_2>", // clusterId2 ) if err != nil { log.Fatalf("Failed to delete multi-region clusters: %v", err) } }