how to install and start using alibaba cloud sdk for java - ApsaraDB for Cassandra - Deprecated

Ce document présente le kit de développement logiciel (SDK) Alibaba Cloud pour Java. Utilisez ce SDK pour gérer vos instances ApsaraDB for Cassandra en effectuant des appels d'API OpenAPI. Il vous permet de créer, mettre à niveau et supprimer des instances, de configurer les listes d'autorisation et de gérer les tags sans programmation complexe. Ce SDK diffère des bibliothèques utilisées pour accéder aux données stockées dans les instances Cassandra. Cette rubrique explique comment installer et commencer à utiliser le SDK Alibaba Cloud pour Java.

Prérequis

Vous devez disposer d'une clé AccessKey. Pour plus d'informations, consultez la rubrique Obtenir une clé AccessKey.

Débogage en ligne et génération d'exemples de code SDK

L'outil OpenAPI Explorer simplifie l'utilisation des API. Il vous permet d'appeler des API en ligne, de générer des exemples de code SDK et de récupérer rapidement les interfaces. Accédez à la page OpenAPI Explorer et sélectionnez le produit Cassandra. OpenAPI Explorer fournit une liste d'API. Chaque API inclut des démonstrations de débogage pour différents langages de programmation.

Téléchargement et installation du SDK Alibaba Cloud pour Java

Installez le SDK Alibaba Cloud pour Java en ajoutant une dépendance Maven ou en important un fichier JAR. Pour plus d'informations, consultez la rubrique Installer le SDK Alibaba Cloud pour Java.

Remarque

Lorsque vous téléchargez le package SDK via Maven, assurez-vous de télécharger la dernière version.

Exemples

Appel de DescribeClusterRequest pour obtenir les informations d'un cluster Cassandra

