Tutorial: criar uma tabela global
Esta seção descreve como criar uma tabela global usando o console do Amazon DynamoDB ou a AWS Command Line Interface (AWS CLI).
Tópicos
Siga estas etapas para criar uma tabela global usando o AWS Management Console. O exemplo a seguir cria uma tabela global com tabelas-réplica nos Estados Unidos e na Europa.
-
Abra o console do DynamoDB em https://console.aws.amazon.com/dynamodb/
. Para este exemplo, escolha a região Leste dos EUA (Ohio). -
No painel de navegação, no lado esquerdo do console, selecione Tables (Tabelas).
-
Selecione Create Table (Criar tabela).
-
Na página Criar tabela, faça o seguinte:
-
Em Table name (Nome da tabela), insira
Music
. -
Em Partition key, (Chave de partição), insira
Artist
. -
Em Chave de classificação, insira
SongTitle
. -
Mantenha a seleção padrão de String para a Chave de partição e a Chave de classificação.
-
Mantenha as demais seleções padrão na página e escolha Criar tabela.
Essa nova tabela serve como a primeira tabela de réplica em uma nova tabela global. Ela é o protótipo das outras tabelas de réplica que serão adicionadas posteriormente.
-
-
Na página Tabelas, escolha a tabela Music recém-criada e faça o seguinte:
-
Selecione a guia Tabelas globais e escolha Criar réplica.
-
Na lista suspensa Regiões de replicação disponíveis, escolha US West (Oregon) us-west-2 (Oeste dos EUA [Oregon], us-west-2).
O console faz uma verificação para garantir que não exista nenhuma tabela com o mesmo nome na região selecionada. Se existir uma tabela com o mesmo nome, será necessário excluir a tabela existente para criar outra tabela-réplica nessa região.
-
Escolha Create replica (Criar réplica). Isso inicia o processo de criação da tabela na região Oeste dos EUA (Oregon), us-west-2.
A guia Tabelas globais da tabela Music (e de qualquer outra tabela de réplica) mostra que a tabela foi replicada em várias regiões.
-
Adicione outra região para que a tabela global seja replicada e sincronizada nos Estados Unidos e na Europa. Para fazer isso, repita a etapa 5.b, mas desta vez especifique Europe (Frankfurt) eu-central-1 (Europa [Frankfurt], eu-central-1) em vez de US West (Oregon) us-west-2 (Oeste dos EUA [Oregon], us-west-2).
-
-
Continue usando o AWS Management Console na região Leste dos EUA (Ohio). Então, faça o seguinte:
-
Escolha Explore table items (Explorar itens da tabela).
-
Selecione Create Item (Criar item).
-
Em Artist (Artista), insira
item_1
. -
Em SongTitle (Nome da música), insira
Song Value 1
. -
Para salvar o item, selecione Criar item.
-
-
Pouco tempo depois o item será replicado em todas as três regiões da tabela global. Para verificar, no console, no seletor de regiões no canto superior direito do console, selecione Europe (Frankfurt) (Europa (Frankfurt)). A tabela Music na região Europa (Frankfurt) deve conter o novo item.
-
Repita a etapa 7 e escolha Oeste dos EUA (Oregon) para verificar a replicação nessa região.
Siga estas etapas para criar uma tabela global Music
usando a AWS CLI. O exemplo a seguir cria uma tabela global com tabelas-réplica nos Estados Unidos e na Europa.
-
Crie uma nova tabela (
Music
) na região Leste dos EUA (Ohio), com o DynamoDB Streams habilitado (NEW_AND_OLD_IMAGES
).aws dynamodb create-table \ --table-name Music \ --attribute-definitions \ AttributeName=Artist,AttributeType=S \ AttributeName=SongTitle,AttributeType=S \ --key-schema \ AttributeName=Artist,KeyType=HASH \ AttributeName=SongTitle,KeyType=RANGE \ --billing-mode PAY_PER_REQUEST \ --stream-specification StreamEnabled=true,StreamViewType=NEW_AND_OLD_IMAGES \ --region us-east-2
-
Crie uma tabela
Music
idêntica na região Leste dos EUA (Norte da Virgínia).aws dynamodb update-table --table-name Music --cli-input-json \ '{ "ReplicaUpdates": [ { "Create": { "RegionName": "us-east-1" } } ] }' \ --region=us-east-2
-
Repita a etapa 2 para criar uma tabela na região Europa (Irlanda) (eu-west-1).
-
É possível visualizar a lista de réplicas criadas usando
describe-table
.aws dynamodb describe-table --table-name Music --region us-east-2
-
Para verificar se a replicação está funcionando, adicione um novo item à tabela
Music
na região Leste dos EUA (Ohio).aws dynamodb put-item \ --table-name Music \ --item '{"Artist": {"S":"item_1"},"SongTitle": {"S":"Song Value 1"}}' \ --region us-east-2
-
Aguarde alguns segundos e verifique se o item foi replicado com êxito nas regiões Leste dos EUA (Norte da Virgínia) e Europa (Irlanda).
aws dynamodb get-item \ --table-name Music \ --key '{"Artist": {"S":"item_1"},"SongTitle": {"S":"Song Value 1"}}' \ --region us-east-1
aws dynamodb get-item \ --table-name Music \ --key '{"Artist": {"S":"item_1"},"SongTitle": {"S":"Song Value 1"}}' \ --region eu-west-1
-
Exclua a tabela-réplica na região Europa (Irlanda).
aws dynamodb update-table --table-name Music --cli-input-json \ '{ "ReplicaUpdates": [ { "Delete": { "RegionName": "eu-west-1" } } ] }'
O exemplo de código Java a seguir cria uma tabela Music
na região Europa (Irlanda) e, depois, cria uma réplica na região Ásia-Pacífico (Seul).
package com.amazonaws.codesamples.gtv2 import java.util.logging.Logger; import com.amazonaws.auth.profile.ProfileCredentialsProvider; import com.amazonaws.regions.Regions; import com.amazonaws.services.dynamodbv2.AmazonDynamoDB; import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder; import com.amazonaws.services.dynamodbv2.model.AmazonDynamoDBException; import com.amazonaws.services.dynamodbv2.model.AttributeDefinition; import com.amazonaws.services.dynamodbv2.model.BillingMode; import com.amazonaws.services.dynamodbv2.model.CreateReplicationGroupMemberAction; import com.amazonaws.services.dynamodbv2.model.CreateTableRequest; import com.amazonaws.services.dynamodbv2.model.DescribeTableRequest; import com.amazonaws.services.dynamodbv2.model.GlobalSecondaryIndex; import com.amazonaws.services.dynamodbv2.model.KeySchemaElement; import com.amazonaws.services.dynamodbv2.model.KeyType; import com.amazonaws.services.dynamodbv2.model.Projection; import com.amazonaws.services.dynamodbv2.model.ProjectionType; import com.amazonaws.services.dynamodbv2.model.ProvisionedThroughput; import com.amazonaws.services.dynamodbv2.model.ProvisionedThroughputOverride; import com.amazonaws.services.dynamodbv2.model.ReplicaGlobalSecondaryIndex; import com.amazonaws.services.dynamodbv2.model.ReplicationGroupUpdate; import com.amazonaws.services.dynamodbv2.model.ScalarAttributeType; import com.amazonaws.services.dynamodbv2.model.StreamSpecification; import com.amazonaws.services.dynamodbv2.model.StreamViewType; import com.amazonaws.services.dynamodbv2.model.UpdateTableRequest; import com.amazonaws.waiters.WaiterParameters; public class App { private final static Logger LOGGER = Logger.getLogger(Logger.GLOBAL_LOGGER_NAME); public static void main( String[] args ) { String tableName = "Music"; String indexName = "index1"; Regions calledRegion = Regions.EU_WEST_1; Regions destRegion = Regions.AP_NORTHEAST_2; AmazonDynamoDB ddbClient = AmazonDynamoDBClientBuilder.standard() .withCredentials(new ProfileCredentialsProvider("default")) .withRegion(calledRegion) .build(); LOGGER.info("Creating a regional table - TableName: " + tableName +", IndexName: " + indexName + " ....."); ddbClient.createTable(new CreateTableRequest() .withTableName(tableName) .withAttributeDefinitions( new AttributeDefinition() .withAttributeName("Artist").withAttributeType(ScalarAttributeType.S), new AttributeDefinition() .withAttributeName("SongTitle").withAttributeType(ScalarAttributeType.S)) .withKeySchema( new KeySchemaElement().withAttributeName("Artist").withKeyType(KeyType.HASH), new KeySchemaElement().withAttributeName("SongTitle").withKeyType(KeyType.RANGE)) .withBillingMode(BillingMode.PAY_PER_REQUEST) .withGlobalSecondaryIndexes(new GlobalSecondaryIndex() .withIndexName(indexName) .withKeySchema(new KeySchemaElement() .withAttributeName("SongTitle") .withKeyType(KeyType.HASH)) .withProjection(new Projection().withProjectionType(ProjectionType.ALL))) .withStreamSpecification(new StreamSpecification() .withStreamEnabled(true) .withStreamViewType(StreamViewType.NEW_AND_OLD_IMAGES))); LOGGER.info("Waiting for ACTIVE table status ....."); ddbClient.waiters().tableExists().run(new WaiterParameters<>(new DescribeTableRequest(tableName))); LOGGER.info("Testing parameters for adding a new Replica in " + destRegion + " ....."); CreateReplicationGroupMemberAction createReplicaAction = new CreateReplicationGroupMemberAction() .withRegionName(destRegion.getName()) .withGlobalSecondaryIndexes(new ReplicaGlobalSecondaryIndex() .withIndexName(indexName) .withProvisionedThroughputOverride(new ProvisionedThroughputOverride() .withReadCapacityUnits(15L))); ddbClient.updateTable(new UpdateTableRequest() .withTableName(tableName) .withReplicaUpdates(new ReplicationGroupUpdate() .withCreate(createReplicaAction.withKMSMasterKeyId(null)))); } }