diff --git a/cdk/lib/dax-benchmarking-stack.ts b/cdk/lib/dax-benchmarking-stack.ts index 917868f..60eb2bd 100644 --- a/cdk/lib/dax-benchmarking-stack.ts +++ b/cdk/lib/dax-benchmarking-stack.ts @@ -27,24 +27,24 @@ export class DaxBenchmarkingStack extends Stack { const { instanceRole, instance } = new DaxBastionHost(this, `${user}-dax-bastion-host`, environmentProps, daxSecurityGroup); const daxClusterName = `${user}-high-velocity`; - const daxFullAccessPolicy = new PolicyStatement({ - effect: Effect.ALLOW, - actions: [ - "dynamodb:BatchGetItem", - "dynamodb:GetItem", - "dynamodb:Query", - "dynamodb:Scan", - "dynamodb:BatchWriteItem", - "dynamodb:DeleteItem", - "dynamodb:PutItem", - "dynamodb:UpdateItem", - "dynamodb:DescribeLimits", - "dynamodb:DescribeTimeToLive", - "dynamodb:DescribeTable", - "dynamodb:ListTables" - ], - resources: [table.tableArn] - }); + const daxFullAccessPolicy = new PolicyStatement({ + effect: Effect.ALLOW, + actions: [ + "dynamodb:BatchGetItem", + "dynamodb:GetItem", + "dynamodb:Query", + "dynamodb:Scan", + "dynamodb:BatchWriteItem", + "dynamodb:DeleteItem", + "dynamodb:PutItem", + "dynamodb:UpdateItem", + "dynamodb:DescribeLimits", + "dynamodb:DescribeTimeToLive", + "dynamodb:DescribeTable", + "dynamodb:ListTables" + ], + resources: [table.tableArn] + }); const daxServiceRole = new Role(this, `${daxClusterName}-role`, { assumedBy: new ServicePrincipal("dax.amazonaws.com"), diff --git a/scripts/randomly-generate-high-velocity-data.sh b/scripts/randomly-generate-high-velocity-data.sh index e5d75e4..aff9cc8 100755 --- a/scripts/randomly-generate-high-velocity-data.sh +++ b/scripts/randomly-generate-high-velocity-data.sh @@ -164,13 +164,11 @@ fi parse-arguments "$@" show-properties -declare -i i=0 declare -i items_written=0 while [[ $items_written -lt $ITEMS ]]; do log-info "Writing 25 entries to DynamoDB..." aws dynamodb batch-write-item --request-items "$(generate-batch-json)" log-info 'Entries Written!' - ((i++)) ((items_written+=25)) log-info "Total entries written: $items_written" log-info "Sleeping for 2 seconds to avoid the partition throughput limits..."