adding files to code sample

Author: sdpoueme

.DS_Store

@@ -0,0 +1,11 @@
+*.swp
+package-lock.json
+__pycache__
+.pytest_cache
+.venv
+*.egg-info
+dist/
+
+# CDK asset staging directory
+.cdk.staging
+cdk.out

.gitignore

@@ -0,0 +1,25 @@
+image: public.ecr.aws/docker/library/python:latest
+
+stages:
+- test
+- build
+- publish
+
+test:
+  script:
+    - apt-get update -y
+    - apt-get install npm -y
+    - npm install -g aws-cdk
+    - python -m ensurepip --upgrade
+    - python -m pip install --upgrade pip
+    - python -m pip install --upgrade virtualenv
+    - python -m venv .venv
+    - source .venv/bin/activate
+    - pip install -r requirements.txt
+#    - cdk synth --json
+publish:
+  script:
+    - pip install build twine
+    - python -m build
+    - TWINE_PASSWORD=${TWINE_PASSWORD} TWINE_USERNAME=${TWINE_USERNAME} python -m twine upload --repository-url  https://${CODE_ARTIFACT_DOMAIN}-${AWS_ACCOUNT_ID}.d.codeartifact.${AWS_REGION}.amazonaws.com/pypi/${CODE_ARTIFACT_REPO_NAME}/ dist/*
+  needs: ["test"]

.gitlab-ci.yml

@@ -0,0 +1,12 @@
+#!/usr/bin/env python3
+
+import aws_cdk as cdk
+
+from cdk_python_module.cdk_workshop_stack import CdkWorkshopStack
+
+
+app = cdk.App()
+CdkWorkshopStack(app, "cdk-workshop")
+
+app.synth()
+

app.py

@@ -0,0 +1,38 @@
+{
+  "app": "python3 app.py",
+  "watch": {
+    "include": [
+      "**"
+    ],
+    "exclude": [
+      "README.md",
+      "cdk*.json",
+      "requirements*.txt",
+      "source.bat",
+      "**/__init__.py",
+      "python/__pycache__",
+      "tests"
+    ]
+  },
+  "context": {
+    "@aws-cdk/aws-lambda:recognizeLayerVersion": true,
+    "@aws-cdk/core:checkSecretUsage": true,
+    "@aws-cdk/core:target-partitions": [
+      "aws",
+      "aws-cn"
+    ],
+    "@aws-cdk-containers/ecs-service-extensions:enableDefaultLogDriver": true,
+    "@aws-cdk/aws-ec2:uniqueImdsv2TemplateName": true,
+    "@aws-cdk/aws-ecs:arnFormatIncludesClusterName": true,
+    "@aws-cdk/aws-iam:minimizePolicies": true,
+    "@aws-cdk/core:validateSnapshotRemovalPolicy": true,
+    "@aws-cdk/aws-codepipeline:crossAccountKeyAliasStackSafeResourceName": true,
+    "@aws-cdk/aws-s3:createDefaultLoggingPolicy": true,
+    "@aws-cdk/aws-sns-subscriptions:restrictSqsDescryption": true,
+    "@aws-cdk/aws-apigateway:disableCloudWatchRole": true,
+    "@aws-cdk/core:enablePartitionLiterals": true,
+    "@aws-cdk/aws-events:eventsTargetQueueSameAccount": true,
+    "@aws-cdk/aws-iam:standardizedServicePrincipals": true,
+    "@aws-cdk/aws-ecs:disableExplicitDeploymentControllerForCircuitBreaker": true
+  }
+}

cdk.json

@@ -0,0 +1,40 @@
+from constructs import Construct
+from aws_cdk import (
+    Stack,
+    aws_lambda as _lambda,
+    aws_apigateway as apigw,
+)
+
+from cdk_dynamo_table_view import TableViewer
+from .hitcounter import HitCounter
+
+
+class CdkWorkshopStack(Stack):
+
+    def __init__(self, scope: Construct, id: str, **kwargs) -> None:
+        super().__init__(scope, id, **kwargs)
+
+        # Defines an AWS Lambda resource
+        hello = _lambda.Function(
+            self, 'HelloHandler',
+            runtime=_lambda.Runtime.PYTHON_3_7,
+            code=_lambda.Code.from_asset('lambda'),
+            handler='hello.handler',
+        )
+
+        hello_with_counter = HitCounter(
+            self, 'HelloHitCounter',
+            downstream=hello,
+        )
+
+        apigw.LambdaRestApi(
+            self, 'Endpoint',
+            handler=hello_with_counter._handler,
+        )
+
+        TableViewer(
+            self, 'ViewHitCounter',
+            title='Hello Hits',
+            table=hello_with_counter.table,
+        )
+

cdk_python_module/__init__.py

@@ -0,0 +1,12 @@
+import json
+
+def handler(event, context):
+    print('request: {}'.format(json.dumps(event)))
+    return {
+        'statusCode': 200,
+        'headers': {
+            'Content-Type': 'text/plain'
+        },
+        'body': 'Good Night, CDK! You have hit {}\n'.format(event['path'])
+    }
+

cdk_python_module/cdk_workshop_stack.py

@@ -0,0 +1,28 @@
+import json
+import os
+
+import boto3
+
+ddb = boto3.resource('dynamodb')
+table = ddb.Table(os.environ['HITS_TABLE_NAME'])
+_lambda = boto3.client('lambda')
+
+
+def handler(event, context):
+    print('request: {}'.format(json.dumps(event)))
+    table.update_item(
+        Key={'path': event['path']},
+        UpdateExpression='ADD hits :incr',
+        ExpressionAttributeValues={':incr': 1}
+    )
+
+    resp = _lambda.invoke(
+        FunctionName=os.environ['DOWNSTREAM_FUNCTION_NAME'],
+        Payload=json.dumps(event),
+    )
+
+    body = resp['Payload'].read()
+
+    print('downstream response: {}'.format(body))
+    return json.loads(body)
+

cdk_python_module/hello.py

@@ -0,0 +1,39 @@
+from constructs import Construct
+from aws_cdk import (
+    aws_lambda as _lambda,
+    aws_dynamodb as ddb,
+)
+
+
+class HitCounter(Construct):
+
+    @property
+    def handler(self):
+        return self._handler
+
+    @property
+    def table(self):
+        return self._table
+
+    def __init__(self, scope: Construct, id: str, downstream: _lambda.IFunction, **kwargs):
+        super().__init__(scope, id, **kwargs)
+
+        self._table = ddb.Table(
+            self, 'Hits',
+            partition_key={'name': 'path', 'type': ddb.AttributeType.STRING}
+        )
+
+        self._handler = _lambda.Function(
+            self, 'HitCountHandler',
+            runtime=_lambda.Runtime.PYTHON_3_7,
+            handler='hitcount.handler',
+            code=_lambda.Code.from_asset('lambda'),
+            environment={
+                'DOWNSTREAM_FUNCTION_NAME': downstream.function_name,
+                'HITS_TABLE_NAME': self._table.table_name,
+            }
+        )
+
+        self._table.grant_read_write_data(self.handler)
+        downstream.grant_invoke(self.handler)
+