Définissez les paramètres d'environnement.

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
// The following parameters are optional. You can use the default values.
DefaultProfile.addEndpoint(
                        "cn-hangzhou",    // The region ID.
                        "cassandra",    // The product code.
                        "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);

Initialisez le client.

IAcsClient client = new DefaultAcsClient(profile);

Créez l'objet de requête.

DescribeClusterRequest request = new DescribeClusterRequest();
request.setClusterId("cds-wz9bui92****697r");

Exécutez la requête.

DescribeClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
DefaultProfile.addEndpoint(
                "cn-hangzhou",    // The region ID.
                "cassandra",    // The product code.
                "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);
IAcsClient client = new DefaultAcsClient(profile);
DescribeClusterRequest request = new DescribeClusterRequest();
request.setClusterId("cds-wz9bui92****697r");
DescribeClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple de réponse

{
  "RequestId": "3B235CE2-2339-42A8-A11D-5F7548519AD2",
  "Cluster": {
    "Status": "Running",
    "MajorVersion": "3.11",
    "CreatedTime": "2020-04-21T08:50:04Z",
    "ClusterId": "cds-wz9bui92****6973",
    "MinorVersion": "3.11.9",
    "PayType": "PayAsYouGo",
    "LockMode": "Expired",
    "IsLatestVersion": true,
    "MaintainEndTime": "22:00Z",
    "DataCenterCount": 1,
    "ClusterName": "auto_test20200421170214",
    "MaintainStartTime": "18:00Z",
    "Tags": {
      "Tag": [
        {
          "Value": "1",
          "Key": "test"
        },
        {
          "Value": "2",
          "Key": "test2"
        }
      ]
    }
  }
}

Appel de CreateCluster pour créer un cluster Cassandra

Définissez les paramètres d'environnement.

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
// The following parameters are optional. You can use the default values.
DefaultProfile.addEndpoint(
                        "cn-hangzhou",    // The region ID.
                        "cassandra",    // The product code.
                        "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);

Initialisez le client.

IAcsClient client = new DefaultAcsClient(profile);

Créez l'objet de requête.

CreateClusterRequest request = new CreateClusterRequest();
// Required parameters.
request.setPayType("PayAsYouGo");
request.setRegionId("cn-hangzhou");
request.setZoneId("cn-hangzhou-e");
request.setMajorVersion("3.11");
request.setInstanceType("cassandra.c.large");
request.setNodeCount("2");
request.setVpcId("vpc-wz9s6dl6nttp1****ydur");
request.setVswitchId("vsw-wz9c90poaus9q****1dxl");
// Optional parameters.
request.setPeriodUnit("Year");// This parameter is required if PayType is set to Subscription.
request.setPeriod("12");// This parameter is required if PayType is set to Subscription.
request.setAutoRenew("false");// This parameter is required if PayType is set to Subscription.
request.setAutoRenewPeriod("3");// This parameter is required if PayType is set to Subscription.
request.setClientToken("ETnLKlblzczshOTUbOCzxxxxxxxxxx");
request.setClusterName("cassandra_01");
request.setDataCenterName("cassandra_dc_01");
request.setDiskType("cloud_ssd");
request.setDiskSize("160");
request.setPassword("Cassandra1@!");

Exécutez la requête.

CreateClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
DefaultProfile.addEndpoint(
                "cn-hangzhou",    // The region ID.
                "cassandra",    // The product code.
                "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);
IAcsClient client = new DefaultAcsClient(profile);
CreateClusterRequest request = new CreateClusterRequest();
// Required parameters.
request.setPayType("PayAsYouGo");
request.setRegionId("cn-hangzhou");
request.setZoneId("cn-hangzhou-e");
request.setMajorVersion("3.11");
request.setInstanceType("cassandra.c.large");
request.setNodeCount("2");
request.setVpcId("vpc-wz9s6dl6nttp1****ydur");
request.setVswitchId("vsw-wz9c90poaus9q****1dxl");
// Optional parameters.
request.setPeriodUnit("Year");// This parameter is required if PayType is set to Subscription.
request.setPeriod("12");// This parameter is required if PayType is set to Subscription.
request.setAutoRenew("false");// This parameter is required if PayType is set to Subscription.
request.setAutoRenewPeriod("3");// This parameter is required if PayType is set to Subscription.
request.setClientToken("ETnLKlblzczshOTUbOCzxxxxxxxxxx");
request.setClusterName("cassandra_01");
request.setDataCenterName("cassandra_dc_01");
request.setDiskType("cloud_ssd");
request.setDiskSize("160");
request.setPassword("Cassandra1@!");
CreateClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple de réponse

{
    "ClusterId":"hb-bp16o0pd5****582s",
    "RequestId":"728C7EAF-4844-4D42-9BBE-DFFFBB77CF33"
}

Appel de ResizeNodeCount pour augmenter le nombre de nœuds dans un centre de données

Définissez les paramètres d'environnement.

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
// The following parameters are optional. You can use the default values.
DefaultProfile.addEndpoint(
                        "cn-hangzhou",    // The region ID.
                        "cassandra",    // The product code.
                        "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);

Initialisez le client.

IAcsClient client = new DefaultAcsClient(profile);

Créez l'objet de requête.

ResizeNodeCountRequest request = new ResizeNodeCountRequest();
request.setClusterId("cds-bp1b136j****5d59");
request.setDataCenterId("cn-hangzhou-g");
request.setNodeCount("3");

Exécutez la requête.

ResizeNodeCountResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
DefaultProfile.addEndpoint(
                "cn-hangzhou",    // The region ID.
                "cassandra",    // The product code.
                "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);
IAcsClient client = new DefaultAcsClient(profile);
ResizeNodeCountRequest request = new ResizeNodeCountRequest();
request.setClusterId("cds-bp1b136j****5d59");
request.setDataCenterId("cn-hangzhou-g");
request.setNodeCount("3");
ResizeNodeCountResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple de réponse

{
    "RequestId": "D7D3088F-AA4F-49C3-BB46-B04F3E35041A"
}

Appel de DeleteCluster pour supprimer un cluster Cassandra

Définissez les paramètres d'environnement.

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
// The following parameters are optional. You can use the default values.
DefaultProfile.addEndpoint(
                        "cn-hangzhou",    // The region ID.
                        "cassandra",    // The product code.
                        "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);

Initialisez le client.

IAcsClient client = new DefaultAcsClient(profile);

Créez l'objet de requête.

DeleteClusterRequest request = new DeleteClusterRequest();
request.setClusterId("cds-bp1hy2ipk****46k");

Exécutez la requête.

DeleteClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple

DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou",
                "LTAI****************", "yourAccessKeySecret");
DefaultProfile.addEndpoint(
                "cn-hangzhou",    // The region ID.
                "cassandra",    // The product code.
                "cassandra.aliyuncs.com"    // The endpoint, which is a domain name.
);
IAcsClient client = new DefaultAcsClient(profile);
DeleteClusterRequest request = new DeleteClusterRequest();
request.setClusterId("cds-bp1hy2ipk****46k");
DeleteClusterResponse response;
try {
        response = client.getAcsResponse(request);
        System.out.println(new Gson().toJson(response));
} catch (ClientException e) {
        e.printStackTrace();
}

Exemple de réponse

{
    "RequestId":"728C7EAF-4844-4D42-9BBE-DFFFBB77CF33"
}