pub-technology · pub-technology · Aug 7, 2021
diff --git a/infra/README.md b/infra/README.md
@@ -101,3 +101,16 @@ aws --endpoint-url=http://localhost:4566 sns list-topics
 
 ```
 
+### How to verify our Dynamo DB Table setup
+```shell
+
+aws --endpoint-url=http://localhost:4566 dynamodb list-tables
+
+{
+    "TableNames": [
+        "test-development"
+    ]
+}
+
+aws --endpoint-url=http://localhost:4566 dynamodb describe-table --table-name test-development > test-development.json
+```
diff --git a/infra/lib/ApplicationStack.ts b/infra/lib/ApplicationStack.ts
@@ -1,7 +1,11 @@
-import * as sns from '@aws-cdk/aws-sns';
-import * as subs from '@aws-cdk/aws-sns-subscriptions';
-import * as sqs from '@aws-cdk/aws-sqs';
-import * as cdk from '@aws-cdk/core';
+import * as sns from "@aws-cdk/aws-sns";
+import * as subs from "@aws-cdk/aws-sns-subscriptions";
+import * as sqs from "@aws-cdk/aws-sqs";
+import * as cdk from "@aws-cdk/core";
+import * as dynamodb from "@aws-cdk/aws-dynamodb";
+import { GlobalSecondaryIndexProps, StreamViewType } from "@aws-cdk/aws-dynamodb/lib/table";
+import { createStandardGSI } from "../utils/createGlobalSecondaryIndex";
+
 
 export class ApplicationStack extends cdk.Stack {
   constructor(scope: cdk.App, id: string, props?: cdk.StackProps) {
@@ -12,7 +16,26 @@ export class ApplicationStack extends cdk.Stack {
     });
 
     const topic = new sns.Topic(this, 'SampleAppTopic');
-
     topic.addSubscription(new subs.SqsSubscription(queue));
+
+    const table = new dynamodb.Table(this, 'Table', {
+      tableName: 'test-development',
+      // partition key & sort key
+      partitionKey: { name: 'pk', type: dynamodb.AttributeType.STRING },
+      sortKey: {name : 'sk', type: dynamodb.AttributeType.STRING},
+      // ProvisionedThroughput
+      readCapacity: 5,
+      writeCapacity: 5,
+      // StreamSpecification
+      stream: StreamViewType.NEW_AND_OLD_IMAGES,
+    });
+
+    const pk2Sk2Index: GlobalSecondaryIndexProps = createStandardGSI('pk2-sk2-index', 'pk2', 'sk2');
+    const pk3Sk3Index: GlobalSecondaryIndexProps = createStandardGSI('pk3-sk3-index', 'pk3', 'sk3');
+    const pk4Sk4Index: GlobalSecondaryIndexProps = createStandardGSI('pk4-sk4-index', 'pk4', 'sk4');
+
+    table.addGlobalSecondaryIndex(pk2Sk2Index);
+    table.addGlobalSecondaryIndex(pk3Sk3Index);
+    table.addGlobalSecondaryIndex(pk4Sk4Index);
   }
 }
diff --git a/infra/localstack/.localstack/data/dynamodb/test_us-east-1.db b/infra/localstack/.localstack/data/dynamodb/test_us-east-1.db
diff --git a/infra/localstack/.localstack/data/kinesis/000007.log b/infra/localstack/.localstack/data/kinesis/000007.log
diff --git a/infra/localstack/.localstack/data/recorded_api_calls.json b/infra/localstack/.localstack/data/recorded_api_calls.json
diff --git a/infra/package.json b/infra/package.json
@@ -24,6 +24,7 @@
     "@aws-cdk/aws-sns": "1.117.0",
     "@aws-cdk/aws-sns-subscriptions": "1.117.0",
     "@aws-cdk/aws-sqs": "1.117.0",
-    "@aws-cdk/core": "1.117.0"
+    "@aws-cdk/core": "1.117.0",
+    "@aws-cdk/aws-dynamodb": "1.117.0"
   }
 }
diff --git a/infra/setup/dynamo-table.json b/infra/setup/dynamo-table.json
@@ -0,0 +1,117 @@
+{
+  "AttributeDefinitions": [
+    {
+      "AttributeName": "pk",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "pk2",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "pk3",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "pk4",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "sk",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "sk2",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "sk3",
+      "AttributeType": "S"
+    },
+    {
+      "AttributeName": "sk4",
+      "AttributeType": "S"
+    }
+  ],
+  "TableName": "GlobalSafetyCheck-development",
+  "KeySchema": [
+    {
+      "AttributeName": "pk",
+      "KeyType": "HASH"
+    },
+    {
+      "AttributeName": "sk",
+      "KeyType": "RANGE"
+    }
+  ],
+  "ProvisionedThroughput": {
+    "ReadCapacityUnits": 5,
+    "WriteCapacityUnits": 5
+  },
+  "GlobalSecondaryIndexes": [
+    {
+      "IndexName": "pk3-sk3-index",
+      "KeySchema": [
+        {
+          "AttributeName": "pk3",
+          "KeyType": "HASH"
+        },
+        {
+          "AttributeName": "sk3",
+          "KeyType": "RANGE"
+        }
+      ],
+      "Projection": {
+        "ProjectionType": "ALL"
+      },
+      "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+      }
+    },
+    {
+      "IndexName": "pk2-sk2-index",
+      "KeySchema": [
+        {
+          "AttributeName": "pk2",
+          "KeyType": "HASH"
+        },
+        {
+          "AttributeName": "sk2",
+          "KeyType": "RANGE"
+        }
+      ],
+      "Projection": {
+        "ProjectionType": "ALL"
+      },
+      "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+      }
+    },
+    {
+      "IndexName": "pk4-sk4-index",
+      "KeySchema": [
+        {
+          "AttributeName": "pk4",
+          "KeyType": "HASH"
+        },
+        {
+          "AttributeName": "sk4",
+          "KeyType": "RANGE"
+        }
+      ],
+      "Projection": {
+        "ProjectionType": "ALL"
+      },
+      "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+      }
+    }
+  ],
+  "StreamSpecification": {
+    "StreamEnabled": true,
+    "StreamViewType": "NEW_AND_OLD_IMAGES"
+  }
+}
diff --git a/infra/setup/test-development.json b/infra/setup/test-development.json
@@ -0,0 +1,141 @@
+{
+    "Table": {
+        "AttributeDefinitions": [
+            {
+                "AttributeName": "pk",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "sk",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "pk2",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "sk2",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "pk3",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "sk3",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "pk4",
+                "AttributeType": "S"
+            },
+            {
+                "AttributeName": "sk4",
+                "AttributeType": "S"
+            }
+        ],
+        "TableName": "test-development",
+        "KeySchema": [
+            {
+                "AttributeName": "pk",
+                "KeyType": "HASH"
+            },
+            {
+                "AttributeName": "sk",
+                "KeyType": "RANGE"
+            }
+        ],
+        "TableStatus": "ACTIVE",
+        "CreationDateTime": "2021-08-07T19:23:03.601000+07:00",
+        "ProvisionedThroughput": {
+            "LastIncreaseDateTime": "1970-01-01T07:00:00+07:00",
+            "LastDecreaseDateTime": "1970-01-01T07:00:00+07:00",
+            "NumberOfDecreasesToday": 0,
+            "ReadCapacityUnits": 5,
+            "WriteCapacityUnits": 5
+        },
+        "TableSizeBytes": 0,
+        "ItemCount": 0,
+        "TableArn": "arn:aws:dynamodb:us-east-1:000000000000:table/test-development",
+        "GlobalSecondaryIndexes": [
+            {
+                "IndexName": "pk3-sk3-index",
+                "KeySchema": [
+                    {
+                        "AttributeName": "pk3",
+                        "KeyType": "HASH"
+                    },
+                    {
+                        "AttributeName": "sk3",
+                        "KeyType": "RANGE"
+                    }
+                ],
+                "Projection": {
+                    "ProjectionType": "ALL"
+                },
+                "IndexStatus": "ACTIVE",
+                "ProvisionedThroughput": {
+                    "ReadCapacityUnits": 5,
+                    "WriteCapacityUnits": 5
+                },
+                "IndexSizeBytes": 0,
+                "ItemCount": 0,
+                "IndexArn": "arn:aws:dynamodb:ddblocal:000000000000:table/test-development/index/pk3-sk3-index"
+            },
+            {
+                "IndexName": "pk2-sk2-index",
+                "KeySchema": [
+                    {
+                        "AttributeName": "pk2",
+                        "KeyType": "HASH"
+                    },
+                    {
+                        "AttributeName": "sk2",
+                        "KeyType": "RANGE"
+                    }
+                ],
+                "Projection": {
+                    "ProjectionType": "ALL"
+                },
+                "IndexStatus": "ACTIVE",
+                "ProvisionedThroughput": {
+                    "ReadCapacityUnits": 5,
+                    "WriteCapacityUnits": 5
+                },
+                "IndexSizeBytes": 0,
+                "ItemCount": 0,
+                "IndexArn": "arn:aws:dynamodb:ddblocal:000000000000:table/test-development/index/pk2-sk2-index"
+            },
+            {
+                "IndexName": "pk4-sk4-index",
+                "KeySchema": [
+                    {
+                        "AttributeName": "pk4",
+                        "KeyType": "HASH"
+                    },
+                    {
+                        "AttributeName": "sk4",
+                        "KeyType": "RANGE"
+                    }
+                ],
+                "Projection": {
+                    "ProjectionType": "ALL"
+                },
+                "IndexStatus": "ACTIVE",
+                "ProvisionedThroughput": {
+                    "ReadCapacityUnits": 5,
+                    "WriteCapacityUnits": 5
+                },
+                "IndexSizeBytes": 0,
+                "ItemCount": 0,
+                "IndexArn": "arn:aws:dynamodb:ddblocal:000000000000:table/test-development/index/pk4-sk4-index"
+            }
+        ],
+        "StreamSpecification": {
+            "StreamEnabled": true,
+            "StreamViewType": "NEW_AND_OLD_IMAGES"
+        },
+        "LatestStreamLabel": "2021-08-07T12:23:03.601",
+        "LatestStreamArn": "arn:aws:dynamodb:us-east-1:000000000000:table/test-development/stream/2021-08-07T12:23:03.601"
+    }
+}
diff --git a/infra/utils/createGlobalSecondaryIndex.ts b/infra/utils/createGlobalSecondaryIndex.ts
@@ -0,0 +1,18 @@
+import { AttributeType, ProjectionType, GlobalSecondaryIndexProps } from "@aws-cdk/aws-dynamodb";
+
+/**
+ * Default pk & sk is attr type is STRING & read/write capacity is 5.
+ * @param indexName
+ * @param pkName
+ * @param skName
+ */
+export const createStandardGSI = (indexName: string, pkName: string, skName: string) : GlobalSecondaryIndexProps => {
+  return {
+    indexName,
+    partitionKey: { name: pkName, type: AttributeType.STRING },
+    sortKey: { name: skName, type: AttributeType.STRING },
+    projectionType: ProjectionType.ALL,
+    readCapacity: 5,
+    writeCapacity: 5,
+  };
+}