Criação de uma instância

Função

Esta API é usada para criar uma instância

. Há suporte para os modos de cobrança de pagamento por uso e anual/mensal.

Método de chamada

Para obter detalhes, consulte Chamada de APIs.

URI

POST /v2/{engine}/{project_id}/instances

Parâmetros de solicitação

Parâmetros de resposta

Código de status: 200

Exemplo de solicitações

• Criação de uma instância do Kafka de pagamento por uso cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  POST https://{endpoint}/v2/{engine}/{project_id}/instances
  
  {
    "name" : "kafka-test",
    "description" : "",
    "engine" : "kafka",
    "engine_version" : "2.7",
    "storage_space" : 300,
    "vpc_id" : "********-9b4a-44c5-a964-************",
    "subnet_id" : "********-8fbf-4438-ba71-************",
    "security_group_id" : "********-e073-4aad-991f-************",
    "available_zones" : [ "********706d4c1fb0eb72f0********" ],
    "product_id" : "c6.2u4g.cluster",
    "ssl_enable" : true,
    "kafka_security_protocol" : "SASL_SSL",
    "sasl_enabled_mechanisms" : [ "SCRAM-SHA-512" ],
    "storage_spec_code" : "dms.physical.storage.ultra.v2",
    "broker_num" : 3,
    "arch_type" : "X86",
    "enterprise_project_id" : "0",
    "access_user" : "********",
    "password" : "********",
    "enable_publicip" : true,
    "tags" : [ {
      "key" : "aaa",
      "value" : "111"
    } ],
    "retention_policy" : "time_base",
    "disk_encrypted_enable" : true,
    "disk_encrypted_key" : "********-b953-4875-a743-************",
    "publicip_id" : "********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************",
    "vpc_client_plain" : true,
    "enable_auto_topic" : true
  }

• Criação de uma instância anual/mensal do Kafka cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  POST https://{endpoint}/v2/{engine}/{project_id}/instances
  
  {
    "name" : "kafka-test1",
    "description" : "",
    "engine" : "kafka",
    "engine_version" : "2.7",
    "storage_space" : 300,
    "vpc_id" : "********-9b4a-44c5-a964-************",
    "subnet_id" : "********-8fbf-4438-ba71-************",
    "security_group_id" : "********-e073-4aad-991f-************",
    "available_zones" : [ "********706d4c1fb0eb72f0********" ],
    "product_id" : "c6.2u4g.cluster",
    "ssl_enable" : true,
    "kafka_security_protocol" : "SASL_SSL",
    "sasl_enabled_mechanisms" : [ "SCRAM-SHA-512" ],
    "storage_spec_code" : "dms.physical.storage.ultra.v2",
    "broker_num" : 3,
    "arch_type" : "X86",
    "enterprise_project_id" : "0",
    "access_user" : "********",
    "password" : "********",
    "enable_publicip" : true,
    "tags" : [ {
      "key" : "aaa",
      "value" : "111"
    } ],
    "retention_policy" : "time_base",
    "publicip_id" : "********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************",
    "vpc_client_plain" : true,
    "enable_auto_topic" : true,
    "bss_param" : {
      "charging_mode" : "prePaid",
      "period_type" : "month",
      "period_num" : 1,
      "is_auto_pay" : true
    }
  }

Exemplo de respostas

Código de status: 200

Instância criada com sucesso.

{
  "instance_id" : "8959ab1c-7n1a-yyb1-a05t-93dfc361b32d"
}

Código de exemplo do SDK

O código de exemplo do SDK é o seguinte.

Java

