Crie uma tabela do DynamoDB com um índice secundário global usando o SDK da AWS. - Exemplos de código do AWS SDK

Há mais exemplos do AWS SDK disponíveis no repositório do GitHub Documento de Exemplos do AWS SDK.

Crie uma tabela do DynamoDB com um índice secundário global usando o SDK da AWS.

O código de exemplo a seguir mostra como criar uma tabela com um índice secundário global.

Java
SDK para Java 2.x

Crie uma tabela do DynamoDB com um índice secundário global usando o AWS SDK for Java 2.x.

import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider; import software.amazon.awssdk.core.waiters.WaiterResponse; import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.services.dynamodb.DynamoDbClient; import software.amazon.awssdk.services.dynamodb.model.AttributeDefinition; import software.amazon.awssdk.services.dynamodb.model.AttributeValue; import software.amazon.awssdk.services.dynamodb.model.CreateTableRequest; import software.amazon.awssdk.services.dynamodb.model.DeleteTableRequest; import software.amazon.awssdk.services.dynamodb.model.DescribeTableRequest; import software.amazon.awssdk.services.dynamodb.model.DescribeTableResponse; import software.amazon.awssdk.services.dynamodb.model.DynamoDbException; import software.amazon.awssdk.services.dynamodb.model.GlobalSecondaryIndex; import software.amazon.awssdk.services.dynamodb.model.KeySchemaElement; import software.amazon.awssdk.services.dynamodb.model.KeyType; import software.amazon.awssdk.services.dynamodb.model.Projection; import software.amazon.awssdk.services.dynamodb.model.ProjectionType; import software.amazon.awssdk.services.dynamodb.model.ProvisionedThroughput; import software.amazon.awssdk.services.dynamodb.model.PutItemRequest; import software.amazon.awssdk.services.dynamodb.model.QueryRequest; import software.amazon.awssdk.services.dynamodb.model.QueryResponse; import software.amazon.awssdk.services.dynamodb.model.ScalarAttributeType; import software.amazon.awssdk.services.dynamodb.waiters.DynamoDbWaiter; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public void createTable() { try { // Attribute definitions final List<AttributeDefinition> attributeDefinitions = new ArrayList<>(); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(ISSUE_ID_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(TITLE_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(CREATE_DATE_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(DUE_DATE_ATTR) .attributeType(ScalarAttributeType.S) .build()); // Key schema for table final List<KeySchemaElement> tableKeySchema = new ArrayList<>(); tableKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.HASH) .build()); // Partition key tableKeySchema.add(KeySchemaElement.builder() .attributeName(TITLE_ATTR) .keyType(KeyType.RANGE) .build()); // Sort key // Initial provisioned throughput settings for the indexes final ProvisionedThroughput ptIndex = ProvisionedThroughput.builder() .readCapacityUnits(1L) .writeCapacityUnits(1L) .build(); // CreateDateIndex final List<KeySchemaElement> createDateKeySchema = new ArrayList<>(); createDateKeySchema.add(KeySchemaElement.builder() .attributeName(CREATE_DATE_ATTR) .keyType(KeyType.HASH) .build()); createDateKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.RANGE) .build()); final Projection createDateProjection = Projection.builder() .projectionType(ProjectionType.INCLUDE) .nonKeyAttributes(DESCRIPTION_ATTR, STATUS_ATTR) .build(); final GlobalSecondaryIndex createDateIndex = GlobalSecondaryIndex.builder() .indexName(CREATE_DATE_INDEX) .keySchema(createDateKeySchema) .projection(createDateProjection) .provisionedThroughput(ptIndex) .build(); // TitleIndex final List<KeySchemaElement> titleKeySchema = new ArrayList<>(); titleKeySchema.add(KeySchemaElement.builder() .attributeName(TITLE_ATTR) .keyType(KeyType.HASH) .build()); titleKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.RANGE) .build()); final Projection titleProjection = Projection.builder().projectionType(ProjectionType.KEYS_ONLY).build(); final GlobalSecondaryIndex titleIndex = GlobalSecondaryIndex.builder() .indexName(TITLE_INDEX) .keySchema(titleKeySchema) .projection(titleProjection) .provisionedThroughput(ptIndex) .build(); // DueDateIndex final List<KeySchemaElement> dueDateKeySchema = new ArrayList<>(); dueDateKeySchema.add(KeySchemaElement.builder() .attributeName(DUE_DATE_ATTR) .keyType(KeyType.HASH) .build()); final Projection dueDateProjection = Projection.builder().projectionType(ProjectionType.ALL).build(); final GlobalSecondaryIndex dueDateIndex = GlobalSecondaryIndex.builder() .indexName(DUE_DATE_INDEX) .keySchema(dueDateKeySchema) .projection(dueDateProjection) .provisionedThroughput(ptIndex) .build(); final CreateTableRequest createTableRequest = CreateTableRequest.builder() .tableName(TABLE_NAME) .keySchema(tableKeySchema) .attributeDefinitions(attributeDefinitions) .globalSecondaryIndexes(createDateIndex, titleIndex, dueDateIndex) .provisionedThroughput(ProvisionedThroughput.builder() .readCapacityUnits(1L) .writeCapacityUnits(1L) .build()) .build(); System.out.println("Creating table " + TABLE_NAME + "..."); dynamoDbClient.createTable(createTableRequest); // Wait for table to become active System.out.println("Waiting for " + TABLE_NAME + " to become ACTIVE..."); final DynamoDbWaiter waiter = dynamoDbClient.waiter(); final DescribeTableRequest describeTableRequest = DescribeTableRequest.builder().tableName(TABLE_NAME).build(); final WaiterResponse<DescribeTableResponse> waiterResponse = waiter.waitUntilTableExists(describeTableRequest); waiterResponse.matched().response().ifPresent(response -> System.out.println("Table is now ready for use")); } catch (DynamoDbException e) { System.err.println("Error creating table: " + e.getMessage()); e.printStackTrace(); } }
  • Consulte detalhes da API em CreateTable na Referência da API AWS SDK for Java 2.x.