Package software.amazon.awscdk.services.dynamodb
Amazon DynamoDB Construct Library
---
AWS CDK v1 has reached End-of-Support on 2023-06-01. This package is no longer being updated, and users should migrate to AWS CDK v2.
For more information on how to migrate, see the Migrating to AWS CDK v2 guide.
Here is a minimal deployable DynamoDB table definition:
Table table = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.build();
Importing existing tables
To import an existing table into your CDK application, use the Table.fromTableName, Table.fromTableArn or Table.fromTableAttributes
factory method. This method accepts table name or table ARN which describes the properties of an already
existing table:
User user; ITable table = Table.fromTableArn(this, "ImportedTable", "arn:aws:dynamodb:us-east-1:111111111:table/my-table"); // now you can just call methods on the table table.grantReadWriteData(user);
If you intend to use the tableStreamArn (including indirectly, for example by creating an
@aws-cdk/aws-lambda-event-source.DynamoEventSource on the imported table), you must use the
Table.fromTableAttributes method and the tableStreamArn property must be populated.
Keys
When a table is defined, you must define it's schema using the partitionKey
(required) and sortKey (optional) properties.
Billing Mode
DynamoDB supports two billing modes:
- PROVISIONED - the default mode where the table and global secondary indexes have configured read and write capacity.
- PAY_PER_REQUEST - on-demand pricing and scaling. You only pay for what you use and there is no read and write capacity for the table or its global secondary indexes.
Table table = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.billingMode(BillingMode.PAY_PER_REQUEST)
.build();
Further reading: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/HowItWorks.ReadWriteCapacityMode.
Table Class
DynamoDB supports two table classes:
- STANDARD - the default mode, and is recommended for the vast majority of workloads.
- STANDARD_INFREQUENT_ACCESS - optimized for tables where storage is the dominant cost.
Table table = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.tableClass(TableClass.STANDARD_INFREQUENT_ACCESS)
.build();
Further reading: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/HowItWorks.TableClasses.html
Configure AutoScaling for your table
You can have DynamoDB automatically raise and lower the read and write capacities of your table by setting up autoscaling. You can use this to either keep your tables at a desired utilization level, or by scaling up and down at pre-configured times of the day:
Auto-scaling is only relevant for tables with the billing mode, PROVISIONED.
IScalableTableAttribute readScaling = table.autoScaleReadCapacity(EnableScalingProps.builder().minCapacity(1).maxCapacity(50).build());
readScaling.scaleOnUtilization(UtilizationScalingProps.builder()
.targetUtilizationPercent(50)
.build());
readScaling.scaleOnSchedule("ScaleUpInTheMorning", ScalingSchedule.builder()
.schedule(Schedule.cron(CronOptions.builder().hour("8").minute("0").build()))
.minCapacity(20)
.build());
readScaling.scaleOnSchedule("ScaleDownAtNight", ScalingSchedule.builder()
.schedule(Schedule.cron(CronOptions.builder().hour("20").minute("0").build()))
.maxCapacity(20)
.build());
Further reading: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/AutoScaling.html https://aws.amazon.com/blogs/database/how-to-use-aws-cloudformation-to-configure-auto-scaling-for-amazon-dynamodb-tables-and-indexes/
Amazon DynamoDB Global Tables
You can create DynamoDB Global Tables by setting the replicationRegions property on a Table:
Table globalTable = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.replicationRegions(List.of("us-east-1", "us-east-2", "us-west-2"))
.build();
When doing so, a CloudFormation Custom Resource will be added to the stack in order to create the replica tables in the selected regions.
The default billing mode for Global Tables is PAY_PER_REQUEST.
If you want to use PROVISIONED,
you have to make sure write auto-scaling is enabled for that Table:
Table globalTable = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.replicationRegions(List.of("us-east-1", "us-east-2", "us-west-2"))
.billingMode(BillingMode.PROVISIONED)
.build();
globalTable.autoScaleWriteCapacity(EnableScalingProps.builder()
.minCapacity(1)
.maxCapacity(10)
.build()).scaleOnUtilization(UtilizationScalingProps.builder().targetUtilizationPercent(75).build());
When adding a replica region for a large table, you might want to increase the timeout for the replication operation:
Table globalTable = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.replicationRegions(List.of("us-east-1", "us-east-2", "us-west-2"))
.replicationTimeout(Duration.hours(2))
.build();
Encryption
All user data stored in Amazon DynamoDB is fully encrypted at rest. When creating a new table, you can choose to encrypt using the following customer master keys (CMK) to encrypt your table:
- AWS owned CMK - By default, all tables are encrypted under an AWS owned customer master key (CMK) in the DynamoDB service account (no additional charges apply).
- AWS managed CMK - AWS KMS keys (one per region) are created in your account, managed, and used on your behalf by AWS DynamoDB (AWS KMS charges apply).
- Customer managed CMK - You have full control over the KMS key used to encrypt the DynamoDB Table (AWS KMS charges apply).
Creating a Table encrypted with a customer managed CMK:
Table table = Table.Builder.create(this, "MyTable")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.encryption(TableEncryption.CUSTOMER_MANAGED)
.build();
// You can access the CMK that was added to the stack on your behalf by the Table construct via:
IKey tableEncryptionKey = table.getEncryptionKey();
You can also supply your own key:
import software.amazon.awscdk.services.kms.*;
Key encryptionKey = Key.Builder.create(this, "Key")
.enableKeyRotation(true)
.build();
Table table = Table.Builder.create(this, "MyTable")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.encryption(TableEncryption.CUSTOMER_MANAGED)
.encryptionKey(encryptionKey)
.build();
In order to use the AWS managed CMK instead, change the code to:
Table table = Table.Builder.create(this, "MyTable")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.encryption(TableEncryption.AWS_MANAGED)
.build();
Get schema of table or secondary indexes
To get the partition key and sort key of the table or indexes you have configured:
Table table; SchemaOptions schema = table.schema(); Attribute partitionKey = schema.getPartitionKey(); Attribute sortKey = schema.getSortKey();
Kinesis Stream
A Kinesis Data Stream can be configured on the DynamoDB table to capture item-level changes.
import software.amazon.awscdk.services.kinesis.*;
Stream stream = new Stream(this, "Stream");
Table table = Table.Builder.create(this, "Table")
.partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
.kinesisStream(stream)
.build();
Deprecated: AWS CDK v1 has reached End-of-Support on 2023-06-01.
This package is no longer being updated, and users should migrate to AWS CDK v2.
For more information on how to migrate, see https://docs.aws.amazon.com/cdk/v2/guide/migrating-v2.html-
ClassDescriptionRepresents an attribute for describing the key schema for the table and indexes.A builder for
AttributeAn implementation forAttributeData types for attributes within a table.DynamoDB's Read/Write capacity modes.A CloudFormationAWS::DynamoDB::GlobalTable.Represents an attribute for describing the key schema for the table and indexes.A builder forCfnGlobalTable.AttributeDefinitionPropertyAn implementation forCfnGlobalTable.AttributeDefinitionPropertyA fluent builder forCfnGlobalTable.Configures a scalable target and an autoscaling policy for a table or global secondary index's read or write capacity.A builder forCfnGlobalTable.CapacityAutoScalingSettingsPropertyAn implementation forCfnGlobalTable.CapacityAutoScalingSettingsPropertyConfigures contributor insights settings for a replica or one of its indexes.A builder forCfnGlobalTable.ContributorInsightsSpecificationPropertyAn implementation forCfnGlobalTable.ContributorInsightsSpecificationPropertyAllows you to specify a global secondary index for the global table.A builder forCfnGlobalTable.GlobalSecondaryIndexPropertyAn implementation forCfnGlobalTable.GlobalSecondaryIndexPropertyRepresents a single element of a key schema.A builder forCfnGlobalTable.KeySchemaPropertyAn implementation forCfnGlobalTable.KeySchemaPropertyThe Kinesis Data Streams configuration for the specified global table replica.A builder forCfnGlobalTable.KinesisStreamSpecificationPropertyAn implementation forCfnGlobalTable.KinesisStreamSpecificationPropertyRepresents the properties of a local secondary index.A builder forCfnGlobalTable.LocalSecondaryIndexPropertyAn implementation forCfnGlobalTable.LocalSecondaryIndexPropertyRepresents the settings used to enable point in time recovery.A builder forCfnGlobalTable.PointInTimeRecoverySpecificationPropertyAn implementation forCfnGlobalTable.PointInTimeRecoverySpecificationPropertyRepresents attributes that are copied (projected) from the table into an index.A builder forCfnGlobalTable.ProjectionPropertyAn implementation forCfnGlobalTable.ProjectionPropertyAllows you to specify the read capacity settings for a replica table or a replica global secondary index when theBillingModeis set toPROVISIONED.A builder forCfnGlobalTable.ReadProvisionedThroughputSettingsPropertyAn implementation forCfnGlobalTable.ReadProvisionedThroughputSettingsPropertyRepresents the properties of a global secondary index that can be set on a per-replica basis.An implementation forCfnGlobalTable.ReplicaGlobalSecondaryIndexSpecificationPropertyDefines settings specific to a single replica of a global table.A builder forCfnGlobalTable.ReplicaSpecificationPropertyAn implementation forCfnGlobalTable.ReplicaSpecificationPropertyAllows you to specify a KMS key identifier to be used for server-side encryption.A builder forCfnGlobalTable.ReplicaSSESpecificationPropertyAn implementation forCfnGlobalTable.ReplicaSSESpecificationPropertyRepresents the settings used to enable server-side encryption.A builder forCfnGlobalTable.SSESpecificationPropertyAn implementation forCfnGlobalTable.SSESpecificationPropertyRepresents the DynamoDB Streams configuration for a table in DynamoDB.A builder forCfnGlobalTable.StreamSpecificationPropertyAn implementation forCfnGlobalTable.StreamSpecificationPropertyDefines a target tracking scaling policy.An implementation forCfnGlobalTable.TargetTrackingScalingPolicyConfigurationPropertyRepresents the settings used to enable or disable Time to Live (TTL) for the specified table.A builder forCfnGlobalTable.TimeToLiveSpecificationPropertyAn implementation forCfnGlobalTable.TimeToLiveSpecificationPropertySpecifies an auto scaling policy for write capacity.An implementation forCfnGlobalTable.WriteProvisionedThroughputSettingsPropertyProperties for defining aCfnGlobalTable.A builder forCfnGlobalTablePropsAn implementation forCfnGlobalTablePropsA CloudFormationAWS::DynamoDB::Table.Represents an attribute for describing the key schema for the table and indexes.A builder forCfnTable.AttributeDefinitionPropertyAn implementation forCfnTable.AttributeDefinitionPropertyA fluent builder forCfnTable.The settings used to enable or disable CloudWatch Contributor Insights.A builder forCfnTable.ContributorInsightsSpecificationPropertyAn implementation forCfnTable.ContributorInsightsSpecificationPropertyThe options for imported source files in CSV format.A builder forCfnTable.CsvPropertyAn implementation forCfnTable.CsvPropertyRepresents the properties of a global secondary index.A builder forCfnTable.GlobalSecondaryIndexPropertyAn implementation forCfnTable.GlobalSecondaryIndexPropertySpecifies the properties of data being imported from the S3 bucket source to the table.A builder forCfnTable.ImportSourceSpecificationPropertyAn implementation forCfnTable.ImportSourceSpecificationPropertyThe format options for the data that was imported into the target table.A builder forCfnTable.InputFormatOptionsPropertyAn implementation forCfnTable.InputFormatOptionsPropertyRepresents a single element of a key schema.A builder forCfnTable.KeySchemaPropertyAn implementation forCfnTable.KeySchemaPropertyThe Kinesis Data Streams configuration for the specified table.A builder forCfnTable.KinesisStreamSpecificationPropertyAn implementation forCfnTable.KinesisStreamSpecificationPropertyRepresents the properties of a local secondary index.A builder forCfnTable.LocalSecondaryIndexPropertyAn implementation forCfnTable.LocalSecondaryIndexPropertyThe settings used to enable point in time recovery.A builder forCfnTable.PointInTimeRecoverySpecificationPropertyAn implementation forCfnTable.PointInTimeRecoverySpecificationPropertyRepresents attributes that are copied (projected) from the table into an index.A builder forCfnTable.ProjectionPropertyAn implementation forCfnTable.ProjectionPropertyThroughput for the specified table, which consists of values forReadCapacityUnitsandWriteCapacityUnits.A builder forCfnTable.ProvisionedThroughputPropertyAn implementation forCfnTable.ProvisionedThroughputPropertyThe S3 bucket that is being imported from.A builder forCfnTable.S3BucketSourcePropertyAn implementation forCfnTable.S3BucketSourcePropertyRepresents the settings used to enable server-side encryption.A builder forCfnTable.SSESpecificationPropertyAn implementation forCfnTable.SSESpecificationPropertyRepresents the DynamoDB Streams configuration for a table in DynamoDB.A builder forCfnTable.StreamSpecificationPropertyAn implementation forCfnTable.StreamSpecificationPropertyRepresents the settings used to enable or disable Time to Live (TTL) for the specified table.A builder forCfnTable.TimeToLiveSpecificationPropertyAn implementation forCfnTable.TimeToLiveSpecificationPropertyProperties for defining aCfnTable.A builder forCfnTablePropsAn implementation forCfnTablePropsProperties for enabling DynamoDB capacity scaling.A builder forEnableScalingPropsAn implementation forEnableScalingPropsProperties for a global secondary index.A builder forGlobalSecondaryIndexPropsAn implementation forGlobalSecondaryIndexPropsInterface for scalable attributes.Internal default implementation forIScalableTableAttribute.A proxy class which represents a concrete javascript instance of this type.An interface that represents a DynamoDB Table - either created with the CDK, or an existing one.Internal default implementation forITable.A proxy class which represents a concrete javascript instance of this type.Properties for a local secondary index.A builder forLocalSecondaryIndexPropsAn implementation forLocalSecondaryIndexPropsSupported DynamoDB table operations.The set of attributes that are projected into the index.Represents the table schema attributes.A builder forSchemaOptionsAn implementation forSchemaOptionsProperties for a secondary index.A builder forSecondaryIndexPropsAn implementation forSecondaryIndexPropsWhen an item in the table is modified, StreamViewType determines what information is written to the stream for this table.Options for configuring a system errors metric that considers multiple operations.A builder forSystemErrorsForOperationsMetricOptionsAn implementation forSystemErrorsForOperationsMetricOptionsProvides a DynamoDB table.A fluent builder forTable.Reference to a dynamodb table.A builder forTableAttributesAn implementation forTableAttributesDynamoDB's table class.What kind of server-side encryption to apply to this table.Properties of a DynamoDB Table.A builder forTableOptionsAn implementation forTableOptionsProperties for a DynamoDB Table.A builder forTablePropsAn implementation forTablePropsProperties for enabling DynamoDB utilization tracking.A builder forUtilizationScalingPropsAn implementation forUtilizationScalingProps