OpenSearch Esempi di servizi che utilizzano SDK per Kotlin - AWS SDK per Kotlin

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

OpenSearch Esempi di servizi che utilizzano SDK per Kotlin

Gli esempi di codice seguenti mostrano come eseguire azioni e implementare scenari comuni utilizzando l' AWS SDK per Kotlin con il Servizio. OpenSearch

Le operazioni sono estratti di codice da programmi più grandi e devono essere eseguite nel contesto. Sebbene le operazioni mostrino come richiamare le singole funzioni del servizio, è possibile visualizzarle contestualizzate negli scenari correlati.

Ogni esempio include un collegamento al codice sorgente completo, dove è possibile trovare le istruzioni su come configurare ed eseguire il codice nel contesto.

Argomenti

Azioni

Il codice di esempio seguente mostra come utilizzareCreateDomain.

SDK per Kotlin
Nota

C'è altro da fare GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel Repository di esempi di codice AWS.

suspend fun createNewDomain(domainNameVal: String?) { val clusterConfigOb = ClusterConfig { dedicatedMasterEnabled = true dedicatedMasterCount = 3 dedicatedMasterType = OpenSearchPartitionInstanceType.fromValue("t2.small.search") instanceType = OpenSearchPartitionInstanceType.fromValue("t2.small.search") instanceCount = 5 } val ebsOptionsOb = EbsOptions { ebsEnabled = true volumeSize = 10 volumeType = VolumeType.Gp2 } val encryptionOptionsOb = NodeToNodeEncryptionOptions { enabled = true } val request = CreateDomainRequest { domainName = domainNameVal engineVersion = "OpenSearch_1.0" clusterConfig = clusterConfigOb ebsOptions = ebsOptionsOb nodeToNodeEncryptionOptions = encryptionOptionsOb } println("Sending domain creation request...") OpenSearchClient { region = "us-east-1" }.use { searchClient -> val createResponse = searchClient.createDomain(request) println("Domain status is ${createResponse.domainStatus}") println("Domain Id is ${createResponse.domainStatus?.domainId}") } }
  • Per i dettagli sull'API, CreateDomainconsulta AWS SDK for Kotlin API reference.

Il codice di esempio seguente mostra come utilizzareDeleteDomain.

SDK per Kotlin
Nota

C'è altro da fare GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel Repository di esempi di codice AWS.

suspend fun deleteSpecificDomain(domainNameVal: String) { val request = DeleteDomainRequest { domainName = domainNameVal } OpenSearchClient { region = "us-east-1" }.use { searchClient -> searchClient.deleteDomain(request) println("$domainNameVal was successfully deleted.") } }
  • Per i dettagli sull'API, DeleteDomainconsulta AWS SDK for Kotlin API reference.

Il codice di esempio seguente mostra come utilizzareListDomainNames.

SDK per Kotlin
Nota

C'è altro da fare GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel Repository di esempi di codice AWS.

suspend fun listAllDomains() { OpenSearchClient { region = "us-east-1" }.use { searchClient -> val response: ListDomainNamesResponse = searchClient.listDomainNames(ListDomainNamesRequest {}) response.domainNames?.forEach { domain -> println("Domain name is " + domain.domainName) } } }
  • Per i dettagli sull'API, ListDomainNamesconsulta AWS SDK for Kotlin API reference.

Il codice di esempio seguente mostra come utilizzareUpdateDomainConfig.

SDK per Kotlin
Nota

C'è altro da fare GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel Repository di esempi di codice AWS.

suspend fun updateSpecificDomain(domainNameVal: String?) { val clusterConfigOb = ClusterConfig { instanceCount = 3 } val request = UpdateDomainConfigRequest { domainName = domainNameVal clusterConfig = clusterConfigOb } println("Sending domain update request...") OpenSearchClient { region = "us-east-1" }.use { searchClient -> val updateResponse = searchClient.updateDomainConfig(request) println("Domain update response from Amazon OpenSearch Service:") println(updateResponse.toString()) } }