D'autres exemples de AWS SDK sont disponibles dans le référentiel [AWS Doc SDK Examples](https://github.com/awsdocs/aws-doc-sdk-examples) GitHub .
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.
# Exemples de base pour l'utilisation d'Amazon Redshift AWS SDKs
Les exemples de code suivants montrent comment utiliser les bases d'Amazon Redshift avec. AWS SDKs
**Contents**
+ [Bonjour Amazon Redshift](redshift_example_redshift_Hello_section.md)
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
+ [Actions](redshift_code_examples_actions.md)
+ [`CreateCluster`](redshift_example_redshift_CreateCluster_section.md)
+ [`DeleteCluster`](redshift_example_redshift_DeleteCluster_section.md)
+ [`DescribeClusters`](redshift_example_redshift_DescribeClusters_section.md)
+ [`DescribeStatement`](redshift_example_redshift_DescribeStatement_section.md)
+ [`ExecuteStatement`](redshift_example_redshift_ExecuteStatement_section.md)
+ [`GetStatementResult`](redshift_example_redshift_GetStatementResult_section.md)
+ [`ListDatabases`](redshift_example_redshift_ListDatabases_section.md)
+ [`ModifyCluster`](redshift_example_redshift_ModifyCluster_section.md)
# Bonjour Amazon Redshift
Les exemples de code suivants montrent comment démarrer avec Amazon Redshift.
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Main method to run the Hello Amazon Redshift example.
///
/// Command line arguments (not used).
public static async Task Main(string[] args)
{
var redshiftClient = new AmazonRedshiftClient();
Console.WriteLine("Hello, Amazon Redshift! Let's list available clusters:");
var clusters = new List();
try
{
// Use pagination to retrieve all clusters.
var clustersPaginator = redshiftClient.Paginators.DescribeClusters(new DescribeClustersRequest());
await foreach (var response in clustersPaginator.Responses)
{
if (response.Clusters != null)
clusters.AddRange(response.Clusters);
}
Console.WriteLine($"{clusters.Count} cluster(s) retrieved.");
foreach (var cluster in clusters)
{
Console.WriteLine($"\t{cluster.ClusterIdentifier} (Status: {cluster.ClusterStatus})");
}
}
catch (AmazonRedshiftException ex)
{
Console.WriteLine($"Couldn't list clusters. Here's why: {ex.Message}");
}
catch (Exception ex)
{
Console.WriteLine($"An error occurred: {ex.Message}");
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DescribeClusters)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
package main
import (
"context"
"fmt"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/service/redshift"
)
// main uses the AWS SDK for Go V2 to create a Redshift client
// and list up to 10 clusters in your account.
// This example uses the default settings specified in your shared credentials
// and config files.
func main() {
ctx := context.Background()
sdkConfig, err := config.LoadDefaultConfig(ctx)
if err != nil {
fmt.Println("Couldn't load default configuration. Have you set up your AWS account?")
fmt.Println(err)
return
}
redshiftClient := redshift.NewFromConfig(sdkConfig)
count := 20
fmt.Printf("Let's list up to %v clusters for your account.\n", count)
result, err := redshiftClient.DescribeClusters(ctx, &redshift.DescribeClustersInput{
MaxRecords: aws.Int32(int32(count)),
})
if err != nil {
fmt.Printf("Couldn't list clusters for your account. Here's why: %v\n", err)
return
}
if len(result.Clusters) == 0 {
fmt.Println("You don't have any clusters!")
return
}
for _, cluster := range result.Clusters {
fmt.Printf("\t%v : %v\n", *cluster.ClusterIdentifier, *cluster.ClusterStatus)
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.DescribeClusters)à la section *Référence des AWS SDK pour Go API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
```
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.redshift.RedshiftClient;
import software.amazon.awssdk.services.redshift.paginators.DescribeClustersIterable;
/**
* Before running this Java V2 code example, set up your development
* environment, including your credentials.
*
* For more information, see the following documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*/
public class HelloRedshift {
public static void main(String[] args) {
Region region = Region.US_EAST_1;
RedshiftClient redshiftClient = RedshiftClient.builder()
.region(region)
.build();
listClustersPaginator(redshiftClient);
}
public static void listClustersPaginator(RedshiftClient redshiftClient) {
DescribeClustersIterable clustersIterable = redshiftClient.describeClustersPaginator();
clustersIterable.stream()
.flatMap(r -> r.clusters().stream())
.forEach(cluster -> System.out
.println(" Cluster identifier: " + cluster.clusterIdentifier() + " status = " + cluster.clusterStatus()));
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DescribeClusters)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
import boto3
def hello_redshift(redshift_client):
"""
Use the AWS SDK for Python (Boto3) to create an Amazon Redshift client and list
the clusters in your account. This list might be empty if you haven't created
any clusters.
This example uses the default settings specified in your shared credentials
and config files.
:param redshift_client: A Boto3 Redshift Client object.
"""
print("Hello, Redshift! Let's list your clusters:")
paginator = redshift_client.get_paginator("describe_clusters")
clusters = []
for page in paginator.paginate():
clusters.extend(page["Clusters"])
print(f"{len(clusters)} cluster(s) were found.")
for cluster in clusters:
print(f" {cluster['ClusterIdentifier']}")
if __name__ == "__main__":
hello_redshift(boto3.client("redshift"))
```
+ Pour plus de détails sur l'API, consultez [DescribeClusters](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DescribeClusters)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
# Découvrez les bases d'Amazon Redshift avec un SDK AWS
Les exemples de code suivants montrent comment :
+ créer un cluster Redshift ;
+ Répertoriez les bases de données du cluster.
+ Créez une table intitulée Films.
+ Renseignez la table Films.
+ Interrogez la table Films par année.
+ Modifiez le cluster Redshift.
+ Supprimez le cluster Amazon Redshift.
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
Créez une classe d'enveloppe Redshift pour gérer les opérations.
```
///
/// Wrapper class for Amazon Redshift operations.
///
public class RedshiftWrapper
{
private readonly IAmazonRedshift _redshiftClient;
private readonly IAmazonRedshiftDataAPIService _redshiftDataClient;
///
/// Constructor for RedshiftWrapper.
///
/// Amazon Redshift client.
/// Amazon Redshift Data API client.
public RedshiftWrapper(IAmazonRedshift redshiftClient, IAmazonRedshiftDataAPIService redshiftDataClient)
{
_redshiftClient = redshiftClient;
_redshiftDataClient = redshiftDataClient;
}
///
/// Create a new Amazon Redshift cluster.
///
/// The identifier for the cluster.
/// The name of the database.
/// The master username.
/// The master user password.
/// The node type for the cluster.
/// The cluster that was created.
public async Task CreateClusterAsync(string clusterIdentifier, string databaseName,
string masterUsername, string masterUserPassword, string nodeType = "ra3.large")
{
try
{
var request = new CreateClusterRequest
{
ClusterIdentifier = clusterIdentifier,
DBName = databaseName,
MasterUsername = masterUsername,
MasterUserPassword = masterUserPassword,
NodeType = nodeType,
NumberOfNodes = 1,
ClusterType = "single-node"
};
var response = await _redshiftClient.CreateClusterAsync(request);
Console.WriteLine($"Created cluster {clusterIdentifier}");
return response.Cluster;
}
catch (ClusterAlreadyExistsException ex)
{
Console.WriteLine($"Cluster already exists: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't create cluster. Here's why: {ex.Message}");
throw;
}
}
///
/// Describe Amazon Redshift clusters.
///
/// Optional cluster identifier to describe a specific cluster.
/// A list of clusters.
public async Task> DescribeClustersAsync(string? clusterIdentifier = null)
{
try
{
var clusters = new List();
var request = new DescribeClustersRequest();
if (!string.IsNullOrEmpty(clusterIdentifier))
{
request.ClusterIdentifier = clusterIdentifier;
}
var clustersPaginator = _redshiftClient.Paginators.DescribeClusters(request);
await foreach (var response in clustersPaginator.Responses)
{
if (response.Clusters != null)
clusters.AddRange(response.Clusters);
}
Console.WriteLine($"{clusters.Count} cluster(s) retrieved.");
foreach (var cluster in clusters)
{
Console.WriteLine($"\t{cluster.ClusterIdentifier} (Status: {cluster.ClusterStatus})");
}
return clusters;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster {clusterIdentifier} not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't describe clusters. Here's why: {ex.Message}");
throw;
}
}
///
/// Modify an Amazon Redshift cluster.
///
/// The identifier for the cluster.
/// The preferred maintenance window.
/// True if successful.
public async Task ModifyClusterAsync(string clusterIdentifier, string preferredMaintenanceWindow)
{
try
{
var request = new ModifyClusterRequest
{
ClusterIdentifier = clusterIdentifier,
PreferredMaintenanceWindow = preferredMaintenanceWindow
};
var response = await _redshiftClient.ModifyClusterAsync(request);
Console.WriteLine($"The modified cluster was successfully modified and has {response.Cluster.PreferredMaintenanceWindow} as the maintenance window");
return true;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster {clusterIdentifier} not found: {ex.Message}");
return false;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't modify cluster. Here's why: {ex.Message}");
return false;
}
}
///
/// Delete an Amazon Redshift cluster without a final snapshot.
///
/// The identifier for the cluster.
/// True if successful.
public async Task DeleteClusterWithoutSnapshotAsync(string clusterIdentifier)
{
try
{
var request = new DeleteClusterRequest
{
ClusterIdentifier = clusterIdentifier,
SkipFinalClusterSnapshot = true
};
var response = await _redshiftClient.DeleteClusterAsync(request);
Console.WriteLine($"The {clusterIdentifier} was deleted");
return true;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster not found: {ex.Message}");
return false;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't delete cluster. Here's why: {ex.Message}");
return false;
}
}
///
/// List databases in a Redshift cluster.
///
/// The cluster identifier.
/// The database user.
/// The database name for authentication.
/// A list of database names.
public async Task> ListDatabasesAsync(string clusterIdentifier, string dbUser, string databaseName)
{
try
{
var request = new ListDatabasesRequest
{
ClusterIdentifier = clusterIdentifier,
DbUser = dbUser,
Database = databaseName
};
var response = await _redshiftDataClient.ListDatabasesAsync(request);
var databases = new List();
foreach (var database in response.Databases)
{
Console.WriteLine($"The database name is : {database}");
databases.Add(database);
}
return databases;
}
catch (Amazon.RedshiftDataAPIService.Model.ValidationException ex)
{
Console.WriteLine($"Validation error: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't list databases. Here's why: {ex.Message}");
throw;
}
}
///
/// Create a table in the Redshift database.
///
/// The cluster identifier.
/// The database name.
/// The database user.
/// The statement ID.
public async Task CreateTableAsync(string clusterIdentifier, string database, string dbUser)
{
try
{
var sqlStatement = @"
CREATE TABLE Movies (
id INTEGER PRIMARY KEY,
title VARCHAR(250) NOT NULL,
year INTEGER NOT NULL
)";
var request = new ExecuteStatementRequest
{
ClusterIdentifier = clusterIdentifier,
Database = database,
DbUser = dbUser,
Sql = sqlStatement
};
var response = await _redshiftDataClient.ExecuteStatementAsync(request);
await WaitForStatementToCompleteAsync(response.Id);
Console.WriteLine("Table created: Movies");
return response.Id;
}
catch (Amazon.RedshiftDataAPIService.Model.ValidationException ex)
{
Console.WriteLine($"Validation error: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't create table. Here's why: {ex.Message}");
throw;
}
}
///
/// Insert a record into the Movies table using parameterized query.
///
/// The cluster identifier.
/// The database name.
/// The database user.
/// The movie ID.
/// The movie title.
/// The movie year.
/// The statement ID.
public async Task InsertMovieAsync(string clusterIdentifier, string database, string dbUser,
int id, string title, int year)
{
try
{
var sqlStatement = "INSERT INTO Movies (id, title, year) VALUES (:id, :title, :year)";
var request = new ExecuteStatementRequest
{
ClusterIdentifier = clusterIdentifier,
Database = database,
DbUser = dbUser,
Sql = sqlStatement,
Parameters = new List
{
new SqlParameter { Name = "id", Value = id.ToString() },
new SqlParameter { Name = "title", Value = title },
new SqlParameter { Name = "year", Value = year.ToString() }
}
};
var response = await _redshiftDataClient.ExecuteStatementAsync(request);
await WaitForStatementToCompleteAsync(response.Id);
Console.WriteLine($"Inserted: {title} ({year})");
return response.Id;
}
catch (Amazon.RedshiftDataAPIService.Model.ValidationException ex)
{
Console.WriteLine($"Validation error: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't insert movie. Here's why: {ex.Message}");
throw;
}
}
///
/// Query movies by year using parameterized query.
///
/// The cluster identifier.
/// The database name.
/// The database user.
/// The year to query.
/// A list of movie titles.
public async Task> QueryMoviesByYearAsync(string clusterIdentifier, string database,
string dbUser, int year)
{
try
{
var sqlStatement = "SELECT title FROM Movies WHERE year = :year";
var request = new ExecuteStatementRequest
{
ClusterIdentifier = clusterIdentifier,
Database = database,
DbUser = dbUser,
Sql = sqlStatement,
Parameters = new List
{
new SqlParameter { Name = "year", Value = year.ToString() }
}
};
var response = await _redshiftDataClient.ExecuteStatementAsync(request);
Console.WriteLine($"The identifier of the statement is {response.Id}");
await WaitForStatementToCompleteAsync(response.Id);
var results = await GetStatementResultAsync(response.Id);
var movieTitles = new List();
foreach (var row in results)
{
if (row.Count > 0)
{
var title = row[0].StringValue;
Console.WriteLine($"The Movie title field is {title}");
movieTitles.Add(title);
}
}
return movieTitles;
}
catch (Amazon.RedshiftDataAPIService.Model.ValidationException ex)
{
Console.WriteLine($"Validation error: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't query movies. Here's why: {ex.Message}");
throw;
}
}
///
/// Describe a statement execution.
///
/// The statement ID.
/// The statement description.
public async Task DescribeStatementAsync(string statementId)
{
try
{
var request = new DescribeStatementRequest
{
Id = statementId
};
var response = await _redshiftDataClient.DescribeStatementAsync(request);
return response;
}
catch (Amazon.RedshiftDataAPIService.Model.ResourceNotFoundException ex)
{
Console.WriteLine($"Statement not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't describe statement. Here's why: {ex.Message}");
throw;
}
}
///
/// Get the results of a statement execution.
///
/// The statement ID.
/// A list of result rows.
public async Task>> GetStatementResultAsync(string statementId)
{
try
{
var request = new GetStatementResultRequest
{
Id = statementId
};
var response = await _redshiftDataClient.GetStatementResultAsync(request);
return response.Records;
}
catch (Amazon.RedshiftDataAPIService.Model.ResourceNotFoundException ex)
{
Console.WriteLine($"Statement not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't get statement result. Here's why: {ex.Message}");
throw;
}
}
///
/// Wait for a statement to complete execution.
///
/// The statement ID.
/// A task representing the asynchronous operation.
private async Task WaitForStatementToCompleteAsync(string statementId)
{
var status = StatusString.SUBMITTED;
DescribeStatementResponse? response = null;
while (status == StatusString.SUBMITTED || status == StatusString.PICKED || status == StatusString.STARTED)
{
await Task.Delay(1000); // Wait 1 second
response = await DescribeStatementAsync(statementId);
status = response.Status;
Console.WriteLine($"...{status}");
}
if (status == StatusString.FINISHED)
{
Console.WriteLine("The statement is finished!");
}
else
{
var errorMessage = response?.Error ?? "Unknown error";
Console.WriteLine($"The statement failed with status: {status}");
Console.WriteLine($"Error message: {errorMessage}");
}
}
///
/// Wait for a cluster to become available.
///
/// The cluster identifier.
/// A task representing the asynchronous operation.
public async Task WaitForClusterAvailableAsync(string clusterIdentifier)
{
Console.WriteLine($"Wait until {clusterIdentifier} is available. This may take a few minutes.");
var startTime = DateTime.Now;
var clusters = await DescribeClustersAsync(clusterIdentifier);
while (clusters[0].ClusterStatus != "available")
{
var elapsed = DateTime.Now - startTime;
Console.WriteLine($"Elapsed Time: {elapsed:mm\\:ss} - Waiting for cluster...");
await Task.Delay(5000); // Wait 5 seconds
clusters = await DescribeClustersAsync(clusterIdentifier);
}
var totalElapsed = DateTime.Now - startTime;
Console.WriteLine($"Cluster is available! Total Elapsed Time: {totalElapsed:mm\\:ss}");
}
}
```
Exécutez un scénario interactif illustrant les principes de base de Redshift.
```
///
/// Amazon Redshift Getting Started Scenario.
///
public class RedshiftBasics
{
public static bool IsInteractive = true;
public static RedshiftWrapper? Wrapper = null;
public static ILogger logger = null!;
private static readonly string _moviesFilePath = "../../../../../../resources/sample_files/movies.json";
///
/// Main method for the Amazon Redshift Getting Started scenario.
///
/// Command line arguments.
public static async Task Main(string[] args)
{
using var host = Host.CreateDefaultBuilder(args)
.ConfigureServices((_, services) =>
services.AddAWSService()
.AddAWSService()
.AddTransient()
)
.Build();
logger = LoggerFactory.Create(builder => { builder.AddConsole(); })
.CreateLogger();
Wrapper = host.Services.GetRequiredService();
await RunScenarioAsync();
}
///
/// Run the complete Amazon Redshift scenario.
///
public static async Task RunScenarioAsync()
{
// Set all variables to default values
string userName = "awsuser";
string userPassword = "AwsUser1000";
string clusterIdentifier = "redshift-cluster-movies";
var databaseName = "dev";
int recordCount = 50;
int year = 2013;
try
{
Console.WriteLine(
"================================================================================");
Console.WriteLine("Welcome to the Amazon Redshift SDK Getting Started scenario.");
Console.WriteLine(
"This .NET program demonstrates how to interact with Amazon Redshift by using the AWS SDK for .NET.");
Console.WriteLine("Let's get started...");
Console.WriteLine(
"================================================================================");
// Step 1: Get user credentials (if interactive)
if (IsInteractive)
{
Console.WriteLine("Please enter a user name for the cluster (default is awsuser):");
var userInput = Console.ReadLine();
if (!string.IsNullOrEmpty(userInput))
userName = userInput;
Console.WriteLine("================================================================================");
Console.WriteLine("Please enter a user password for the cluster (default is AwsUser1000):");
var passwordInput = Console.ReadLine();
if (!string.IsNullOrEmpty(passwordInput))
userPassword = passwordInput;
Console.WriteLine("================================================================================");
// Step 2: Get cluster identifier
Console.WriteLine("Enter a cluster id value (default is redshift-cluster-movies):");
var clusterInput = Console.ReadLine();
if (!string.IsNullOrEmpty(clusterInput))
clusterIdentifier = clusterInput;
}
else
{
Console.WriteLine($"Using default values: userName={userName}, clusterIdentifier={clusterIdentifier}");
}
// Step 3: Create Redshift cluster
await Wrapper!.CreateClusterAsync(clusterIdentifier, databaseName, userName, userPassword);
Console.WriteLine("================================================================================");
// Step 4: Wait for cluster to become available
Console.WriteLine("================================================================================");
await Wrapper.WaitForClusterAvailableAsync(clusterIdentifier);
Console.WriteLine("================================================================================");
// Step 5: List databases
Console.WriteLine("================================================================================");
Console.WriteLine($" When you created {clusterIdentifier}, the dev database is created by default and used in this scenario.");
Console.WriteLine(" To create a custom database, you need to have a CREATEDB privilege.");
Console.WriteLine(" For more information, see the documentation here: https://docs.aws.amazon.com/redshift/latest/dg/r_CREATE_DATABASE.html.");
if (IsInteractive)
{
Console.WriteLine("Press Enter to continue...");
Console.ReadLine();
}
Console.WriteLine("================================================================================");
Console.WriteLine("================================================================================");
Console.WriteLine($"List databases in {clusterIdentifier}");
if (IsInteractive)
{
Console.WriteLine("Press Enter to continue...");
Console.ReadLine();
}
await Wrapper.ListDatabasesAsync(clusterIdentifier, userName, databaseName);
Console.WriteLine("================================================================================");
// Step 6: Create Movies table
Console.WriteLine("================================================================================");
Console.WriteLine("Now you will create a table named Movies.");
if (IsInteractive)
{
Console.WriteLine("Press Enter to continue...");
Console.ReadLine();
}
await Wrapper.CreateTableAsync(clusterIdentifier, databaseName, userName);
Console.WriteLine("================================================================================");
// Step 7: Populate the Movies table
Console.WriteLine("================================================================================");
Console.WriteLine("Populate the Movies table using the Movies.json file.");
if (IsInteractive)
{
Console.WriteLine("Specify the number of records you would like to add to the Movies Table.");
Console.WriteLine("Please enter a value between 50 and 200.");
Console.Write("Enter a value: ");
var recordCountInput = Console.ReadLine();
if (int.TryParse(recordCountInput, out var inputCount) && inputCount is >= 50 and <= 200)
{
recordCount = inputCount;
}
else
{
Console.WriteLine($"Invalid input. Using default value of {recordCount}.");
}
}
else
{
Console.WriteLine($"Using default record count: {recordCount}");
}
await PopulateMoviesTableAsync(clusterIdentifier, databaseName, userName, recordCount);
Console.WriteLine($"{recordCount} records were added to the Movies table.");
Console.WriteLine("================================================================================");
// Step 8 & 9: Query movies by year
Console.WriteLine("================================================================================");
Console.WriteLine("Query the Movies table by year. Enter a value between 2012-2014.");
if (IsInteractive)
{
Console.Write("Enter a year: ");
var yearInput = Console.ReadLine();
if (int.TryParse(yearInput, out var inputYear) && inputYear is >= 2012 and <= 2014)
{
year = inputYear;
}
else
{
Console.WriteLine($"Invalid input. Using default value of {year}.");
}
}
else
{
Console.WriteLine($"Using default year: {year}");
}
await Wrapper.QueryMoviesByYearAsync(clusterIdentifier, databaseName, userName, year);
Console.WriteLine("================================================================================");
// Step 10: Modify the cluster
Console.WriteLine("================================================================================");
Console.WriteLine("Now you will modify the Redshift cluster.");
if (IsInteractive)
{
Console.WriteLine("Press Enter to continue...");
Console.ReadLine();
}
await Wrapper.ModifyClusterAsync(clusterIdentifier, "wed:07:30-wed:08:00");
Console.WriteLine("================================================================================");
// Step 11 & 12: Delete cluster confirmation
Console.WriteLine("================================================================================");
if (IsInteractive)
{
Console.WriteLine("Would you like to delete the Amazon Redshift cluster? (y/n)");
var deleteResponse = Console.ReadLine();
if (deleteResponse?.ToLower() == "y")
{
await Wrapper.DeleteClusterWithoutSnapshotAsync(clusterIdentifier);
}
}
else
{
Console.WriteLine("Deleting the Amazon Redshift cluster...");
await Wrapper.DeleteClusterWithoutSnapshotAsync(clusterIdentifier);
}
Console.WriteLine("================================================================================");
Console.WriteLine("================================================================================");
Console.WriteLine("This concludes the Amazon Redshift SDK Getting Started scenario.");
Console.WriteLine("================================================================================");
}
catch (Exception ex)
{
Console.WriteLine($"An error occurred during the scenario: {ex.Message}");
Console.WriteLine("Deleting the Amazon Redshift cluster...");
await Wrapper!.DeleteClusterWithoutSnapshotAsync(clusterIdentifier);
throw;
}
}
///
/// Populate the Movies table with data from the JSON file.
///
/// The cluster identifier.
/// The database name.
/// The database user.
/// Number of records to insert.
private static async Task PopulateMoviesTableAsync(string clusterIdentifier, string database, string dbUser, int recordCount)
{
if (!File.Exists(_moviesFilePath))
{
throw new FileNotFoundException($"Required movies data file not found at: {_moviesFilePath}");
}
var jsonContent = await File.ReadAllTextAsync(_moviesFilePath);
var options = new JsonSerializerOptions
{
PropertyNameCaseInsensitive = true
};
var movies = JsonSerializer.Deserialize>(jsonContent, options);
if (movies == null || movies.Count == 0)
{
throw new InvalidOperationException("Failed to parse movies JSON file or file is empty.");
}
var insertCount = Math.Min(recordCount, movies.Count);
for (int i = 0; i < insertCount; i++)
{
var movie = movies[i];
await Wrapper!.InsertMovieAsync(clusterIdentifier, database, dbUser, i, movie.Title, movie.Year);
}
}
///
/// Movie data model.
///
private class Movie
{
public string Title { get; set; } = string.Empty;
public int Year { get; set; }
}
}
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK pour .NET *.
+ [CreateCluster](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/CreateCluster)
+ [DescribeClusters](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DescribeClusters)
+ [DescribeStatement](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DescribeStatement)
+ [ExecuteStatement](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/ExecuteStatement)
+ [GetStatementResult](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/GetStatementResult)
+ [ListDatabasesPaginator](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/ListDatabasesPaginator)
+ [ModifyCluster](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/ModifyCluster)
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
package scenarios
import (
"context"
"encoding/json"
"errors"
"fmt"
"log"
"math/rand"
"strings"
"time"
"github.com/aws/aws-sdk-go-v2/aws"
redshift_types "github.com/aws/aws-sdk-go-v2/service/redshift/types"
redshiftdata_types "github.com/aws/aws-sdk-go-v2/service/redshiftdata/types"
"github.com/aws/aws-sdk-go-v2/service/secretsmanager"
"github.com/awsdocs/aws-doc-sdk-examples/gov2/demotools"
"github.com/awsdocs/aws-doc-sdk-examples/gov2/redshift/actions"
"github.com/aws/aws-sdk-go-v2/service/redshift"
"github.com/aws/aws-sdk-go-v2/service/redshiftdata"
)
// IScenarioHelper abstracts input and wait functions from a scenario so that they
// can be mocked for unit testing.
type IScenarioHelper interface {
GetName() string
}
const rMax = 100000
type ScenarioHelper struct {
Prefix string
Random *rand.Rand
}
// GetName returns a unique name formed of a prefix and a random number.
func (helper ScenarioHelper) GetName() string {
return fmt.Sprintf("%v%v", helper.Prefix, helper.Random.Intn(rMax))
}
// RedshiftBasicsScenario separates the steps of this scenario into individual functions so that
// they are simpler to read and understand.
type RedshiftBasicsScenario struct {
sdkConfig aws.Config
helper IScenarioHelper
questioner demotools.IQuestioner
pauser demotools.IPausable
filesystem demotools.IFileSystem
redshiftActor *actions.RedshiftActions
redshiftDataActor *actions.RedshiftDataActions
secretsmanager *SecretsManager
}
// SecretsManager is used to retrieve username and password information from a secure service.
type SecretsManager struct {
SecretsManagerClient *secretsmanager.Client
}
// RedshiftBasics constructs a new Redshift Basics runner.
func RedshiftBasics(sdkConfig aws.Config, questioner demotools.IQuestioner, pauser demotools.IPausable, filesystem demotools.IFileSystem, helper IScenarioHelper) RedshiftBasicsScenario {
scenario := RedshiftBasicsScenario{
sdkConfig: sdkConfig,
helper: helper,
questioner: questioner,
pauser: pauser,
filesystem: filesystem,
secretsmanager: &SecretsManager{SecretsManagerClient: secretsmanager.NewFromConfig(sdkConfig)},
redshiftActor: &actions.RedshiftActions{RedshiftClient: redshift.NewFromConfig(sdkConfig)},
redshiftDataActor: &actions.RedshiftDataActions{RedshiftDataClient: redshiftdata.NewFromConfig(sdkConfig)},
}
return scenario
}
// Movie makes it easier to use Movie objects given in json format.
type Movie struct {
ID int `json:"id"`
Title string `json:"title"`
Year int `json:"year"`
}
// User makes it easier to get the User data back from SecretsManager and use it later.
type User struct {
Username string `json:"userName"`
Password string `json:"userPassword"`
}
// Run runs the RedshiftBasics interactive example that shows you how to use Amazon
// Redshift and how to interact with its common endpoints.
//
// 0. Retrieve username and password information to access Redshift.
// 1. Create a cluster.
// 2. Wait for the cluster to become available.
// 3. List the available databases in the region.
// 4. Create a table named "Movies" in the "dev" database.
// 5. Populate the movies table from the "movies.json" file.
// 6. Query the movies table by year.
// 7. Modify the cluster's maintenance window.
// 8. Optionally clean up all resources created during this demo.
//
// This example creates an Amazon Redshift service client from the specified sdkConfig so that
// you can replace it with a mocked or stubbed config for unit testing.
//
// It uses a questioner from the `demotools` package to get input during the example.
// This package can be found in the ..\..\demotools folder of this repo.
func (runner *RedshiftBasicsScenario) Run(ctx context.Context) {
user := User{}
secretId := "s3express/basics/secrets"
clusterId := "demo-cluster-1"
maintenanceWindow := "wed:07:30-wed:08:00"
databaseName := "dev"
tableName := "Movies"
fileName := "Movies.json"
nodeType := "ra3.xlplus"
clusterType := "single-node"
defer func() {
if r := recover(); r != nil {
log.Println("Something went wrong with the demo.")
_, isMock := runner.questioner.(*demotools.MockQuestioner)
if isMock || runner.questioner.AskBool("Do you want to see the full error message (y/n)?", "y") {
log.Println(r)
}
runner.cleanUpResources(ctx, clusterId, databaseName, tableName, user.Username, runner.questioner)
}
}()
// Retrieve the userName and userPassword from SecretsManager
output, err := runner.secretsmanager.SecretsManagerClient.GetSecretValue(ctx, &secretsmanager.GetSecretValueInput{
SecretId: aws.String(secretId),
})
if err != nil {
log.Printf("There was a problem getting the secret value: %s", err)
log.Printf("Please make sure to create a secret named 's3express/basics/secrets' with keys of 'userName' and 'userPassword'.")
panic(err)
}
err = json.Unmarshal([]byte(*output.SecretString), &user)
if err != nil {
log.Printf("There was a problem parsing the secret value from JSON: %s", err)
panic(err)
}
// Create the Redshift cluster
_, err = runner.redshiftActor.CreateCluster(ctx, clusterId, user.Username, user.Password, nodeType, clusterType, true)
if err != nil {
var clusterAlreadyExistsFault *redshift_types.ClusterAlreadyExistsFault
if errors.As(err, &clusterAlreadyExistsFault) {
log.Println("Cluster already exists. Continuing.")
} else {
log.Println("Error creating cluster.")
panic(err)
}
}
// Wait for the cluster to become available
waiter := redshift.NewClusterAvailableWaiter(runner.redshiftActor.RedshiftClient)
err = waiter.Wait(ctx, &redshift.DescribeClustersInput{
ClusterIdentifier: aws.String(clusterId),
}, 5*time.Minute)
if err != nil {
log.Println("An error occurred waiting for the cluster.")
panic(err)
}
// Get some info about the cluster
describeOutput, err := runner.redshiftActor.DescribeClusters(ctx, clusterId)
if err != nil {
log.Println("Something went wrong trying to get information about the cluster.")
panic(err)
}
log.Println("Here's some information about the cluster.")
log.Printf("The cluster's status is %s", *describeOutput.Clusters[0].ClusterStatus)
log.Printf("The cluster was created at %s", *describeOutput.Clusters[0].ClusterCreateTime)
// List databases
log.Println("List databases in", clusterId)
runner.questioner.Ask("Press Enter to continue...")
err = runner.redshiftDataActor.ListDatabases(ctx, clusterId, databaseName, user.Username)
if err != nil {
log.Printf("Failed to list databases: %v\n", err)
panic(err)
}
// Create the "Movies" table
log.Println("Now you will create a table named " + tableName + ".")
runner.questioner.Ask("Press Enter to continue...")
err = nil
result, err := runner.redshiftDataActor.CreateTable(ctx, clusterId, databaseName, tableName, user.Username, runner.pauser, []string{"title VARCHAR(256)", "year INT"})
if err != nil {
log.Printf("Failed to create table: %v\n", err)
panic(err)
}
describeInput := redshiftdata.DescribeStatementInput{
Id: result.Id,
}
query := actions.RedshiftQuery{
Context: ctx,
Input: describeInput,
Result: result,
}
err = runner.redshiftDataActor.WaitForQueryStatus(query, runner.pauser, true)
if err != nil {
log.Printf("Failed to execute query: %v\n", err)
panic(err)
}
log.Printf("Successfully executed query\n")
// Populate the "Movies" table
runner.PopulateMoviesTable(ctx, clusterId, databaseName, tableName, user.Username, fileName)
// Query the "Movies" table by year
log.Println("Query the Movies table by year.")
year := runner.questioner.AskInt(
fmt.Sprintf("Enter a value between %v and %v:", 2012, 2014),
demotools.InIntRange{Lower: 2012, Upper: 2014})
runner.QueryMoviesByYear(ctx, clusterId, databaseName, tableName, user.Username, year)
// Modify the cluster's maintenance window
runner.redshiftActor.ModifyCluster(ctx, clusterId, maintenanceWindow)
// Delete the Redshift cluster if confirmed
runner.cleanUpResources(ctx, clusterId, databaseName, tableName, user.Username, runner.questioner)
log.Println("Thanks for watching!")
}
// cleanUpResources asks the user if they would like to delete each resource created during the scenario, from most
// impactful to least impactful. If any choice to delete is made, further deletion attempts are skipped.
func (runner *RedshiftBasicsScenario) cleanUpResources(ctx context.Context, clusterId string, databaseName string, tableName string, userName string, questioner demotools.IQuestioner) {
deleted := false
var err error = nil
if questioner.AskBool("Do you want to delete the entire cluster? This will clean up all resources. (y/n)", "y") {
deleted, err = runner.redshiftActor.DeleteCluster(ctx, clusterId)
if err != nil {
log.Printf("Error deleting cluster: %v", err)
}
}
if !deleted && questioner.AskBool("Do you want to delete the dev table? This will clean up all inserted records but keep your cluster intact. (y/n)", "y") {
deleted, err = runner.redshiftDataActor.DeleteTable(ctx, clusterId, databaseName, tableName, userName)
if err != nil {
log.Printf("Error deleting movies table: %v", err)
}
}
if !deleted && questioner.AskBool("Do you want to delete all rows in the Movies table? This will clean up all inserted records but keep your cluster and table intact. (y/n)", "y") {
deleted, err = runner.redshiftDataActor.DeleteDataRows(ctx, clusterId, databaseName, tableName, userName, runner.pauser)
if err != nil {
log.Printf("Error deleting data rows: %v", err)
}
}
if !deleted {
log.Print("Please manually delete any unwanted resources.")
}
}
// loadMoviesFromJSON takes the file and populates a slice of Movie objects.
func (runner *RedshiftBasicsScenario) loadMoviesFromJSON(fileName string, filesystem demotools.IFileSystem) ([]Movie, error) {
file, err := filesystem.OpenFile("../../resources/sample_files/" + fileName)
if err != nil {
return nil, err
}
defer filesystem.CloseFile(file)
var movies []Movie
err = json.NewDecoder(file).Decode(&movies)
if err != nil {
return nil, err
}
return movies, nil
}
// PopulateMoviesTable reads data from the file and inserts records into the "Movies" table.
func (runner *RedshiftBasicsScenario) PopulateMoviesTable(ctx context.Context, clusterId string, databaseName string, tableName string, userName string, fileName string) {
log.Println("Populate the " + tableName + " table using the " + fileName + " file.")
numRecords := runner.questioner.AskInt(
fmt.Sprintf("Enter a value between %v and %v:", 10, 100),
demotools.InIntRange{Lower: 10, Upper: 100})
movies, err := runner.loadMoviesFromJSON(fileName, runner.filesystem)
if err != nil {
log.Printf("Failed to load movies from JSON: %v\n", err)
panic(err)
}
var sqlStatements []string
for i, movie := range movies {
if i >= numRecords {
break
}
sqlStatement := fmt.Sprintf(`INSERT INTO %s (title, year) VALUES ('%s', %d);`,
tableName,
strings.Replace(movie.Title, "'", "''", -1), // Double any single quotes to escape them
movie.Year)
sqlStatements = append(sqlStatements, sqlStatement)
}
input := &redshiftdata.BatchExecuteStatementInput{
ClusterIdentifier: aws.String(clusterId),
Database: aws.String(databaseName),
DbUser: aws.String(userName),
Sqls: sqlStatements,
}
result, err := runner.redshiftDataActor.ExecuteBatchStatement(ctx, *input)
if err != nil {
log.Printf("Failed to execute batch statement: %v\n", err)
panic(err)
}
describeInput := redshiftdata.DescribeStatementInput{
Id: result.Id,
}
query := actions.RedshiftQuery{
Context: ctx,
Result: result,
Input: describeInput,
}
err = runner.redshiftDataActor.WaitForQueryStatus(query, runner.pauser, true)
if err != nil {
log.Printf("Failed to execute batch insert query: %v\n", err)
return
}
log.Printf("Successfully executed batch statement\n")
log.Printf("%d records were added to the Movies table.\n", numRecords)
}
// QueryMoviesByYear retrieves only movies from the "Movies" table which match the given year.
func (runner *RedshiftBasicsScenario) QueryMoviesByYear(ctx context.Context, clusterId string, databaseName string, tableName string, userName string, year int) {
sqlStatement := fmt.Sprintf(`SELECT title FROM %s WHERE year = %d;`, tableName, year)
input := &redshiftdata.ExecuteStatementInput{
ClusterIdentifier: aws.String(clusterId),
Database: aws.String(databaseName),
DbUser: aws.String(userName),
Sql: aws.String(sqlStatement),
}
result, err := runner.redshiftDataActor.ExecuteStatement(ctx, *input)
if err != nil {
log.Printf("Failed to query movies: %v\n", err)
panic(err)
}
log.Println("The identifier of the statement is ", *result.Id)
describeInput := redshiftdata.DescribeStatementInput{
Id: result.Id,
}
query := actions.RedshiftQuery{
Context: ctx,
Input: describeInput,
Result: result,
}
err = runner.redshiftDataActor.WaitForQueryStatus(query, runner.pauser, true)
if err != nil {
log.Printf("Failed to execute query: %v\n", err)
panic(err)
}
log.Printf("Successfully executed query\n")
getResultOutput, err := runner.redshiftDataActor.GetStatementResult(ctx, *result.Id)
if err != nil {
log.Printf("Failed to query movies: %v\n", err)
panic(err)
}
for _, row := range getResultOutput.Records {
for _, col := range row {
title, ok := col.(*redshiftdata_types.FieldMemberStringValue)
if !ok {
log.Println("Failed to parse the field")
} else {
log.Printf("The Movie title field is %s\n", title.Value)
}
}
}
}
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK pour Go *.
+ [CreateCluster](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.CreateCluster)
+ [DescribeClusters](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.DescribeClusters)
+ [DescribeStatement](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.DescribeStatement)
+ [ExecuteStatement](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.ExecuteStatement)
+ [GetStatementResult](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.GetStatementResult)
+ [ListDatabasesPaginator](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.ListDatabasesPaginator)
+ [ModifyCluster](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.ModifyCluster)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Exécutez un scénario interactif illustrant les fonctionnalités d’Amazon Redshift.
```
import com.example.redshift.User;
import com.google.gson.Gson;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.redshift.model.ClusterAlreadyExistsException;
import software.amazon.awssdk.services.redshift.model.CreateClusterResponse;
import software.amazon.awssdk.services.redshift.model.DeleteClusterResponse;
import software.amazon.awssdk.services.redshift.model.ModifyClusterResponse;
import software.amazon.awssdk.services.redshift.model.RedshiftException;
import software.amazon.awssdk.services.redshiftdata.model.ExecuteStatementResponse;
import software.amazon.awssdk.services.redshiftdata.model.RedshiftDataException;
import java.util.Scanner;
import java.util.concurrent.CompletableFuture;
import software.amazon.awssdk.services.secretsmanager.SecretsManagerClient;
import software.amazon.awssdk.services.secretsmanager.model.GetSecretValueRequest;
import software.amazon.awssdk.services.secretsmanager.model.GetSecretValueResponse;
/**
* Before running this Java V2 code example, set up your development
* environment, including your credentials.
*
* For more information, see the following documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*
*
* This example requires an AWS Secrets Manager secret that contains the
* database credentials. If you do not create a
* secret that specifies user name and password, this example will not work. For details, see:
*
* https://docs.aws.amazon.com/secretsmanager/latest/userguide/integrating_how-services-use-secrets_RS.html
*
This Java example performs these tasks:
*
* 1. Prompts the user for a unique cluster ID or use the default value.
* 2. Creates a Redshift cluster with the specified or default cluster Id value.
* 3. Waits until the Redshift cluster is available for use.
* 4. Lists all databases using a pagination API call.
* 5. Creates a table named "Movies" with fields ID, title, and year.
* 6. Inserts a specified number of records into the "Movies" table by reading the Movies JSON file.
* 7. Prompts the user for a movie release year.
* 8. Runs a SQL query to retrieve movies released in the specified year.
* 9. Modifies the Redshift cluster.
* 10. Prompts the user for confirmation to delete the Redshift cluster.
* 11. If confirmed, deletes the specified Redshift cluster.
*/
public class RedshiftScenario {
public static final String DASHES = new String(new char[80]).replace("\0", "-");
private static final Logger logger = LoggerFactory.getLogger(RedshiftScenario.class);
static RedshiftActions redshiftActions = new RedshiftActions();
public static void main(String[] args) throws Exception {
final String usage = """
Usage:
\s
Where:
jsonFilePath - The path to the Movies JSON file (you can locate that file in ../../../resources/sample_files/movies.json)
secretName - The name of the secret that belongs to Secret Manager that stores the user name and password used in this scenario.
""";
if (args.length != 2) {
logger.info(usage);
return;
}
String jsonFilePath = args[0];
String secretName = args[1];
Scanner scanner = new Scanner(System.in);
logger.info(DASHES);
logger.info("Welcome to the Amazon Redshift SDK Basics scenario.");
logger.info("""
This Java program demonstrates how to interact with Amazon Redshift by using the AWS SDK for Java (v2).\s
Amazon Redshift is a fully managed, petabyte-scale data warehouse service hosted in the cloud.
The program's primary functionalities include cluster creation, verification of cluster readiness,\s
list databases, table creation, data population within the table, and execution of SQL statements.
Furthermore, it demonstrates the process of querying data from the Movie table.\s
Upon completion of the program, all AWS resources are cleaned up.
""");
logger.info("Lets get started...");
logger.info("""
First, we will retrieve the user name and password from Secrets Manager.
Using Amazon Secrets Manager to store Redshift credentials provides several security benefits.
It allows you to securely store and manage sensitive information, such as passwords, API keys, and
database credentials, without embedding them directly in your application code.
More information can be found here:
https://docs.aws.amazon.com/secretsmanager/latest/userguide/integrating_how-services-use-secrets_RS.html
""");
Gson gson = new Gson();
User user = gson.fromJson(String.valueOf(getSecretValues(secretName)), User.class);
waitForInputToContinue(scanner);
logger.info(DASHES);
try {
runScenario(user, scanner, jsonFilePath);
} catch (RuntimeException e) {
e.printStackTrace();
} catch (Throwable e) {
throw new RuntimeException(e);
}
}
private static void runScenario(User user, Scanner scanner, String jsonFilePath) throws Throwable {
String databaseName = "dev";
System.out.println(DASHES);
logger.info("Create a Redshift Cluster");
logger.info("A Redshift cluster refers to the collection of computing resources and storage that work together to process and analyze large volumes of data.");
logger.info("Enter a cluster id value or accept the default by hitting Enter (default is redshift-cluster-movies): ");
String userClusterId = scanner.nextLine();
String clusterId = userClusterId.isEmpty() ? "redshift-cluster-movies" : userClusterId;
try {
CompletableFuture future = redshiftActions.createClusterAsync(clusterId, user.getUserName(), user.getUserPassword());
CreateClusterResponse response = future.join();
logger.info("Cluster successfully created. Cluster Identifier {} ", response.cluster().clusterIdentifier());
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof ClusterAlreadyExistsException) {
logger.info("The Cluster {} already exists. Moving on...", clusterId);
} else {
logger.info("An unexpected error occurred: " + rt.getMessage());
}
}
logger.info(DASHES);
logger.info(DASHES);
logger.info("Wait until {} is available.", clusterId);
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.waitForClusterReadyAsync(clusterId);
future.join();
logger.info("Cluster is ready!");
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftException redshiftEx) {
logger.info("Redshift error occurred: Error message: {}, Error code {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: " + rt.getMessage());
}
throw cause;
}
logger.info(DASHES);
logger.info(DASHES);
String databaseInfo = """
When you created $clusteridD, the dev database is created by default and used in this scenario.\s
To create a custom database, you need to have a CREATEDB privilege.\s
For more information, see the documentation here: https://docs.aws.amazon.com/redshift/latest/dg/r_CREATE_DATABASE.html.
""".replace("$clusteridD", clusterId);
logger.info(databaseInfo);
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("List databases in {} ",clusterId);
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.listAllDatabasesAsync(clusterId, user.getUserName(), "dev");
future.join();
logger.info("Databases listed successfully.");
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.error("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.error("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
logger.info(DASHES);
logger.info(DASHES);
logger.info("Now you will create a table named Movies.");
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.createTableAsync(clusterId, databaseName, user.getUserName());
future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
logger.info(DASHES);
logger.info(DASHES);
logger.info("Populate the Movies table using the Movies.json file.");
logger.info("Specify the number of records you would like to add to the Movies Table.");
logger.info("Please enter a value between 50 and 200.");
int numRecords;
do {
logger.info("Enter a value: ");
while (!scanner.hasNextInt()) {
logger.info("Invalid input. Please enter a value between 50 and 200.");
logger.info("Enter a year: ");
scanner.next();
}
numRecords = scanner.nextInt();
} while (numRecords < 50 || numRecords > 200);
try {
redshiftActions.popTableAsync(clusterId, databaseName, user.getUserName(), jsonFilePath, numRecords).join(); // Wait for the operation to complete
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("Query the Movies table by year. Enter a value between 2012-2014.");
int movieYear;
do {
logger.info("Enter a year: ");
while (!scanner.hasNextInt()) {
logger.info("Invalid input. Please enter a valid year between 2012 and 2014.");
logger.info("Enter a year: ");
scanner.next();
}
movieYear = scanner.nextInt();
scanner.nextLine();
} while (movieYear < 2012 || movieYear > 2014);
String id;
try {
CompletableFuture future = redshiftActions.queryMoviesByYearAsync(databaseName, user.getUserName(), movieYear, clusterId);
id = future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
logger.info("The identifier of the statement is " + id);
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.checkStatementAsync(id);
future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.getResultsAsync(id);
future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("Now you will modify the Redshift cluster.");
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.modifyClusterAsync(clusterId);;
future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("Would you like to delete the Amazon Redshift cluster? (y/n)");
String delAns = scanner.nextLine().trim();
if (delAns.equalsIgnoreCase("y")) {
logger.info("You selected to delete {} ", clusterId);
waitForInputToContinue(scanner);
try {
CompletableFuture future = redshiftActions.deleteRedshiftClusterAsync(clusterId);;
future.join();
} catch (RuntimeException rt) {
Throwable cause = rt.getCause();
if (cause instanceof RedshiftDataException redshiftEx) {
logger.info("Redshift Data error occurred: {} Error code: {}", redshiftEx.getMessage(), redshiftEx.awsErrorDetails().errorCode());
} else {
logger.info("An unexpected error occurred: {}", rt.getMessage());
}
throw cause;
}
} else {
logger.info("The {} was not deleted", clusterId);
}
logger.info(DASHES);
logger.info(DASHES);
logger.info("This concludes the Amazon Redshift SDK Basics scenario.");
logger.info(DASHES);
}
private static SecretsManagerClient getSecretClient() {
Region region = Region.US_EAST_1;
return SecretsManagerClient.builder()
.region(region)
.build();
}
private static void waitForInputToContinue(Scanner scanner) {
while (true) {
System.out.println("");
System.out.println("Enter 'c' followed by to continue:");
String input = scanner.nextLine();
if (input.trim().equalsIgnoreCase("c")) {
System.out.println("Continuing with the program...");
System.out.println("");
break;
} else {
// Handle invalid input.
System.out.println("Invalid input. Please try again.");
}
}
}
// Get the Amazon Redshift credentials from AWS Secrets Manager.
private static String getSecretValues(String secretName) {
SecretsManagerClient secretClient = getSecretClient();
GetSecretValueRequest valueRequest = GetSecretValueRequest.builder()
.secretId(secretName)
.build();
GetSecretValueResponse valueResponse = secretClient.getSecretValue(valueRequest);
return valueResponse.secretString();
}
}
```
Une classe d’encapsuleur pour les méthodes du kit SDK Amazon Redshift.
```
public class RedshiftActions {
private static final Logger logger = LoggerFactory.getLogger(RedshiftActions.class);
private static RedshiftDataAsyncClient redshiftDataAsyncClient;
private static RedshiftAsyncClient redshiftAsyncClient;
private static RedshiftAsyncClient getAsyncClient() {
if (redshiftAsyncClient == null) {
SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder()
.maxConcurrency(100)
.connectionTimeout(Duration.ofSeconds(60))
.readTimeout(Duration.ofSeconds(60))
.writeTimeout(Duration.ofSeconds(60))
.build();
ClientOverrideConfiguration overrideConfig = ClientOverrideConfiguration.builder()
.apiCallTimeout(Duration.ofMinutes(2))
.apiCallAttemptTimeout(Duration.ofSeconds(90))
.retryStrategy(RetryMode.STANDARD)
.build();
redshiftAsyncClient = RedshiftAsyncClient.builder()
.httpClient(httpClient)
.overrideConfiguration(overrideConfig)
.build();
}
return redshiftAsyncClient;
}
private static RedshiftDataAsyncClient getAsyncDataClient() {
if (redshiftDataAsyncClient == null) {
SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder()
.maxConcurrency(100)
.connectionTimeout(Duration.ofSeconds(60))
.readTimeout(Duration.ofSeconds(60))
.writeTimeout(Duration.ofSeconds(60))
.build();
ClientOverrideConfiguration overrideConfig = ClientOverrideConfiguration.builder()
.apiCallTimeout(Duration.ofMinutes(2))
.apiCallAttemptTimeout(Duration.ofSeconds(90))
.retryStrategy(RetryMode.STANDARD)
.build();
redshiftDataAsyncClient = RedshiftDataAsyncClient.builder()
.httpClient(httpClient)
.overrideConfiguration(overrideConfig)
.build();
}
return redshiftDataAsyncClient;
}
/**
* Creates a new Amazon Redshift cluster asynchronously.
* @param clusterId the unique identifier for the cluster
* @param username the username for the administrative user
* @param userPassword the password for the administrative user
* @return a CompletableFuture that represents the asynchronous operation of creating the cluster
* @throws RuntimeException if the cluster creation fails
*/
public CompletableFuture createClusterAsync(String clusterId, String username, String userPassword) {
CreateClusterRequest clusterRequest = CreateClusterRequest.builder()
.clusterIdentifier(clusterId)
.masterUsername(username)
.masterUserPassword(userPassword)
.nodeType("ra3.4xlarge")
.publiclyAccessible(true)
.numberOfNodes(2)
.build();
return getAsyncClient().createCluster(clusterRequest)
.whenComplete((response, exception) -> {
if (response != null) {
logger.info("Created cluster ");
} else {
throw new RuntimeException("Failed to create cluster: " + exception.getMessage(), exception);
}
});
}
/**
* Waits asynchronously for the specified cluster to become available.
* @param clusterId the identifier of the cluster to wait for
* @return a {@link CompletableFuture} that completes when the cluster is ready
*/
public CompletableFuture waitForClusterReadyAsync(String clusterId) {
DescribeClustersRequest clustersRequest = DescribeClustersRequest.builder()
.clusterIdentifier(clusterId)
.build();
logger.info("Waiting for cluster to become available. This may take a few minutes.");
long startTime = System.currentTimeMillis();
// Recursive method to poll the cluster status.
return checkClusterStatusAsync(clustersRequest, startTime);
}
private CompletableFuture checkClusterStatusAsync(DescribeClustersRequest clustersRequest, long startTime) {
return getAsyncClient().describeClusters(clustersRequest)
.thenCompose(clusterResponse -> {
List clusterList = clusterResponse.clusters();
boolean clusterReady = false;
for (Cluster cluster : clusterList) {
if ("available".equals(cluster.clusterStatus())) {
clusterReady = true;
break;
}
}
if (clusterReady) {
logger.info(String.format("Cluster is available!"));
return CompletableFuture.completedFuture(null);
} else {
long elapsedTimeMillis = System.currentTimeMillis() - startTime;
long elapsedSeconds = elapsedTimeMillis / 1000;
long minutes = elapsedSeconds / 60;
long seconds = elapsedSeconds % 60;
System.out.printf("\rElapsed Time: %02d:%02d - Waiting for cluster...", minutes, seconds);
System.out.flush();
// Wait 1 second before the next status check
return CompletableFuture.runAsync(() -> {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException("Error during sleep: " + e.getMessage(), e);
}
}).thenCompose(ignored -> checkClusterStatusAsync(clustersRequest, startTime));
}
}).exceptionally(exception -> {
throw new RuntimeException("Failed to get cluster status: " + exception.getMessage(), exception);
});
}
/**
* Lists all databases asynchronously for the specified cluster, database user, and database.
* @param clusterId the identifier of the cluster to list databases for
* @param dbUser the database user to use for the list databases request
* @param database the database to list databases for
* @return a {@link CompletableFuture} that completes when the database listing is complete, or throws a {@link RuntimeException} if there was an error
*/
public CompletableFuture listAllDatabasesAsync(String clusterId, String dbUser, String database) {
ListDatabasesRequest databasesRequest = ListDatabasesRequest.builder()
.clusterIdentifier(clusterId)
.dbUser(dbUser)
.database(database)
.build();
// Asynchronous paginator for listing databases.
ListDatabasesPublisher databasesPaginator = getAsyncDataClient().listDatabasesPaginator(databasesRequest);
CompletableFuture future = databasesPaginator.subscribe(response -> {
response.databases().forEach(db -> {
logger.info("The database name is {} ", db);
});
});
// Return the future for asynchronous handling.
return future.exceptionally(exception -> {
throw new RuntimeException("Failed to list databases: " + exception.getMessage(), exception);
});
}
/**
* Creates an asynchronous task to execute a SQL statement for creating a new table.
*
* @param clusterId the identifier of the Amazon Redshift cluster
* @param databaseName the name of the database to create the table in
* @param userName the username to use for the database connection
* @return a {@link CompletableFuture} that completes with the result of the SQL statement execution
* @throws RuntimeException if there is an error creating the table
*/
public CompletableFuture createTableAsync(String clusterId, String databaseName, String userName) {
ExecuteStatementRequest createTableRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.dbUser(userName)
.database(databaseName)
.sql("CREATE TABLE Movies (" +
"id INT PRIMARY KEY, " +
"title VARCHAR(100), " +
"year INT)")
.build();
return getAsyncDataClient().executeStatement(createTableRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new RuntimeException("Error creating table: " + exception.getMessage(), exception);
} else {
logger.info("Table created: Movies");
}
});
}
/**
* Asynchronously pops a table from a JSON file.
*
* @param clusterId the ID of the cluster
* @param databaseName the name of the database
* @param userName the username
* @param fileName the name of the JSON file
* @param number the number of records to process
* @return a CompletableFuture that completes with the number of records added to the Movies table
*/
public CompletableFuture popTableAsync(String clusterId, String databaseName, String userName, String fileName, int number) {
return CompletableFuture.supplyAsync(() -> {
try {
JsonParser parser = new JsonFactory().createParser(new File(fileName));
JsonNode rootNode = new ObjectMapper().readTree(parser);
Iterator iter = rootNode.iterator();
return iter;
} catch (IOException e) {
throw new RuntimeException("Failed to read or parse JSON file: " + e.getMessage(), e);
}
}).thenCompose(iter -> processNodesAsync(clusterId, databaseName, userName, iter, number))
.whenComplete((result, exception) -> {
if (exception != null) {
logger.info("Error {} ", exception.getMessage());
} else {
logger.info("{} records were added to the Movies table." , result);
}
});
}
private CompletableFuture processNodesAsync(String clusterId, String databaseName, String userName, Iterator iter, int number) {
return CompletableFuture.supplyAsync(() -> {
int t = 0;
try {
while (iter.hasNext()) {
if (t == number)
break;
JsonNode currentNode = iter.next();
int year = currentNode.get("year").asInt();
String title = currentNode.get("title").asText();
// Use SqlParameter to avoid SQL injection.
List parameterList = new ArrayList<>();
String sqlStatement = "INSERT INTO Movies VALUES( :id , :title, :year);";
SqlParameter idParam = SqlParameter.builder()
.name("id")
.value(String.valueOf(t))
.build();
SqlParameter titleParam = SqlParameter.builder()
.name("title")
.value(title)
.build();
SqlParameter yearParam = SqlParameter.builder()
.name("year")
.value(String.valueOf(year))
.build();
parameterList.add(idParam);
parameterList.add(titleParam);
parameterList.add(yearParam);
ExecuteStatementRequest insertStatementRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.sql(sqlStatement)
.database(databaseName)
.dbUser(userName)
.parameters(parameterList)
.build();
getAsyncDataClient().executeStatement(insertStatementRequest);
logger.info("Inserted: " + title + " (" + year + ")");
t++;
}
} catch (RedshiftDataException e) {
throw new RuntimeException("Error inserting data: " + e.getMessage(), e);
}
return t;
});
}
/**
* Checks the status of an SQL statement asynchronously and handles the completion of the statement.
*
* @param sqlId the ID of the SQL statement to check
* @return a {@link CompletableFuture} that completes when the SQL statement's status is either "FINISHED" or "FAILED"
*/
public CompletableFuture checkStatementAsync(String sqlId) {
DescribeStatementRequest statementRequest = DescribeStatementRequest.builder()
.id(sqlId)
.build();
return getAsyncDataClient().describeStatement(statementRequest)
.thenCompose(response -> {
String status = response.statusAsString();
logger.info("... Status: {} ", status);
if ("FAILED".equals(status)) {
throw new RuntimeException("The Query Failed. Ending program");
} else if ("FINISHED".equals(status)) {
return CompletableFuture.completedFuture(null);
} else {
// Sleep for 1 second and recheck status
return CompletableFuture.runAsync(() -> {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException("Error during sleep: " + e.getMessage(), e);
}
}).thenCompose(ignore -> checkStatementAsync(sqlId)); // Recursively call until status is FINISHED or FAILED
}
}).whenComplete((result, exception) -> {
if (exception != null) {
// Handle exceptions
logger.info("Error: {} ", exception.getMessage());
} else {
logger.info("The statement is finished!");
}
});
}
/**
* Asynchronously retrieves the results of a statement execution.
*
* @param statementId the ID of the statement for which to retrieve the results
* @return a {@link CompletableFuture} that completes when the statement result has been processed
*/
public CompletableFuture getResultsAsync(String statementId) {
GetStatementResultRequest resultRequest = GetStatementResultRequest.builder()
.id(statementId)
.build();
return getAsyncDataClient().getStatementResult(resultRequest)
.handle((response, exception) -> {
if (exception != null) {
logger.info("Error getting statement result {} ", exception.getMessage());
throw new RuntimeException("Error getting statement result: " + exception.getMessage(), exception);
}
// Extract and print the field values using streams if the response is valid.
response.records().stream()
.flatMap(List::stream)
.map(Field::stringValue)
.filter(value -> value != null)
.forEach(value -> System.out.println("The Movie title field is " + value));
return response;
}).thenAccept(response -> {
// Optionally add more logic here if needed after handling the response
});
}
/**
* Asynchronously queries movies by a given year from a Redshift database.
*
* @param database the name of the database to query
* @param dbUser the user to connect to the database with
* @param year the year to filter the movies by
* @param clusterId the identifier of the Redshift cluster to connect to
* @return a {@link CompletableFuture} containing the response ID of the executed SQL statement
*/
public CompletableFuture queryMoviesByYearAsync(String database,
String dbUser,
int year,
String clusterId) {
String sqlStatement = "SELECT * FROM Movies WHERE year = :year";
SqlParameter yearParam = SqlParameter.builder()
.name("year")
.value(String.valueOf(year))
.build();
ExecuteStatementRequest statementRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.database(database)
.dbUser(dbUser)
.parameters(yearParam)
.sql(sqlStatement)
.build();
return CompletableFuture.supplyAsync(() -> {
try {
ExecuteStatementResponse response = getAsyncDataClient().executeStatement(statementRequest).join(); // Use join() to wait for the result
return response.id();
} catch (RedshiftDataException e) {
throw new RuntimeException("Error executing statement: " + e.getMessage(), e);
}
}).exceptionally(exception -> {
logger.info("Error: {}", exception.getMessage());
return "";
});
}
/**
* Modifies an Amazon Redshift cluster asynchronously.
*
* @param clusterId the identifier of the cluster to be modified
* @return a {@link CompletableFuture} that completes when the cluster modification is complete
*/
public CompletableFuture modifyClusterAsync(String clusterId) {
ModifyClusterRequest modifyClusterRequest = ModifyClusterRequest.builder()
.clusterIdentifier(clusterId)
.preferredMaintenanceWindow("wed:07:30-wed:08:00")
.build();
return getAsyncClient().modifyCluster(modifyClusterRequest)
.whenComplete((clusterResponse, exception) -> {
if (exception != null) {
if (exception.getCause() instanceof RedshiftException) {
logger.info("Error: {} ", exception.getMessage());
} else {
logger.info("Unexpected error: {} ", exception.getMessage());
}
} else {
logger.info("The modified cluster was successfully modified and has "
+ clusterResponse.cluster().preferredMaintenanceWindow() + " as the maintenance window");
}
});
}
/**
* Deletes a Redshift cluster asynchronously.
*
* @param clusterId the identifier of the Redshift cluster to be deleted
* @return a {@link CompletableFuture} that represents the asynchronous operation of deleting the Redshift cluster
*/
public CompletableFuture deleteRedshiftClusterAsync(String clusterId) {
DeleteClusterRequest deleteClusterRequest = DeleteClusterRequest.builder()
.clusterIdentifier(clusterId)
.skipFinalClusterSnapshot(true)
.build();
return getAsyncClient().deleteCluster(deleteClusterRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
// Handle exceptions
if (exception.getCause() instanceof RedshiftException) {
logger.info("Error: {}", exception.getMessage());
} else {
logger.info("Unexpected error: {}", exception.getMessage());
}
} else {
// Handle successful response
logger.info("The status is {}", response.cluster().clusterStatus());
}
});
}
}
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK for Java 2.x *.
+ [CreateCluster](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/CreateCluster)
+ [DescribeClusters](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DescribeClusters)
+ [DescribeStatement](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DescribeStatement)
+ [ExecuteStatement](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ExecuteStatement)
+ [GetStatementResult](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/GetStatementResult)
+ [ListDatabasesPaginator](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ListDatabasesPaginator)
+ [ModifyCluster](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ModifyCluster)
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftScenario:
"""Runs an interactive scenario that shows how to get started with Redshift."""
def __init__(self, redshift_wrapper, redshift_data_wrapper):
self.redshift_wrapper = redshift_wrapper
self.redshift_data_wrapper = redshift_data_wrapper
def redhift_scenario(self, json_file_path):
database_name = "dev"
print(DASHES)
print("Welcome to the Amazon Redshift SDK Getting Started example.")
print(
"""
This Python program demonstrates how to interact with Amazon Redshift
using the AWS SDK for Python (Boto3).
Amazon Redshift is a fully managed, petabyte-scale data warehouse
service hosted in the cloud.
The program's primary functionalities include cluster creation,
verification of cluster readiness, listing databases, table creation,
populating data within the table, and executing SQL statements.
It also demonstrates querying data from the Movies table.
Upon completion, all AWS resources are cleaned up.
"""
)
if not os.path.isfile(json_file_path):
logging.error(f"The file {json_file_path} does not exist.")
return
print("Let's get started...")
user_name = q.ask("Please enter your user name (default is awsuser):")
user_name = user_name if user_name else "awsuser"
print(DASHES)
user_password = q.ask(
"Please enter your user password (default is AwsUser1000):"
)
user_password = user_password if user_password else "AwsUser1000"
print(DASHES)
print(
"""A Redshift cluster refers to the collection of computing resources and storage that work
together to process and analyze large volumes of data."""
)
cluster_id = q.ask(
"Enter a cluster identifier value (default is redshift-cluster-movies): "
)
cluster_id = cluster_id if cluster_id else "redshift-cluster-movies"
self.redshift_wrapper.create_cluster(
cluster_id, "ra3.4xlarge", user_name, user_password, True, 2
)
print(DASHES)
print(f"Wait until {cluster_id} is available. This may take a few minutes...")
q.ask("Press Enter to continue...")
self.wait_cluster_available(cluster_id)
print(DASHES)
print(
f"""
When you created {cluster_id}, the dev database is created by default and used in this scenario.
To create a custom database, you need to have a CREATEDB privilege.
For more information, see the documentation here:
https://docs.aws.amazon.com/redshift/latest/dg/r_CREATE_DATABASE.html.
"""
)
q.ask("Press Enter to continue...")
print(DASHES)
print(DASHES)
print(f"List databases in {cluster_id}")
q.ask("Press Enter to continue...")
databases = self.redshift_data_wrapper.list_databases(
cluster_id, database_name, user_name
)
print(f"The cluster contains {len(databases)} database(s).")
for database in databases:
print(f" Database: {database}")
print(DASHES)
print(DASHES)
print("Now you will create a table named Movies.")
q.ask("Press Enter to continue...")
self.create_table(cluster_id, database_name, user_name)
print(DASHES)
print("Populate the Movies table using the Movies.json file.")
print(
"Specify the number of records you would like to add to the Movies Table."
)
print("Please enter a value between 50 and 200.")
while True:
try:
num_records = int(q.ask("Enter a value: ", q.is_int))
if 50 <= num_records <= 200:
break
else:
print("Invalid input. Please enter a value between 50 and 200.")
except ValueError:
print("Invalid input. Please enter a value between 50 and 200.")
self.populate_table(
cluster_id, database_name, user_name, json_file_path, num_records
)
print(DASHES)
print("Query the Movies table by year. Enter a value between 2012-2014.")
while True:
movie_year = int(q.ask("Enter a year: ", q.is_int))
if 2012 <= movie_year <= 2014:
break
else:
print("Invalid input. Please enter a valid year between 2012 and 2014.")
# Function to query database
sql_id = self.query_movies_by_year(
database_name, user_name, movie_year, cluster_id
)
print(f"The identifier of the statement is {sql_id}")
print("Checking statement status...")
self.wait_statement_finished(sql_id)
result = self.redshift_data_wrapper.get_statement_result(sql_id)
self.display_movies(result)
print(DASHES)
print(DASHES)
print("Now you will modify the Redshift cluster.")
q.ask("Press Enter to continue...")
preferred_maintenance_window = "wed:07:30-wed:08:00"
self.redshift_wrapper.modify_cluster(cluster_id, preferred_maintenance_window)
print(DASHES)
print(DASHES)
delete = q.ask("Do you want to delete the cluster? (y/n) ", q.is_yesno)
if delete:
print(f"You selected to delete {cluster_id}")
q.ask("Press Enter to continue...")
self.redshift_wrapper.delete_cluster(cluster_id)
else:
print(f"Cluster {cluster_id}cluster_id was not deleted")
print(DASHES)
print("This concludes the Amazon Redshift SDK Getting Started scenario.")
print(DASHES)
def create_table(self, cluster_id, database, username):
self.redshift_data_wrapper.execute_statement(
cluster_identifier=cluster_id,
database_name=database,
user_name=username,
sql="CREATE TABLE Movies (statement_id INT PRIMARY KEY, title VARCHAR(100), year INT)",
)
print("Table created: Movies")
def populate_table(self, cluster_id, database, username, file_name, number):
with open(file_name) as f:
data = json.load(f)
i = 0
for record in data:
if i == number:
break
statement_id = i
title = record["title"]
year = record["year"]
i = i + 1
parameters = [
{"name": "statement_id", "value": str(statement_id)},
{"name": "title", "value": title},
{"name": "year", "value": str(year)},
]
self.redshift_data_wrapper.execute_statement(
cluster_identifier=cluster_id,
database_name=database,
user_name=username,
sql="INSERT INTO Movies VALUES(:statement_id, :title, :year)",
parameter_list=parameters,
)
print(f"{i} records inserted into Movies table")
def wait_cluster_available(self, cluster_id):
"""
Waits for a cluster to be available.
:param cluster_id: The cluster identifier.
Note: The cluster_available waiter can also be used.
It is not used in this case to allow an elapsed time message.
"""
cluster_ready = False
start_time = time.time()
while not cluster_ready:
time.sleep(30)
cluster = self.redshift_wrapper.describe_clusters(cluster_id)
status = cluster[0]["ClusterStatus"]
if status == "available":
cluster_ready = True
elif status != "creating":
raise Exception(
f"Cluster {cluster_id} creation failed with status {status}."
)
elapsed_seconds = int(round(time.time() - start_time))
minutes = int(elapsed_seconds // 60)
seconds = int(elapsed_seconds % 60)
print(f"Elapsed Time: {minutes}:{seconds:02d} - status {status}...")
if minutes > 30:
raise Exception(
f"Cluster {cluster_id} is not available after 30 minutes."
)
def query_movies_by_year(self, database, username, year, cluster_id):
sql = "SELECT * FROM Movies WHERE year = :year"
params = [{"name": "year", "value": str(year)}]
response = self.redshift_data_wrapper.execute_statement(
cluster_identifier=cluster_id,
database_name=database,
user_name=username,
sql=sql,
parameter_list=params,
)
return response["Id"]
@staticmethod
def display_movies(response):
metadata = response["ColumnMetadata"]
records = response["Records"]
title_column_index = None
for i in range(len(metadata)):
if metadata[i]["name"] == "title":
title_column_index = i
break
if title_column_index is None:
print("No title column found.")
return
print(f"Found {len(records)} movie(s).")
for record in records:
print(f" {record[title_column_index]['stringValue']}")
def wait_statement_finished(self, sql_id):
while True:
time.sleep(1)
response = self.redshift_data_wrapper.describe_statement(sql_id)
status = response["Status"]
print(f"Statement status is {status}.")
if status == "FAILED":
print(f"The query failed because {response['Error']}. Ending program")
raise Exception("The Query Failed. Ending program")
elif status == "FINISHED":
break
```
Fonction principale montrant la mise en œuvre du scénario.
```
def main():
redshift_client = boto3.client("redshift")
redshift_data_client = boto3.client("redshift-data")
redshift_wrapper = RedshiftWrapper(redshift_client)
redshift_data_wrapper = RedshiftDataWrapper(redshift_data_client)
redshift_scenario = RedshiftScenario(redshift_wrapper, redshift_data_wrapper)
redshift_scenario.redhift_scenario(
f"{os.path.dirname(__file__)}/../../../resources/sample_files/movies.json"
)
```
Les fonctions d’encapsuleur utilisées dans le scénario.
```
def create_cluster(
self,
cluster_identifier,
node_type,
master_username,
master_user_password,
publicly_accessible,
number_of_nodes,
):
"""
Creates a cluster.
:param cluster_identifier: The name of the cluster.
:param node_type: The type of node in the cluster.
:param master_username: The master username.
:param master_user_password: The master user password.
:param publicly_accessible: Whether the cluster is publicly accessible.
:param number_of_nodes: The number of nodes in the cluster.
:return: The cluster.
"""
try:
cluster = self.client.create_cluster(
ClusterIdentifier=cluster_identifier,
NodeType=node_type,
MasterUsername=master_username,
MasterUserPassword=master_user_password,
PubliclyAccessible=publicly_accessible,
NumberOfNodes=number_of_nodes,
)
return cluster
except ClientError as err:
logging.error(
"Couldn't create a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def describe_clusters(self, cluster_identifier):
"""
Describes a cluster.
:param cluster_identifier: The cluster identifier.
:return: A list of clusters.
"""
try:
kwargs = {}
if cluster_identifier:
kwargs["ClusterIdentifier"] = cluster_identifier
paginator = self.client.get_paginator("describe_clusters")
clusters = []
for page in paginator.paginate(**kwargs):
clusters.extend(page["Clusters"])
return clusters
except ClientError as err:
logging.error(
"Couldn't describe a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def execute_statement(
self, cluster_identifier, database_name, user_name, sql, parameter_list=None
):
"""
Executes a SQL statement.
:param cluster_identifier: The cluster identifier.
:param database_name: The database name.
:param user_name: The user's name.
:param sql: The SQL statement.
:param parameter_list: The optional SQL statement parameters.
:return: The SQL statement result.
"""
try:
kwargs = {
"ClusterIdentifier": cluster_identifier,
"Database": database_name,
"DbUser": user_name,
"Sql": sql,
}
if parameter_list:
kwargs["Parameters"] = parameter_list
response = self.client.execute_statement(**kwargs)
return response
except ClientError as err:
logging.error(
"Couldn't execute statement. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def describe_statement(self, statement_id):
"""
Describes a SQL statement.
:param statement_id: The SQL statement identifier.
:return: The SQL statement result.
"""
try:
response = self.client.describe_statement(Id=statement_id)
return response
except ClientError as err:
logging.error(
"Couldn't describe statement. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def get_statement_result(self, statement_id):
"""
Gets the result of a SQL statement.
:param statement_id: The SQL statement identifier.
:return: The SQL statement result.
"""
try:
result = {
"Records": [],
}
paginator = self.client.get_paginator("get_statement_result")
for page in paginator.paginate(Id=statement_id):
if "ColumnMetadata" not in result:
result["ColumnMetadata"] = page["ColumnMetadata"]
result["Records"].extend(page["Records"])
return result
except ClientError as err:
logging.error(
"Couldn't get statement result. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def modify_cluster(self, cluster_identifier, preferred_maintenance_window):
"""
Modifies a cluster.
:param cluster_identifier: The cluster identifier.
:param preferred_maintenance_window: The preferred maintenance window.
"""
try:
self.client.modify_cluster(
ClusterIdentifier=cluster_identifier,
PreferredMaintenanceWindow=preferred_maintenance_window,
)
except ClientError as err:
logging.error(
"Couldn't modify a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def list_databases(self, cluster_identifier, database_name, database_user):
"""
Lists databases in a cluster.
:param cluster_identifier: The cluster identifier.
:param database_name: The database name.
:param database_user: The database user.
:return: The list of databases.
"""
try:
paginator = self.client.get_paginator("list_databases")
databases = []
for page in paginator.paginate(
ClusterIdentifier=cluster_identifier,
Database=database_name,
DbUser=database_user,
):
databases.extend(page["Databases"])
return databases
except ClientError as err:
logging.error(
"Couldn't list databases. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def delete_cluster(self, cluster_identifier):
"""
Deletes a cluster.
:param cluster_identifier: The cluster identifier.
"""
try:
self.client.delete_cluster(
ClusterIdentifier=cluster_identifier, SkipFinalClusterSnapshot=True
)
except ClientError as err:
logging.error(
"Couldn't delete a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK for Python (Boto3)*.
+ [CreateCluster](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/CreateCluster)
+ [DescribeClusters](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DescribeClusters)
+ [DescribeStatement](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DescribeStatement)
+ [ExecuteStatement](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/ExecuteStatement)
+ [GetStatementResult](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/GetStatementResult)
+ [ListDatabasesPaginator](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/ListDatabasesPaginator)
+ [ModifyCluster](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/ModifyCluster)
------
# Actions pour Amazon Redshift utilisant AWS SDKs
Les exemples de code suivants montrent comment effectuer des actions Amazon Redshift individuelles avec. AWS SDKs Chaque exemple inclut un lien vers GitHub, où vous pouvez trouver des instructions pour configurer et exécuter le code.
Ces extraits appellent l’API Amazon Redshift et sont des extraits de code de programmes plus volumineux qui doivent être exécutés en contexte. Vous pouvez voir les actions dans leur contexte dans [Scénarios d'utilisation d'Amazon Redshift AWS SDKs](redshift_code_examples_scenarios.md).
Les exemples suivants incluent uniquement les actions les plus couramment utilisées. Pour obtenir la liste complète, consultez la [référence des API Amazon Redshift](https://docs.aws.amazon.com/redshift/latest/APIReference/Welcome.html).
**Topics**
+ [`CreateCluster`](redshift_example_redshift_CreateCluster_section.md)
+ [`DeleteCluster`](redshift_example_redshift_DeleteCluster_section.md)
+ [`DescribeClusters`](redshift_example_redshift_DescribeClusters_section.md)
+ [`DescribeStatement`](redshift_example_redshift_DescribeStatement_section.md)
+ [`ExecuteStatement`](redshift_example_redshift_ExecuteStatement_section.md)
+ [`GetStatementResult`](redshift_example_redshift_GetStatementResult_section.md)
+ [`ListDatabases`](redshift_example_redshift_ListDatabases_section.md)
+ [`ModifyCluster`](redshift_example_redshift_ModifyCluster_section.md)
# Utilisation `CreateCluster` avec un AWS SDK ou une CLI
Les exemples de code suivants illustrent comment utiliser `CreateCluster`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Create a new Amazon Redshift cluster.
///
/// The identifier for the cluster.
/// The name of the database.
/// The master username.
/// The master user password.
/// The node type for the cluster.
/// The cluster that was created.
public async Task CreateClusterAsync(string clusterIdentifier, string databaseName,
string masterUsername, string masterUserPassword, string nodeType = "ra3.large")
{
try
{
var request = new CreateClusterRequest
{
ClusterIdentifier = clusterIdentifier,
DBName = databaseName,
MasterUsername = masterUsername,
MasterUserPassword = masterUserPassword,
NodeType = nodeType,
NumberOfNodes = 1,
ClusterType = "single-node"
};
var response = await _redshiftClient.CreateClusterAsync(request);
Console.WriteLine($"Created cluster {clusterIdentifier}");
return response.Cluster;
}
catch (ClusterAlreadyExistsException ex)
{
Console.WriteLine($"Cluster already exists: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't create cluster. Here's why: {ex.Message}");
throw;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [CreateCluster](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/CreateCluster)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ CLI ]
**AWS CLI**
L' ParametersThis exemple Create a Cluster with Minimal crée un cluster avec un ensemble minimal de paramètres. JSON est le format de sortie par défaut. Commande :
```
aws redshift create-cluster --node-type dw.hs1.xlarge --number-of-nodes 2 --master-username adminuser --master-user-password TopSecret1 --cluster-identifier mycluster
```
Résultat :
```
{
"Cluster": {
"NodeType": "dw.hs1.xlarge",
"ClusterVersion": "1.0",
"PubliclyAccessible": "true",
"MasterUsername": "adminuser",
"ClusterParameterGroups": [
{
"ParameterApplyStatus": "in-sync",
"ParameterGroupName": "default.redshift-1.0"
} ],
"ClusterSecurityGroups": [
{
"Status": "active",
"ClusterSecurityGroupName": "default"
} ],
"AllowVersionUpgrade": true,
"VpcSecurityGroups": \[],
"PreferredMaintenanceWindow": "sat:03:30-sat:04:00",
"AutomatedSnapshotRetentionPeriod": 1,
"ClusterStatus": "creating",
"ClusterIdentifier": "mycluster",
"DBName": "dev",
"NumberOfNodes": 2,
"PendingModifiedValues": {
"MasterUserPassword": "\****"
}
},
"ResponseMetadata": {
"RequestId": "7cf4bcfc-64dd-11e2-bea9-49e0ce183f07"
}
}
```
+ Pour plus de détails sur l'API, voir [CreateCluster](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/redshift/create-cluster.html)la section *Référence des AWS CLI commandes*.
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
import (
"context"
"errors"
"log"
"time"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/redshift"
"github.com/aws/aws-sdk-go-v2/service/redshift/types"
)
// RedshiftActions wraps Redshift service actions.
type RedshiftActions struct {
RedshiftClient *redshift.Client
}
// CreateCluster sends a request to create a cluster with the given clusterId using the provided credentials.
func (actor RedshiftActions) CreateCluster(ctx context.Context, clusterId string, userName string, userPassword string, nodeType string, clusterType string, publiclyAccessible bool) (*redshift.CreateClusterOutput, error) {
// Create a new Redshift cluster
input := &redshift.CreateClusterInput{
ClusterIdentifier: aws.String(clusterId),
MasterUserPassword: aws.String(userPassword),
MasterUsername: aws.String(userName),
NodeType: aws.String(nodeType),
ClusterType: aws.String(clusterType),
PubliclyAccessible: aws.Bool(publiclyAccessible),
}
var opErr *types.ClusterAlreadyExistsFault
output, err := actor.RedshiftClient.CreateCluster(ctx, input)
if err != nil && errors.As(err, &opErr) {
log.Println("Cluster already exists")
return nil, nil
} else if err != nil {
log.Printf("Failed to create Redshift cluster: %v\n", err)
return nil, err
}
log.Printf("Created cluster %s\n", *output.Cluster.ClusterIdentifier)
return output, nil
}
```
+ Pour plus de détails sur l'API, reportez-vous [CreateCluster](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.CreateCluster)à la section *Référence des AWS SDK pour Go API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Créez le cluster.
```
/**
* Creates a new Amazon Redshift cluster asynchronously.
* @param clusterId the unique identifier for the cluster
* @param username the username for the administrative user
* @param userPassword the password for the administrative user
* @return a CompletableFuture that represents the asynchronous operation of creating the cluster
* @throws RuntimeException if the cluster creation fails
*/
public CompletableFuture createClusterAsync(String clusterId, String username, String userPassword) {
CreateClusterRequest clusterRequest = CreateClusterRequest.builder()
.clusterIdentifier(clusterId)
.masterUsername(username)
.masterUserPassword(userPassword)
.nodeType("ra3.4xlarge")
.publiclyAccessible(true)
.numberOfNodes(2)
.build();
return getAsyncClient().createCluster(clusterRequest)
.whenComplete((response, exception) -> {
if (response != null) {
logger.info("Created cluster ");
} else {
throw new RuntimeException("Failed to create cluster: " + exception.getMessage(), exception);
}
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [CreateCluster](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/CreateCluster)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ JavaScript ]
**SDK pour JavaScript (v3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/redshift#code-examples).
Créez le client.
```
import { RedshiftClient } from "@aws-sdk/client-redshift";
// Set the AWS Region.
const REGION = "REGION";
//Set the Redshift Service Object
const redshiftClient = new RedshiftClient({ region: REGION });
export { redshiftClient };
```
Créez le cluster.
```
// Import required AWS SDK clients and commands for Node.js
import { CreateClusterCommand } from "@aws-sdk/client-redshift";
import { redshiftClient } from "./libs/redshiftClient.js";
const params = {
ClusterIdentifier: "CLUSTER_NAME", // Required
NodeType: "NODE_TYPE", //Required
MasterUsername: "MASTER_USER_NAME", // Required - must be lowercase
MasterUserPassword: "MASTER_USER_PASSWORD", // Required - must contain at least one uppercase letter, and one number
ClusterType: "CLUSTER_TYPE", // Required
IAMRoleARN: "IAM_ROLE_ARN", // Optional - the ARN of an IAM role with permissions your cluster needs to access other AWS services on your behalf, such as Amazon S3.
ClusterSubnetGroupName: "CLUSTER_SUBNET_GROUPNAME", //Optional - the name of a cluster subnet group to be associated with this cluster. Defaults to 'default' if not specified.
DBName: "DATABASE_NAME", // Optional - defaults to 'dev' if not specified
Port: "PORT_NUMBER", // Optional - defaults to '5439' if not specified
};
const run = async () => {
try {
const data = await redshiftClient.send(new CreateClusterCommand(params));
console.log(
`Cluster ${data.Cluster.ClusterIdentifier} successfully created`,
);
return data; // For unit tests.
} catch (err) {
console.log("Error", err);
}
};
run();
```
+ Pour plus de détails sur l'API, reportez-vous [CreateCluster](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/redshift/command/CreateClusterCommand)à la section *Référence des AWS SDK pour JavaScript API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/redshift#code-examples).
Créez le cluster.
```
suspend fun createCluster(
clusterId: String?,
masterUsernameVal: String?,
masterUserPasswordVal: String?,
) {
val clusterRequest =
CreateClusterRequest {
clusterIdentifier = clusterId
availabilityZone = "us-east-1a"
masterUsername = masterUsernameVal
masterUserPassword = masterUserPasswordVal
nodeType = "ra3.4xlarge"
publiclyAccessible = true
numberOfNodes = 2
}
RedshiftClient.fromEnvironment { region = "us-east-1" }.use { redshiftClient ->
val clusterResponse = redshiftClient.createCluster(clusterRequest)
println("Created cluster ${clusterResponse.cluster?.clusterIdentifier}")
}
}
```
+ Pour plus de détails sur l'API, consultez [CreateCluster](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftWrapper:
"""
Encapsulates Amazon Redshift cluster operations.
"""
def __init__(self, redshift_client):
"""
:param redshift_client: A Boto3 Redshift client.
"""
self.client = redshift_client
def create_cluster(
self,
cluster_identifier,
node_type,
master_username,
master_user_password,
publicly_accessible,
number_of_nodes,
):
"""
Creates a cluster.
:param cluster_identifier: The name of the cluster.
:param node_type: The type of node in the cluster.
:param master_username: The master username.
:param master_user_password: The master user password.
:param publicly_accessible: Whether the cluster is publicly accessible.
:param number_of_nodes: The number of nodes in the cluster.
:return: The cluster.
"""
try:
cluster = self.client.create_cluster(
ClusterIdentifier=cluster_identifier,
NodeType=node_type,
MasterUsername=master_username,
MasterUserPassword=master_user_password,
PubliclyAccessible=publicly_accessible,
NumberOfNodes=number_of_nodes,
)
return cluster
except ClientError as err:
logging.error(
"Couldn't create a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftWrapper objet.
```
client = boto3.client("redshift")
redhift_wrapper = RedshiftWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [CreateCluster](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/CreateCluster)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsh#code-examples).
Créez le cluster.
```
TRY.
" Example values: iv_cluster_identifier = 'my-redshift-cluster'
" Example values: iv_node_type = 'ra3.4xlarge'
" Example values: iv_master_username = 'awsuser'
" Example values: iv_master_password = 'AwsUser1000'
" Example values: iv_publicly_accessible = abap_true
" Example values: iv_number_of_nodes = 2
oo_result = lo_rsh->createcluster(
iv_clusteridentifier = iv_cluster_identifier
iv_nodetype = iv_node_type
iv_masterusername = iv_master_username
iv_masteruserpassword = iv_master_password
iv_publiclyaccessible = iv_publicly_accessible
iv_numberofnodes = iv_number_of_nodes
).
MESSAGE 'Redshift cluster created successfully.' TYPE 'I'.
CATCH /aws1/cx_rshclustalrdyexfault.
MESSAGE 'Cluster already exists.' TYPE 'I'.
CATCH /aws1/cx_rshclstquotaexcdfault.
MESSAGE 'Cluster quota exceeded.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [CreateCluster](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `DeleteCluster` avec un AWS SDK ou une CLI
Les exemples de code suivants illustrent comment utiliser `DeleteCluster`.
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Delete an Amazon Redshift cluster without a final snapshot.
///
/// The identifier for the cluster.
/// True if successful.
public async Task DeleteClusterWithoutSnapshotAsync(string clusterIdentifier)
{
try
{
var request = new DeleteClusterRequest
{
ClusterIdentifier = clusterIdentifier,
SkipFinalClusterSnapshot = true
};
var response = await _redshiftClient.DeleteClusterAsync(request);
Console.WriteLine($"The {clusterIdentifier} was deleted");
return true;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster not found: {ex.Message}");
return false;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't delete cluster. Here's why: {ex.Message}");
return false;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DeleteCluster](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DeleteCluster)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ CLI ]
**AWS CLI**
Supprimer un cluster sans cluster final SnapshotThis Exemple de suppression d'un cluster, forçant ainsi la suppression des données afin qu'aucun instantané final du cluster ne soit créé.Commande :
```
aws redshift delete-cluster --cluster-identifier mycluster --skip-final-cluster-snapshot
```
Supprimer un cluster, autoriser un cluster final, SnapshotThis par exemple, supprime un cluster, mais spécifie un instantané du cluster.Commande :
```
aws redshift delete-cluster --cluster-identifier mycluster --final-cluster-snapshot-identifier myfinalsnapshot
```
+ Pour plus de détails sur l'API, voir [DeleteCluster](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/redshift/delete-cluster.html)la section *Référence des AWS CLI commandes*.
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
import (
"context"
"errors"
"log"
"time"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/redshift"
"github.com/aws/aws-sdk-go-v2/service/redshift/types"
)
// RedshiftActions wraps Redshift service actions.
type RedshiftActions struct {
RedshiftClient *redshift.Client
}
// DeleteCluster deletes the given cluster.
func (actor RedshiftActions) DeleteCluster(ctx context.Context, clusterId string) (bool, error) {
input := redshift.DeleteClusterInput{
ClusterIdentifier: aws.String(clusterId),
SkipFinalClusterSnapshot: aws.Bool(true),
}
_, err := actor.RedshiftClient.DeleteCluster(ctx, &input)
var opErr *types.ClusterNotFoundFault
if err != nil && errors.As(err, &opErr) {
log.Println("Cluster was not found. Where could it be?")
return false, err
} else if err != nil {
log.Printf("Failed to delete Redshift cluster: %v\n", err)
return false, err
}
waiter := redshift.NewClusterDeletedWaiter(actor.RedshiftClient)
err = waiter.Wait(ctx, &redshift.DescribeClustersInput{
ClusterIdentifier: aws.String(clusterId),
}, 5*time.Minute)
if err != nil {
log.Printf("Wait time exceeded for deleting cluster, continuing: %v\n", err)
}
log.Printf("The cluster %s was deleted\n", clusterId)
return true, nil
}
```
+ Pour plus de détails sur l'API, reportez-vous [DeleteCluster](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.DeleteCluster)à la section *Référence des AWS SDK pour Go API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Supprimez le cluster.
```
/**
* Deletes a Redshift cluster asynchronously.
*
* @param clusterId the identifier of the Redshift cluster to be deleted
* @return a {@link CompletableFuture} that represents the asynchronous operation of deleting the Redshift cluster
*/
public CompletableFuture deleteRedshiftClusterAsync(String clusterId) {
DeleteClusterRequest deleteClusterRequest = DeleteClusterRequest.builder()
.clusterIdentifier(clusterId)
.skipFinalClusterSnapshot(true)
.build();
return getAsyncClient().deleteCluster(deleteClusterRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
// Handle exceptions
if (exception.getCause() instanceof RedshiftException) {
logger.info("Error: {}", exception.getMessage());
} else {
logger.info("Unexpected error: {}", exception.getMessage());
}
} else {
// Handle successful response
logger.info("The status is {}", response.cluster().clusterStatus());
}
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [DeleteCluster](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DeleteCluster)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ JavaScript ]
**SDK pour JavaScript (v3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/redshift#code-examples).
Créez le client.
```
import { RedshiftClient } from "@aws-sdk/client-redshift";
// Set the AWS Region.
const REGION = "REGION";
//Set the Redshift Service Object
const redshiftClient = new RedshiftClient({ region: REGION });
export { redshiftClient };
```
Créez le cluster.
```
// Import required AWS SDK clients and commands for Node.js
import { DeleteClusterCommand } from "@aws-sdk/client-redshift";
import { redshiftClient } from "./libs/redshiftClient.js";
const params = {
ClusterIdentifier: "CLUSTER_NAME",
SkipFinalClusterSnapshot: false,
FinalClusterSnapshotIdentifier: "CLUSTER_SNAPSHOT_ID",
};
const run = async () => {
try {
const data = await redshiftClient.send(new DeleteClusterCommand(params));
console.log("Success, cluster deleted. ", data);
return data; // For unit tests.
} catch (err) {
console.log("Error", err);
}
};
run();
```
+ Pour plus de détails sur l'API, reportez-vous [DeleteCluster](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/redshift/command/DeleteClusterCommand)à la section *Référence des AWS SDK pour JavaScript API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/redshift#code-examples).
Supprimez le cluster.
```
suspend fun deleteRedshiftCluster(clusterId: String?) {
val request =
DeleteClusterRequest {
clusterIdentifier = clusterId
skipFinalClusterSnapshot = true
}
RedshiftClient.fromEnvironment { region = "us-west-2" }.use { redshiftClient ->
val response = redshiftClient.deleteCluster(request)
println("The status is ${response.cluster?.clusterStatus}")
}
}
```
+ Pour plus de détails sur l'API, consultez [DeleteCluster](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftWrapper:
"""
Encapsulates Amazon Redshift cluster operations.
"""
def __init__(self, redshift_client):
"""
:param redshift_client: A Boto3 Redshift client.
"""
self.client = redshift_client
def delete_cluster(self, cluster_identifier):
"""
Deletes a cluster.
:param cluster_identifier: The cluster identifier.
"""
try:
self.client.delete_cluster(
ClusterIdentifier=cluster_identifier, SkipFinalClusterSnapshot=True
)
except ClientError as err:
logging.error(
"Couldn't delete a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftWrapper objet.
```
client = boto3.client("redshift")
redhift_wrapper = RedshiftWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [DeleteCluster](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DeleteCluster)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsh#code-examples).
Supprimez le cluster.
```
TRY.
" Example values: iv_cluster_identifier = 'my-redshift-cluster'
lo_rsh->deletecluster(
iv_clusteridentifier = iv_cluster_identifier
iv_skipfinalclustersnapshot = abap_true
).
MESSAGE 'Redshift cluster deleted successfully.' TYPE 'I'.
CATCH /aws1/cx_rshclustnotfoundfault.
MESSAGE 'Cluster not found.' TYPE 'I'.
CATCH /aws1/cx_rshinvcluststatefault.
MESSAGE 'Invalid cluster state for deletion.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [DeleteCluster](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `DescribeClusters` avec un AWS SDK ou une CLI
Les exemples de code suivants illustrent comment utiliser `DescribeClusters`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Describe Amazon Redshift clusters.
///
/// Optional cluster identifier to describe a specific cluster.
/// A list of clusters.
public async Task> DescribeClustersAsync(string? clusterIdentifier = null)
{
try
{
var clusters = new List();
var request = new DescribeClustersRequest();
if (!string.IsNullOrEmpty(clusterIdentifier))
{
request.ClusterIdentifier = clusterIdentifier;
}
var clustersPaginator = _redshiftClient.Paginators.DescribeClusters(request);
await foreach (var response in clustersPaginator.Responses)
{
if (response.Clusters != null)
clusters.AddRange(response.Clusters);
}
Console.WriteLine($"{clusters.Count} cluster(s) retrieved.");
foreach (var cluster in clusters)
{
Console.WriteLine($"\t{cluster.ClusterIdentifier} (Status: {cluster.ClusterStatus})");
}
return clusters;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster {clusterIdentifier} not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't describe clusters. Here's why: {ex.Message}");
throw;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DescribeClusters)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ CLI ]
**AWS CLI**
L' ClustersThis exemple Get a Description of All renvoie une description de tous les clusters du compte. JSON est le format de sortie par défaut. Commande :
```
aws redshift describe-clusters
```
Résultat :
```
{
"Clusters": [
{
"NodeType": "dw.hs1.xlarge",
"Endpoint": {
"Port": 5439,
"Address": "mycluster.coqoarplqhsn.us-east-1.redshift.amazonaws.com"
},
"ClusterVersion": "1.0",
"PubliclyAccessible": "true",
"MasterUsername": "adminuser",
"ClusterParameterGroups": [
{
"ParameterApplyStatus": "in-sync",
"ParameterGroupName": "default.redshift-1.0"
} ],
"ClusterSecurityGroups": [
{
"Status": "active",
"ClusterSecurityGroupName": "default"
} ],
"AllowVersionUpgrade": true,
"VpcSecurityGroups": \[],
"AvailabilityZone": "us-east-1a",
"ClusterCreateTime": "2013-01-22T21:59:29.559Z",
"PreferredMaintenanceWindow": "sat:03:30-sat:04:00",
"AutomatedSnapshotRetentionPeriod": 1,
"ClusterStatus": "available",
"ClusterIdentifier": "mycluster",
"DBName": "dev",
"NumberOfNodes": 2,
"PendingModifiedValues": {}
} ],
"ResponseMetadata": {
"RequestId": "65b71cac-64df-11e2-8f5b-e90bd6c77476"
}
}
```
Vous pouvez également obtenir les mêmes informations au format texte à l’aide de l’option `--output text`. Commande :
option `--output text`. Commande :
option. Commande :
```
aws redshift describe-clusters --output text
```
Résultat :
```
dw.hs1.xlarge 1.0 true adminuser True us-east-1a 2013-01-22T21:59:29.559Z sat:03:30-sat:04:00 1 available mycluster dev 2
ENDPOINT 5439 mycluster.coqoarplqhsn.us-east-1.redshift.amazonaws.com
in-sync default.redshift-1.0
active default
PENDINGMODIFIEDVALUES
RESPONSEMETADATA 934281a8-64df-11e2-b07c-f7fbdd006c67
```
+ Pour plus de détails sur l'API, voir [DescribeClusters](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/redshift/describe-clusters.html)la section *Référence des AWS CLI commandes*.
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
import (
"context"
"errors"
"log"
"time"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/redshift"
"github.com/aws/aws-sdk-go-v2/service/redshift/types"
)
// RedshiftActions wraps Redshift service actions.
type RedshiftActions struct {
RedshiftClient *redshift.Client
}
// DescribeClusters returns information about the given cluster.
func (actor RedshiftActions) DescribeClusters(ctx context.Context, clusterId string) (*redshift.DescribeClustersOutput, error) {
input, err := actor.RedshiftClient.DescribeClusters(ctx, &redshift.DescribeClustersInput{
ClusterIdentifier: aws.String(clusterId),
})
var opErr *types.AccessToClusterDeniedFault
if errors.As(err, &opErr) {
println("Access to cluster denied.")
panic(err)
} else if err != nil {
println("Failed to describe Redshift clusters.")
return nil, err
}
return input, nil
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.DescribeClusters)à la section *Référence des AWS SDK pour Go API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Décrivez le cluster.
```
/**
* Waits asynchronously for the specified cluster to become available.
* @param clusterId the identifier of the cluster to wait for
* @return a {@link CompletableFuture} that completes when the cluster is ready
*/
public CompletableFuture waitForClusterReadyAsync(String clusterId) {
DescribeClustersRequest clustersRequest = DescribeClustersRequest.builder()
.clusterIdentifier(clusterId)
.build();
logger.info("Waiting for cluster to become available. This may take a few minutes.");
long startTime = System.currentTimeMillis();
// Recursive method to poll the cluster status.
return checkClusterStatusAsync(clustersRequest, startTime);
}
private CompletableFuture checkClusterStatusAsync(DescribeClustersRequest clustersRequest, long startTime) {
return getAsyncClient().describeClusters(clustersRequest)
.thenCompose(clusterResponse -> {
List clusterList = clusterResponse.clusters();
boolean clusterReady = false;
for (Cluster cluster : clusterList) {
if ("available".equals(cluster.clusterStatus())) {
clusterReady = true;
break;
}
}
if (clusterReady) {
logger.info(String.format("Cluster is available!"));
return CompletableFuture.completedFuture(null);
} else {
long elapsedTimeMillis = System.currentTimeMillis() - startTime;
long elapsedSeconds = elapsedTimeMillis / 1000;
long minutes = elapsedSeconds / 60;
long seconds = elapsedSeconds % 60;
System.out.printf("\rElapsed Time: %02d:%02d - Waiting for cluster...", minutes, seconds);
System.out.flush();
// Wait 1 second before the next status check
return CompletableFuture.runAsync(() -> {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException("Error during sleep: " + e.getMessage(), e);
}
}).thenCompose(ignored -> checkClusterStatusAsync(clustersRequest, startTime));
}
}).exceptionally(exception -> {
throw new RuntimeException("Failed to get cluster status: " + exception.getMessage(), exception);
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DescribeClusters)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ JavaScript ]
**SDK pour JavaScript (v3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/redshift#code-examples).
Créez le client.
```
import { RedshiftClient } from "@aws-sdk/client-redshift";
// Set the AWS Region.
const REGION = "REGION";
//Set the Redshift Service Object
const redshiftClient = new RedshiftClient({ region: REGION });
export { redshiftClient };
```
Décrivez vos clusters.
```
// Import required AWS SDK clients and commands for Node.js
import { DescribeClustersCommand } from "@aws-sdk/client-redshift";
import { redshiftClient } from "./libs/redshiftClient.js";
const params = {
ClusterIdentifier: "CLUSTER_NAME",
};
const run = async () => {
try {
const data = await redshiftClient.send(new DescribeClustersCommand(params));
console.log("Success", data);
return data; // For unit tests.
} catch (err) {
console.log("Error", err);
}
};
run();
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/redshift/command/DescribeClustersCommand)à la section *Référence des AWS SDK pour JavaScript API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/redshift#code-examples).
Décrivez le cluster.
```
suspend fun describeRedshiftClusters() {
RedshiftClient.fromEnvironment { region = "us-west-2" }.use { redshiftClient ->
val clusterResponse = redshiftClient.describeClusters(DescribeClustersRequest {})
val clusterList = clusterResponse.clusters
if (clusterList != null) {
for (cluster in clusterList) {
println("Cluster database name is ${cluster.dbName}")
println("Cluster status is ${cluster.clusterStatus}")
}
}
}
}
```
+ Pour plus de détails sur l'API, consultez [DescribeClusters](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftWrapper:
"""
Encapsulates Amazon Redshift cluster operations.
"""
def __init__(self, redshift_client):
"""
:param redshift_client: A Boto3 Redshift client.
"""
self.client = redshift_client
def describe_clusters(self, cluster_identifier):
"""
Describes a cluster.
:param cluster_identifier: The cluster identifier.
:return: A list of clusters.
"""
try:
kwargs = {}
if cluster_identifier:
kwargs["ClusterIdentifier"] = cluster_identifier
paginator = self.client.get_paginator("describe_clusters")
clusters = []
for page in paginator.paginate(**kwargs):
clusters.extend(page["Clusters"])
return clusters
except ClientError as err:
logging.error(
"Couldn't describe a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftWrapper objet.
```
client = boto3.client("redshift")
redhift_wrapper = RedshiftWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [DescribeClusters](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DescribeClusters)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsh#code-examples).
Décrivez le cluster.
```
TRY.
" Example values: iv_cluster_identifier = 'my-redshift-cluster' (optional)
oo_result = lo_rsh->describeclusters(
iv_clusteridentifier = iv_cluster_identifier
).
lt_clusters = oo_result->get_clusters( ).
lv_cluster_count = lines( lt_clusters ).
MESSAGE |Retrieved { lv_cluster_count } cluster(s).| TYPE 'I'.
CATCH /aws1/cx_rshclustnotfoundfault.
MESSAGE 'Cluster not found.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeClusters](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `DescribeStatement` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `DescribeStatement`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Describe a statement execution.
///
/// The statement ID.
/// The statement description.
public async Task DescribeStatementAsync(string statementId)
{
try
{
var request = new DescribeStatementRequest
{
Id = statementId
};
var response = await _redshiftDataClient.DescribeStatementAsync(request);
return response;
}
catch (Amazon.RedshiftDataAPIService.Model.ResourceNotFoundException ex)
{
Console.WriteLine($"Statement not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't describe statement. Here's why: {ex.Message}");
throw;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeStatement](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/DescribeStatement)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
```
/**
* Checks the status of an SQL statement asynchronously and handles the completion of the statement.
*
* @param sqlId the ID of the SQL statement to check
* @return a {@link CompletableFuture} that completes when the SQL statement's status is either "FINISHED" or "FAILED"
*/
public CompletableFuture checkStatementAsync(String sqlId) {
DescribeStatementRequest statementRequest = DescribeStatementRequest.builder()
.id(sqlId)
.build();
return getAsyncDataClient().describeStatement(statementRequest)
.thenCompose(response -> {
String status = response.statusAsString();
logger.info("... Status: {} ", status);
if ("FAILED".equals(status)) {
throw new RuntimeException("The Query Failed. Ending program");
} else if ("FINISHED".equals(status)) {
return CompletableFuture.completedFuture(null);
} else {
// Sleep for 1 second and recheck status
return CompletableFuture.runAsync(() -> {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException("Error during sleep: " + e.getMessage(), e);
}
}).thenCompose(ignore -> checkStatementAsync(sqlId)); // Recursively call until status is FINISHED or FAILED
}
}).whenComplete((result, exception) -> {
if (exception != null) {
// Handle exceptions
logger.info("Error: {} ", exception.getMessage());
} else {
logger.info("The statement is finished!");
}
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeStatement](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/DescribeStatement)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftDataWrapper:
"""Encapsulates Amazon Redshift data."""
def __init__(self, client):
"""
:param client: A Boto3 RedshiftDataWrapper client.
"""
self.client = client
def describe_statement(self, statement_id):
"""
Describes a SQL statement.
:param statement_id: The SQL statement identifier.
:return: The SQL statement result.
"""
try:
response = self.client.describe_statement(Id=statement_id)
return response
except ClientError as err:
logging.error(
"Couldn't describe statement. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftDataWrapper objet.
```
client = boto3.client("redshift-data")
redshift_data_wrapper = RedshiftDataWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [DescribeStatement](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/DescribeStatement)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsd#code-examples).
```
TRY.
" Example values: iv_statement_id = 'xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx'
oo_result = lo_rsd->describestatement(
iv_id = iv_statement_id
).
lv_status = oo_result->get_status( ).
MESSAGE |Statement status: { lv_status }| TYPE 'I'.
CATCH /aws1/cx_rsdresourcenotfoundex.
MESSAGE 'Statement not found.' TYPE 'I'.
CATCH /aws1/cx_rsdinternalserverex.
MESSAGE 'Internal server error.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [DescribeStatement](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `ExecuteStatement` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `ExecuteStatement`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Exécute une instruction SQL pour créer une table de base de données.
```
/**
* Creates an asynchronous task to execute a SQL statement for creating a new table.
*
* @param clusterId the identifier of the Amazon Redshift cluster
* @param databaseName the name of the database to create the table in
* @param userName the username to use for the database connection
* @return a {@link CompletableFuture} that completes with the result of the SQL statement execution
* @throws RuntimeException if there is an error creating the table
*/
public CompletableFuture createTableAsync(String clusterId, String databaseName, String userName) {
ExecuteStatementRequest createTableRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.dbUser(userName)
.database(databaseName)
.sql("CREATE TABLE Movies (" +
"id INT PRIMARY KEY, " +
"title VARCHAR(100), " +
"year INT)")
.build();
return getAsyncDataClient().executeStatement(createTableRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new RuntimeException("Error creating table: " + exception.getMessage(), exception);
} else {
logger.info("Table created: Movies");
}
});
}
```
Exécute une instruction SQL pour insérer des données dans une table de base de données.
```
/**
* Asynchronously pops a table from a JSON file.
*
* @param clusterId the ID of the cluster
* @param databaseName the name of the database
* @param userName the username
* @param fileName the name of the JSON file
* @param number the number of records to process
* @return a CompletableFuture that completes with the number of records added to the Movies table
*/
public CompletableFuture popTableAsync(String clusterId, String databaseName, String userName, String fileName, int number) {
return CompletableFuture.supplyAsync(() -> {
try {
JsonParser parser = new JsonFactory().createParser(new File(fileName));
JsonNode rootNode = new ObjectMapper().readTree(parser);
Iterator iter = rootNode.iterator();
return iter;
} catch (IOException e) {
throw new RuntimeException("Failed to read or parse JSON file: " + e.getMessage(), e);
}
}).thenCompose(iter -> processNodesAsync(clusterId, databaseName, userName, iter, number))
.whenComplete((result, exception) -> {
if (exception != null) {
logger.info("Error {} ", exception.getMessage());
} else {
logger.info("{} records were added to the Movies table." , result);
}
});
}
private CompletableFuture processNodesAsync(String clusterId, String databaseName, String userName, Iterator iter, int number) {
return CompletableFuture.supplyAsync(() -> {
int t = 0;
try {
while (iter.hasNext()) {
if (t == number)
break;
JsonNode currentNode = iter.next();
int year = currentNode.get("year").asInt();
String title = currentNode.get("title").asText();
// Use SqlParameter to avoid SQL injection.
List parameterList = new ArrayList<>();
String sqlStatement = "INSERT INTO Movies VALUES( :id , :title, :year);";
SqlParameter idParam = SqlParameter.builder()
.name("id")
.value(String.valueOf(t))
.build();
SqlParameter titleParam = SqlParameter.builder()
.name("title")
.value(title)
.build();
SqlParameter yearParam = SqlParameter.builder()
.name("year")
.value(String.valueOf(year))
.build();
parameterList.add(idParam);
parameterList.add(titleParam);
parameterList.add(yearParam);
ExecuteStatementRequest insertStatementRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.sql(sqlStatement)
.database(databaseName)
.dbUser(userName)
.parameters(parameterList)
.build();
getAsyncDataClient().executeStatement(insertStatementRequest);
logger.info("Inserted: " + title + " (" + year + ")");
t++;
}
} catch (RedshiftDataException e) {
throw new RuntimeException("Error inserting data: " + e.getMessage(), e);
}
return t;
});
}
```
Exécute une instruction SQL pour interroger une table de base de données.
```
/**
* Asynchronously queries movies by a given year from a Redshift database.
*
* @param database the name of the database to query
* @param dbUser the user to connect to the database with
* @param year the year to filter the movies by
* @param clusterId the identifier of the Redshift cluster to connect to
* @return a {@link CompletableFuture} containing the response ID of the executed SQL statement
*/
public CompletableFuture queryMoviesByYearAsync(String database,
String dbUser,
int year,
String clusterId) {
String sqlStatement = "SELECT * FROM Movies WHERE year = :year";
SqlParameter yearParam = SqlParameter.builder()
.name("year")
.value(String.valueOf(year))
.build();
ExecuteStatementRequest statementRequest = ExecuteStatementRequest.builder()
.clusterIdentifier(clusterId)
.database(database)
.dbUser(dbUser)
.parameters(yearParam)
.sql(sqlStatement)
.build();
return CompletableFuture.supplyAsync(() -> {
try {
ExecuteStatementResponse response = getAsyncDataClient().executeStatement(statementRequest).join(); // Use join() to wait for the result
return response.id();
} catch (RedshiftDataException e) {
throw new RuntimeException("Error executing statement: " + e.getMessage(), e);
}
}).exceptionally(exception -> {
logger.info("Error: {}", exception.getMessage());
return "";
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [ExecuteStatement](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ExecuteStatement)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsd#code-examples).
```
TRY.
" Example values: iv_cluster_identifier = 'redshift-cluster-movies'
" Example values: iv_database_name = 'dev'
" Example values: iv_user_name = 'awsuser'
" Example values: iv_sql = 'SELECT * FROM movies WHERE year = :year'
" Example values: it_parameter_list - SQL parameters for parameterized queries
" Only pass parameters if the list is not empty
IF it_parameter_list IS NOT INITIAL.
oo_result = lo_rsd->executestatement(
iv_clusteridentifier = iv_cluster_identifier
iv_database = iv_database_name
iv_dbuser = iv_user_name
iv_sql = iv_sql
it_parameters = it_parameter_list
).
ELSE.
oo_result = lo_rsd->executestatement(
iv_clusteridentifier = iv_cluster_identifier
iv_database = iv_database_name
iv_dbuser = iv_user_name
iv_sql = iv_sql
).
ENDIF.
lv_statement_id = oo_result->get_id( ).
MESSAGE |Statement executed. ID: { lv_statement_id }| TYPE 'I'.
CATCH /aws1/cx_rsdexecutestatementex.
MESSAGE 'Statement execution error.' TYPE 'I'.
CATCH /aws1/cx_rsdresourcenotfoundex.
MESSAGE 'Resource not found.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [ExecuteStatement](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `GetStatementResult` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `GetStatementResult`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Get the results of a statement execution.
///
/// The statement ID.
/// A list of result rows.
public async Task>> GetStatementResultAsync(string statementId)
{
try
{
var request = new GetStatementResultRequest
{
Id = statementId
};
var response = await _redshiftDataClient.GetStatementResultAsync(request);
return response.Records;
}
catch (Amazon.RedshiftDataAPIService.Model.ResourceNotFoundException ex)
{
Console.WriteLine($"Statement not found: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't get statement result. Here's why: {ex.Message}");
throw;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [GetStatementResult](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/GetStatementResult)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Vérifiez le résultat de l’instruction.
```
/**
* Asynchronously retrieves the results of a statement execution.
*
* @param statementId the ID of the statement for which to retrieve the results
* @return a {@link CompletableFuture} that completes when the statement result has been processed
*/
public CompletableFuture getResultsAsync(String statementId) {
GetStatementResultRequest resultRequest = GetStatementResultRequest.builder()
.id(statementId)
.build();
return getAsyncDataClient().getStatementResult(resultRequest)
.handle((response, exception) -> {
if (exception != null) {
logger.info("Error getting statement result {} ", exception.getMessage());
throw new RuntimeException("Error getting statement result: " + exception.getMessage(), exception);
}
// Extract and print the field values using streams if the response is valid.
response.records().stream()
.flatMap(List::stream)
.map(Field::stringValue)
.filter(value -> value != null)
.forEach(value -> System.out.println("The Movie title field is " + value));
return response;
}).thenAccept(response -> {
// Optionally add more logic here if needed after handling the response
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [GetStatementResult](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/GetStatementResult)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftDataWrapper:
"""Encapsulates Amazon Redshift data."""
def __init__(self, client):
"""
:param client: A Boto3 RedshiftDataWrapper client.
"""
self.client = client
def get_statement_result(self, statement_id):
"""
Gets the result of a SQL statement.
:param statement_id: The SQL statement identifier.
:return: The SQL statement result.
"""
try:
result = {
"Records": [],
}
paginator = self.client.get_paginator("get_statement_result")
for page in paginator.paginate(Id=statement_id):
if "ColumnMetadata" not in result:
result["ColumnMetadata"] = page["ColumnMetadata"]
result["Records"].extend(page["Records"])
return result
except ClientError as err:
logging.error(
"Couldn't get statement result. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftDataWrapper objet.
```
client = boto3.client("redshift-data")
redshift_data_wrapper = RedshiftDataWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [GetStatementResult](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/GetStatementResult)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsd#code-examples).
Vérifiez le résultat de l’instruction.
```
TRY.
" Example values: iv_statement_id = 'xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx'
" Handle pagination for large result sets
DO.
lo_result_page = lo_rsd->getstatementresult(
iv_id = iv_statement_id
iv_nexttoken = lv_next_token
).
" Collect records from this page
lt_page_records = lo_result_page->get_records( ).
APPEND LINES OF lt_page_records TO lt_all_records.
" Check if there are more pages
lv_next_token = lo_result_page->get_nexttoken( ).
IF lv_next_token IS INITIAL.
EXIT. " No more pages
ENDIF.
ENDDO.
" For the last call, set oo_result for return value
oo_result = lo_result_page.
lv_record_count = lines( lt_all_records ).
MESSAGE |Retrieved { lv_record_count } record(s).| TYPE 'I'.
CATCH /aws1/cx_rsdresourcenotfoundex.
MESSAGE 'Statement not found or results not available.' TYPE 'I'.
CATCH /aws1/cx_rsdinternalserverex.
MESSAGE 'Internal server error.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [GetStatementResult](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `ListDatabases` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `ListDatabases`.
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// List databases in a Redshift cluster.
///
/// The cluster identifier.
/// The database user.
/// The database name for authentication.
/// A list of database names.
public async Task> ListDatabasesAsync(string clusterIdentifier, string dbUser, string databaseName)
{
try
{
var request = new ListDatabasesRequest
{
ClusterIdentifier = clusterIdentifier,
DbUser = dbUser,
Database = databaseName
};
var response = await _redshiftDataClient.ListDatabasesAsync(request);
var databases = new List();
foreach (var database in response.Databases)
{
Console.WriteLine($"The database name is : {database}");
databases.Add(database);
}
return databases;
}
catch (Amazon.RedshiftDataAPIService.Model.ValidationException ex)
{
Console.WriteLine($"Validation error: {ex.Message}");
throw;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't list databases. Here's why: {ex.Message}");
throw;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [ListDatabases](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/ListDatabases)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
```
/**
* Lists all databases asynchronously for the specified cluster, database user, and database.
* @param clusterId the identifier of the cluster to list databases for
* @param dbUser the database user to use for the list databases request
* @param database the database to list databases for
* @return a {@link CompletableFuture} that completes when the database listing is complete, or throws a {@link RuntimeException} if there was an error
*/
public CompletableFuture listAllDatabasesAsync(String clusterId, String dbUser, String database) {
ListDatabasesRequest databasesRequest = ListDatabasesRequest.builder()
.clusterIdentifier(clusterId)
.dbUser(dbUser)
.database(database)
.build();
// Asynchronous paginator for listing databases.
ListDatabasesPublisher databasesPaginator = getAsyncDataClient().listDatabasesPaginator(databasesRequest);
CompletableFuture future = databasesPaginator.subscribe(response -> {
response.databases().forEach(db -> {
logger.info("The database name is {} ", db);
});
});
// Return the future for asynchronous handling.
return future.exceptionally(exception -> {
throw new RuntimeException("Failed to list databases: " + exception.getMessage(), exception);
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [ListDatabases](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ListDatabases)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsd#code-examples).
```
TRY.
" Example values: iv_cluster_identifier = 'redshift-cluster-movies'
" Example values: iv_database_name = 'dev'
" Example values: iv_database_user = 'awsuser'
oo_result = lo_rsd->listdatabases(
iv_clusteridentifier = iv_cluster_identifier
iv_database = iv_database_name
iv_dbuser = iv_database_user
).
lt_databases = oo_result->get_databases( ).
lv_db_count = lines( lt_databases ).
MESSAGE |Retrieved { lv_db_count } database(s).| TYPE 'I'.
CATCH /aws1/cx_rsddatabaseconnex.
MESSAGE 'Database connection error.' TYPE 'I'.
CATCH /aws1/cx_rsdresourcenotfoundex.
MESSAGE 'Cluster not found.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [ListDatabases](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------
# Utilisation `ModifyCluster` avec un AWS SDK ou une CLI
Les exemples de code suivants illustrent comment utiliser `ModifyCluster`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](redshift_example_redshift_Scenario_section.md)
------
#### [ .NET ]
**SDK pour .NET (v4)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv4/Redshift#code-examples).
```
///
/// Modify an Amazon Redshift cluster.
///
/// The identifier for the cluster.
/// The preferred maintenance window.
/// True if successful.
public async Task ModifyClusterAsync(string clusterIdentifier, string preferredMaintenanceWindow)
{
try
{
var request = new ModifyClusterRequest
{
ClusterIdentifier = clusterIdentifier,
PreferredMaintenanceWindow = preferredMaintenanceWindow
};
var response = await _redshiftClient.ModifyClusterAsync(request);
Console.WriteLine($"The modified cluster was successfully modified and has {response.Cluster.PreferredMaintenanceWindow} as the maintenance window");
return true;
}
catch (ClusterNotFoundException ex)
{
Console.WriteLine($"Cluster {clusterIdentifier} not found: {ex.Message}");
return false;
}
catch (Exception ex)
{
Console.WriteLine($"Couldn't modify cluster. Here's why: {ex.Message}");
return false;
}
}
```
+ Pour plus de détails sur l'API, reportez-vous [ModifyCluster](https://docs.aws.amazon.com/goto/DotNetSDKV4/redshift-2012-12-01/ModifyCluster)à la section *Référence des AWS SDK pour .NET API*.
------
#### [ CLI ]
**AWS CLI**
Associer un groupe de sécurité à l'aide d'un ClusterThis exemple montre comment associer un groupe de sécurité de cluster au cluster spécifié.Commande :
```
aws redshift modify-cluster --cluster-identifier mycluster --cluster-security-groups mysecuritygroup
```
Modifiez la fenêtre de maintenance pour ClusterThis montrer comment modifier la fenêtre de maintenance hebdomadaire préférée pour un cluster afin qu'elle soit au minimum de quatre heures commençant le dimanche à 23 h 15 et se terminant le lundi à 3 h 15. Commande :
```
aws redshift modify-cluster --cluster-identifier mycluster --preferred-maintenance-window Sun:23:15-Mon:03:15
```
Modifiez le mot de passe principal. L' ClusterThis exemple montre comment modifier le mot de passe principal d'un cluster.Commande :
```
aws redshift modify-cluster --cluster-identifier mycluster --master-user-password A1b2c3d4
```
+ Pour plus de détails sur l'API, voir [ModifyCluster](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/redshift/modify-cluster.html)la section *Référence des AWS CLI commandes*.
------
#### [ Go ]
**Kit SDK pour Go V2**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/gov2/redshift#code-examples).
```
import (
"context"
"errors"
"log"
"time"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/redshift"
"github.com/aws/aws-sdk-go-v2/service/redshift/types"
)
// RedshiftActions wraps Redshift service actions.
type RedshiftActions struct {
RedshiftClient *redshift.Client
}
// ModifyCluster sets the preferred maintenance window for the given cluster.
func (actor RedshiftActions) ModifyCluster(ctx context.Context, clusterId string, maintenanceWindow string) *redshift.ModifyClusterOutput {
// Modify the cluster's maintenance window
input := &redshift.ModifyClusterInput{
ClusterIdentifier: aws.String(clusterId),
PreferredMaintenanceWindow: aws.String(maintenanceWindow),
}
var opErr *types.InvalidClusterStateFault
output, err := actor.RedshiftClient.ModifyCluster(ctx, input)
if err != nil && errors.As(err, &opErr) {
log.Println("Cluster is in an invalid state.")
panic(err)
} else if err != nil {
log.Printf("Failed to modify Redshift cluster: %v\n", err)
panic(err)
}
log.Printf("The cluster was successfully modified and now has %s as the maintenance window\n", *output.Cluster.PreferredMaintenanceWindow)
return output
}
```
+ Pour plus de détails sur l'API, reportez-vous [ModifyCluster](https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/redshift#Client.ModifyCluster)à la section *Référence des AWS SDK pour Go API*.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/redshift#code-examples).
Modifiez un cluster.
```
/**
* Modifies an Amazon Redshift cluster asynchronously.
*
* @param clusterId the identifier of the cluster to be modified
* @return a {@link CompletableFuture} that completes when the cluster modification is complete
*/
public CompletableFuture modifyClusterAsync(String clusterId) {
ModifyClusterRequest modifyClusterRequest = ModifyClusterRequest.builder()
.clusterIdentifier(clusterId)
.preferredMaintenanceWindow("wed:07:30-wed:08:00")
.build();
return getAsyncClient().modifyCluster(modifyClusterRequest)
.whenComplete((clusterResponse, exception) -> {
if (exception != null) {
if (exception.getCause() instanceof RedshiftException) {
logger.info("Error: {} ", exception.getMessage());
} else {
logger.info("Unexpected error: {} ", exception.getMessage());
}
} else {
logger.info("The modified cluster was successfully modified and has "
+ clusterResponse.cluster().preferredMaintenanceWindow() + " as the maintenance window");
}
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [ModifyCluster](https://docs.aws.amazon.com/goto/SdkForJavaV2/redshift-2012-12-01/ModifyCluster)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ JavaScript ]
**SDK pour JavaScript (v3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/redshift#code-examples).
Créez le client.
```
import { RedshiftClient } from "@aws-sdk/client-redshift";
// Set the AWS Region.
const REGION = "REGION";
//Set the Redshift Service Object
const redshiftClient = new RedshiftClient({ region: REGION });
export { redshiftClient };
```
Modifiez un cluster.
```
// Import required AWS SDK clients and commands for Node.js
import { ModifyClusterCommand } from "@aws-sdk/client-redshift";
import { redshiftClient } from "./libs/redshiftClient.js";
// Set the parameters
const params = {
ClusterIdentifier: "CLUSTER_NAME",
MasterUserPassword: "NEW_MASTER_USER_PASSWORD",
};
const run = async () => {
try {
const data = await redshiftClient.send(new ModifyClusterCommand(params));
console.log("Success was modified.", data);
return data; // For unit tests.
} catch (err) {
console.log("Error", err);
}
};
run();
```
+ Pour plus de détails sur l'API, reportez-vous [ModifyCluster](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/redshift/command/ModifyClusterCommand)à la section *Référence des AWS SDK pour JavaScript API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/redshift#code-examples).
Modifiez un cluster.
```
suspend fun modifyCluster(clusterId: String?) {
val modifyClusterRequest =
ModifyClusterRequest {
clusterIdentifier = clusterId
preferredMaintenanceWindow = "wed:07:30-wed:08:00"
}
RedshiftClient { region = "us-west-2" }.use { redshiftClient ->
val clusterResponse = redshiftClient.modifyCluster(modifyClusterRequest)
println(
"The modified cluster was successfully modified and has ${clusterResponse.cluster?.preferredMaintenanceWindow} as the maintenance window",
)
}
}
```
+ Pour plus de détails sur l'API, consultez [ModifyCluster](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
#### [ Python ]
**Kit SDK for Python (Boto3)**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/redshift#code-examples).
```
class RedshiftWrapper:
"""
Encapsulates Amazon Redshift cluster operations.
"""
def __init__(self, redshift_client):
"""
:param redshift_client: A Boto3 Redshift client.
"""
self.client = redshift_client
def modify_cluster(self, cluster_identifier, preferred_maintenance_window):
"""
Modifies a cluster.
:param cluster_identifier: The cluster identifier.
:param preferred_maintenance_window: The preferred maintenance window.
"""
try:
self.client.modify_cluster(
ClusterIdentifier=cluster_identifier,
PreferredMaintenanceWindow=preferred_maintenance_window,
)
except ClientError as err:
logging.error(
"Couldn't modify a cluster. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
Le code suivant instancie l' RedshiftWrapper objet.
```
client = boto3.client("redshift")
redhift_wrapper = RedshiftWrapper(client)
```
+ Pour plus de détails sur l'API, consultez [ModifyCluster](https://docs.aws.amazon.com/goto/boto3/redshift-2012-12-01/ModifyCluster)le *AWS manuel de référence de l'API SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**Kit SDK pour SAP ABAP**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/rsh#code-examples).
Modifiez un cluster.
```
TRY.
" Example values: iv_cluster_identifier = 'my-redshift-cluster'
" Example values: iv_pref_maintenance_wn = 'wed:07:30-wed:08:00'
lo_rsh->modifycluster(
iv_clusteridentifier = iv_cluster_identifier
iv_preferredmaintenancewin00 = iv_pref_maintenance_wn
).
MESSAGE 'Redshift cluster modified successfully.' TYPE 'I'.
CATCH /aws1/cx_rshclustnotfoundfault.
MESSAGE 'Cluster not found.' TYPE 'I'.
CATCH /aws1/cx_rshinvcluststatefault.
MESSAGE 'Invalid cluster state for modification.' TYPE 'I'.
ENDTRY.
```
+ Pour plus de détails sur l'API, reportez-vous [ModifyCluster](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)à la section de référence du *AWS SDK pour l'API SAP ABAP*.
------