• Criação de uma instância do Kafka de pagamento por uso cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89

  package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud.sdk.core.auth.BasicCredentials; import com.huaweicloud.sdk.core.exception.ConnectionException; import com.huaweicloud.sdk.core.exception.RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateInstanceByEngineSolution { public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK"); String projectId = "{project_id}"; ICredential auth = new BasicCredentials() .withProjectId(projectId) .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth) .withRegion(KafkaRegion.valueOf("<YOUR REGION>")) .build(); CreateInstanceByEngineRequest request = new CreateInstanceByEngineRequest(); request.withEngine(CreateInstanceByEngineRequest.EngineEnum.fromValue("{engine}")); CreateInstanceByEngineReq body = new CreateInstanceByEngineReq(); List<TagEntity> listbodyTags = new ArrayList<>(); listbodyTags.add( new TagEntity() .withKey("aaa") .withValue("111") ); List<CreateInstanceByEngineReq.SaslEnabledMechanismsEnum> listbodySaslEnabledMechanisms = new ArrayList<>(); listbodySaslEnabledMechanisms.add(CreateInstanceByEngineReq.SaslEnabledMechanismsEnum.fromValue("SCRAM-SHA-512")); List<String> listbodyAvailableZones = new ArrayList<>(); listbodyAvailableZones.add("********706d4c1fb0eb72f0********"); body.withVpcClientPlain(true); body.withArchType("X86"); body.withTags(listbodyTags); body.withEnterpriseProjectId("0"); body.withStorageSpecCode(CreateInstanceByEngineReq.StorageSpecCodeEnum.fromValue("dms.physical.storage.ultra.v2")); body.withEnableAutoTopic(true); body.withDiskEncryptedKey("********-b953-4875-a743-************"); body.withDiskEncryptedEnable(true); body.withRetentionPolicy(CreateInstanceByEngineReq.RetentionPolicyEnum.fromValue("time_base")); body.withSaslEnabledMechanisms(listbodySaslEnabledMechanisms); body.withKafkaSecurityProtocol("SASL_SSL"); body.withSslEnable(true); body.withPublicipId("********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************"); body.withEnablePublicip(true); body.withProductId("c6.2u4g.cluster"); body.withAvailableZones(listbodyAvailableZones); body.withSubnetId("********-8fbf-4438-ba71-************"); body.withSecurityGroupId("********-e073-4aad-991f-************"); body.withVpcId("********-9b4a-44c5-a964-************"); body.withPassword("********"); body.withAccessUser("********"); body.withStorageSpace(300); body.withBrokerNum(3); body.withEngineVersion("2.7"); body.withEngine(CreateInstanceByEngineReq.EngineEnum.fromValue("kafka")); body.withDescription(""); body.withName("kafka-test"); request.withBody(body); try { CreateInstanceByEngineResponse response = client.createInstanceByEngine(request); System.out.println(response.toString()); } catch (ConnectionException e) { e.printStackTrace(); } catch (RequestTimeoutException e) { e.printStackTrace(); } catch (ServiceResponseException e) { e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId()); System.out.println(e.getErrorCode()); System.out.println(e.getErrorMsg()); } } }

• Criação de uma instância anual/mensal do Kafka cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93

  package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud.sdk.core.auth.BasicCredentials; import com.huaweicloud.sdk.core.exception.ConnectionException; import com.huaweicloud.sdk.core.exception.RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateInstanceByEngineSolution { public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK"); String projectId = "{project_id}"; ICredential auth = new BasicCredentials() .withProjectId(projectId) .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth) .withRegion(KafkaRegion.valueOf("<YOUR REGION>")) .build(); CreateInstanceByEngineRequest request = new CreateInstanceByEngineRequest(); request.withEngine(CreateInstanceByEngineRequest.EngineEnum.fromValue("{engine}")); CreateInstanceByEngineReq body = new CreateInstanceByEngineReq(); BssParam bssParambody = new BssParam(); bssParambody.withChargingMode(BssParam.ChargingModeEnum.fromValue("prePaid")) .withIsAutoPay(true) .withPeriodType(BssParam.PeriodTypeEnum.fromValue("month")) .withPeriodNum(1); List<TagEntity> listbodyTags = new ArrayList<>(); listbodyTags.add( new TagEntity() .withKey("aaa") .withValue("111") ); List<CreateInstanceByEngineReq.SaslEnabledMechanismsEnum> listbodySaslEnabledMechanisms = new ArrayList<>(); listbodySaslEnabledMechanisms.add(CreateInstanceByEngineReq.SaslEnabledMechanismsEnum.fromValue("SCRAM-SHA-512")); List<String> listbodyAvailableZones = new ArrayList<>(); listbodyAvailableZones.add("********706d4c1fb0eb72f0********"); body.withBssParam(bssParambody); body.withVpcClientPlain(true); body.withArchType("X86"); body.withTags(listbodyTags); body.withEnterpriseProjectId("0"); body.withStorageSpecCode(CreateInstanceByEngineReq.StorageSpecCodeEnum.fromValue("dms.physical.storage.ultra.v2")); body.withEnableAutoTopic(true); body.withRetentionPolicy(CreateInstanceByEngineReq.RetentionPolicyEnum.fromValue("time_base")); body.withSaslEnabledMechanisms(listbodySaslEnabledMechanisms); body.withKafkaSecurityProtocol("SASL_SSL"); body.withSslEnable(true); body.withPublicipId("********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************"); body.withEnablePublicip(true); body.withProductId("c6.2u4g.cluster"); body.withAvailableZones(listbodyAvailableZones); body.withSubnetId("********-8fbf-4438-ba71-************"); body.withSecurityGroupId("********-e073-4aad-991f-************"); body.withVpcId("********-9b4a-44c5-a964-************"); body.withPassword("********"); body.withAccessUser("********"); body.withStorageSpace(300); body.withBrokerNum(3); body.withEngineVersion("2.7"); body.withEngine(CreateInstanceByEngineReq.EngineEnum.fromValue("kafka")); body.withDescription(""); body.withName("kafka-test1"); request.withBody(body); try { CreateInstanceByEngineResponse response = client.createInstanceByEngine(request); System.out.println(response.toString()); } catch (ConnectionException e) { e.printStackTrace(); } catch (RequestTimeoutException e) { e.printStackTrace(); } catch (ServiceResponseException e) { e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId()); System.out.println(e.getErrorCode()); System.out.println(e.getErrorMsg()); } } }

Python

• Criação de uma instância do Kafka de pagamento por uso cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72

  # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkkafka.v2.region.kafka_region import KafkaRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkkafka.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials) \ .with_region(KafkaRegion.value_of("<YOUR REGION>")) \ .build() try: request = CreateInstanceByEngineRequest() request.engine = "{engine}" listTagsbody = [ TagEntity( key="aaa", value="111" ) ] listSaslEnabledMechanismsbody = [ "SCRAM-SHA-512" ] listAvailableZonesbody = [ "********706d4c1fb0eb72f0********" ] request.body = CreateInstanceByEngineReq( vpc_client_plain=True, arch_type="X86", tags=listTagsbody, enterprise_project_id="0", storage_spec_code="dms.physical.storage.ultra.v2", enable_auto_topic=True, disk_encrypted_key="********-b953-4875-a743-************", disk_encrypted_enable=True, retention_policy="time_base", sasl_enabled_mechanisms=listSaslEnabledMechanismsbody, kafka_security_protocol="SASL_SSL", ssl_enable=True, publicip_id="********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************", enable_publicip=True, product_id="c6.2u4g.cluster", available_zones=listAvailableZonesbody, subnet_id="********-8fbf-4438-ba71-************", security_group_id="********-e073-4aad-991f-************", vpc_id="********-9b4a-44c5-a964-************", password="********", access_user="********", storage_space=300, broker_num=3, engine_version="2.7", engine="kafka", description="", name="kafka-test" ) response = client.create_instance_by_engine(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

• Criação de uma instância anual/mensal do Kafka cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77

  # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkkafka.v2.region.kafka_region import KafkaRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkkafka.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = __import__('os').getenv("CLOUD_SDK_AK") sk = __import__('os').getenv("CLOUD_SDK_SK") projectId = "{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials) \ .with_region(KafkaRegion.value_of("<YOUR REGION>")) \ .build() try: request = CreateInstanceByEngineRequest() request.engine = "{engine}" bssParambody = BssParam( charging_mode="prePaid", is_auto_pay=True, period_type="month", period_num=1 ) listTagsbody = [ TagEntity( key="aaa", value="111" ) ] listSaslEnabledMechanismsbody = [ "SCRAM-SHA-512" ] listAvailableZonesbody = [ "********706d4c1fb0eb72f0********" ] request.body = CreateInstanceByEngineReq( bss_param=bssParambody, vpc_client_plain=True, arch_type="X86", tags=listTagsbody, enterprise_project_id="0", storage_spec_code="dms.physical.storage.ultra.v2", enable_auto_topic=True, retention_policy="time_base", sasl_enabled_mechanisms=listSaslEnabledMechanismsbody, kafka_security_protocol="SASL_SSL", ssl_enable=True, publicip_id="********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************", enable_publicip=True, product_id="c6.2u4g.cluster", available_zones=listAvailableZonesbody, subnet_id="********-8fbf-4438-ba71-************", security_group_id="********-e073-4aad-991f-************", vpc_id="********-9b4a-44c5-a964-************", password="********", access_user="********", storage_space=300, broker_num=3, engine_version="2.7", engine="kafka", description="", name="kafka-test1" ) response = client.create_instance_by_engine(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

Go

• Criação de uma instância do Kafka de pagamento por uso cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95

  package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" kafka "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2/region" ) func main() { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). WithProjectId(projectId). Build() client := kafka.NewKafkaClient( kafka.KafkaClientBuilder(). WithRegion(region.ValueOf("<YOUR REGION>")). WithCredential(auth). Build()) request := &model.CreateInstanceByEngineRequest{} request.Engine = model.GetCreateInstanceByEngineRequestEngineEnum().ENGINE keyTags:= "aaa" valueTags:= "111" var listTagsbody = []model.TagEntity{ { Key: &keyTags, Value: &valueTags, }, } var listSaslEnabledMechanismsbody = []model.CreateInstanceByEngineReqSaslEnabledMechanisms{ model.GetCreateInstanceByEngineReqSaslEnabledMechanismsEnum().SCRAM_SHA_512, } var listAvailableZonesbody = []string{ "********706d4c1fb0eb72f0********", } vpcClientPlainCreateInstanceByEngineReq:= true archTypeCreateInstanceByEngineReq:= "X86" enterpriseProjectIdCreateInstanceByEngineReq:= "0" enableAutoTopicCreateInstanceByEngineReq:= true diskEncryptedKeyCreateInstanceByEngineReq:= "********-b953-4875-a743-************" diskEncryptedEnableCreateInstanceByEngineReq:= true retentionPolicyCreateInstanceByEngineReq:= model.GetCreateInstanceByEngineReqRetentionPolicyEnum().TIME_BASE kafkaSecurityProtocolCreateInstanceByEngineReq:= "SASL_SSL" sslEnableCreateInstanceByEngineReq:= true publicipIdCreateInstanceByEngineReq:= "********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************" enablePublicipCreateInstanceByEngineReq:= true passwordCreateInstanceByEngineReq:= "********" accessUserCreateInstanceByEngineReq:= "********" descriptionCreateInstanceByEngineReq:= "" request.Body = &model.CreateInstanceByEngineReq{ VpcClientPlain: &vpcClientPlainCreateInstanceByEngineReq, ArchType: &archTypeCreateInstanceByEngineReq, Tags: &listTagsbody, EnterpriseProjectId: &enterpriseProjectIdCreateInstanceByEngineReq, StorageSpecCode: model.GetCreateInstanceByEngineReqStorageSpecCodeEnum().DMS_PHYSICAL_STORAGE_ULTRA, EnableAutoTopic: &enableAutoTopicCreateInstanceByEngineReq, DiskEncryptedKey: &diskEncryptedKeyCreateInstanceByEngineReq, DiskEncryptedEnable: &diskEncryptedEnableCreateInstanceByEngineReq, RetentionPolicy: &retentionPolicyCreateInstanceByEngineReq, SaslEnabledMechanisms: &listSaslEnabledMechanismsbody, KafkaSecurityProtocol: &kafkaSecurityProtocolCreateInstanceByEngineReq, SslEnable: &sslEnableCreateInstanceByEngineReq, PublicipId: &publicipIdCreateInstanceByEngineReq, EnablePublicip: &enablePublicipCreateInstanceByEngineReq, ProductId: "c6.2u4g.cluster", AvailableZones: listAvailableZonesbody, SubnetId: "********-8fbf-4438-ba71-************", SecurityGroupId: "********-e073-4aad-991f-************", VpcId: "********-9b4a-44c5-a964-************", Password: &passwordCreateInstanceByEngineReq, AccessUser: &accessUserCreateInstanceByEngineReq, StorageSpace: int32(300), BrokerNum: int32(3), EngineVersion: "2.7", Engine: model.GetCreateInstanceByEngineReqEngineEnum().KAFKA, Description: &descriptionCreateInstanceByEngineReq, Name: "kafka-test", } response, err := client.CreateInstanceByEngine(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

• Criação de uma instância anual/mensal do Kafka cuja versão é 2.7, as especificações são 2 vCPUs | 4 GB x 3 e o espaço de armazenamento é de 300 GB

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102

  package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" kafka "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2/region" ) func main() { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). WithProjectId(projectId). Build() client := kafka.NewKafkaClient( kafka.KafkaClientBuilder(). WithRegion(region.ValueOf("<YOUR REGION>")). WithCredential(auth). Build()) request := &model.CreateInstanceByEngineRequest{} request.Engine = model.GetCreateInstanceByEngineRequestEngineEnum().ENGINE chargingModeBssParam:= model.GetBssParamChargingModeEnum().PRE_PAID isAutoPayBssParam:= true periodTypeBssParam:= model.GetBssParamPeriodTypeEnum().MONTH periodNumBssParam:= int32(1) bssParambody := &model.BssParam{ ChargingMode: &chargingModeBssParam, IsAutoPay: &isAutoPayBssParam, PeriodType: &periodTypeBssParam, PeriodNum: &periodNumBssParam, } keyTags:= "aaa" valueTags:= "111" var listTagsbody = []model.TagEntity{ { Key: &keyTags, Value: &valueTags, }, } var listSaslEnabledMechanismsbody = []model.CreateInstanceByEngineReqSaslEnabledMechanisms{ model.GetCreateInstanceByEngineReqSaslEnabledMechanismsEnum().SCRAM_SHA_512, } var listAvailableZonesbody = []string{ "********706d4c1fb0eb72f0********", } vpcClientPlainCreateInstanceByEngineReq:= true archTypeCreateInstanceByEngineReq:= "X86" enterpriseProjectIdCreateInstanceByEngineReq:= "0" enableAutoTopicCreateInstanceByEngineReq:= true retentionPolicyCreateInstanceByEngineReq:= model.GetCreateInstanceByEngineReqRetentionPolicyEnum().TIME_BASE kafkaSecurityProtocolCreateInstanceByEngineReq:= "SASL_SSL" sslEnableCreateInstanceByEngineReq:= true publicipIdCreateInstanceByEngineReq:= "********-88fc-4a8c-86d0-************,********-16af-455d-8d54-************,********-3d69-4367-95ab-************" enablePublicipCreateInstanceByEngineReq:= true passwordCreateInstanceByEngineReq:= "********" accessUserCreateInstanceByEngineReq:= "********" descriptionCreateInstanceByEngineReq:= "" request.Body = &model.CreateInstanceByEngineReq{ BssParam: bssParambody, VpcClientPlain: &vpcClientPlainCreateInstanceByEngineReq, ArchType: &archTypeCreateInstanceByEngineReq, Tags: &listTagsbody, EnterpriseProjectId: &enterpriseProjectIdCreateInstanceByEngineReq, StorageSpecCode: model.GetCreateInstanceByEngineReqStorageSpecCodeEnum().DMS_PHYSICAL_STORAGE_ULTRA, EnableAutoTopic: &enableAutoTopicCreateInstanceByEngineReq, RetentionPolicy: &retentionPolicyCreateInstanceByEngineReq, SaslEnabledMechanisms: &listSaslEnabledMechanismsbody, KafkaSecurityProtocol: &kafkaSecurityProtocolCreateInstanceByEngineReq, SslEnable: &sslEnableCreateInstanceByEngineReq, PublicipId: &publicipIdCreateInstanceByEngineReq, EnablePublicip: &enablePublicipCreateInstanceByEngineReq, ProductId: "c6.2u4g.cluster", AvailableZones: listAvailableZonesbody, SubnetId: "********-8fbf-4438-ba71-************", SecurityGroupId: "********-e073-4aad-991f-************", VpcId: "********-9b4a-44c5-a964-************", Password: &passwordCreateInstanceByEngineReq, AccessUser: &accessUserCreateInstanceByEngineReq, StorageSpace: int32(300), BrokerNum: int32(3), EngineVersion: "2.7", Engine: model.GetCreateInstanceByEngineReqEngineEnum().KAFKA, Description: &descriptionCreateInstanceByEngineReq, Name: "kafka-test1", } response, err := client.CreateInstanceByEngine(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

Mais

Para obter o código de exemplo do SDK de mais linguagens de programação, consulte a guia Código de exemplo no API Explorer. O código de exemplo do SDK pode ser gerado automaticamente.

Códigos de status

Códigos de erro

Consulte Códigos de erro.