Add initial files

Author: simsek97

.gitignore

@@ -0,0 +1,4 @@
+.DS_Store
+node_modules
+cdk.out
+package-lock.json

README.md

@@ -1,17 +1,20 @@
-## My Project
+# State Machine with sub-minute Loop
 
-TODO: Fill this README out!
+This CDK creates a state machine for a 3 seconds loop to trigger a lambda function.
 
-Be sure to:
+![alt text](assets/state-machine.png)
 
-* Change the title in this README
-* Edit your repository description on GitHub
+## Get Started
 
-## Security
+```sh
+git clone https://github.com/aws-samples/aws-cdk-state-machine-with-sub-minute-loop.git
+cd aws-cdk-state-machine-with-sub-minute-loop
+npm install
+```
 
-See [CONTRIBUTING](CONTRIBUTING.md#security-issue-notifications) for more information.
-
-## License
-
-This library is licensed under the MIT-0 License. See the LICENSE file.
+## Deployment
 
+```sh
+npx cdk bootstrap
+npx cdk deploy
+```

assets/state-machine.png

@@ -0,0 +1,6 @@
+#!/usr/bin/env node
+import * as cdk from "aws-cdk-lib";
+import { CdkStack } from "../lib/cdk-stack";
+
+const app = new cdk.App();
+new CdkStack(app, "CdkStack");

bin/cdk.ts

@@ -0,0 +1,3 @@
+{
+    "app": "npx ts-node bin/cdk.ts"
+}

cdk.json

@@ -0,0 +1,74 @@
+import * as cdk from "aws-cdk-lib";
+import * as lambda from "aws-cdk-lib/aws-lambda";
+import * as sfn from "aws-cdk-lib/aws-stepfunctions";
+import * as tasks from "aws-cdk-lib/aws-stepfunctions-tasks";
+
+export class CdkStack extends cdk.Stack {
+  constructor(scope: cdk.App, id: string, props?: cdk.StackProps) {
+    super(scope, id, props);
+
+    // Set hit interval in seconds
+    const hitIntervalInSeconds = 3;
+    const hitDurationInSeconds = 1 * 60; // 1 minute * 60 seconds
+
+    // The lambda function
+    const playLambda = new lambda.Function(this, "playLambda", {
+      description: "Lambda function that pulls will be triggered",
+      handler: "playLambda.handler",
+      runtime: lambda.Runtime.NODEJS_14_X,
+      code: lambda.Code.fromInline(`
+exports.handler = async (event, context, callback) => {
+  console.log('event: ', event);
+
+  let index = event.iterator.index;
+  let step = event.iterator.step;
+  let count = event.iterator.count;
+
+  // do your business
+
+  callback(null, {
+    index,
+    step,
+    count,
+    continue: index < count ? "CONTINUE" : "END",
+  });
+};
+      `),
+    });
+
+    const ConfigureCount = new sfn.Pass(this, "ConfigureCount", {
+      result: {
+        value: {
+          count: Math.round(hitDurationInSeconds / hitIntervalInSeconds),
+          index: 0,
+          step: 1,
+        },
+      },
+      resultPath: "$.iterator",
+    });
+
+    const Iterator = new tasks.LambdaInvoke(this, "PlayTask", {
+      lambdaFunction: playLambda,
+      payloadResponseOnly: true,
+      retryOnServiceExceptions: false,
+      resultPath: "$.iterator",
+    });
+
+    const Wait = new sfn.Wait(this, "Wait", {
+      time: sfn.WaitTime.duration(cdk.Duration.seconds(hitIntervalInSeconds)),
+    }).next(Iterator);
+
+    const Done = new sfn.Succeed(this, "Done");
+
+    const IsCountReached = new sfn.Choice(this, "IsCountReached", {
+      comment: "If the count is reached then end the process",
+    })
+      .when(sfn.Condition.stringEquals("$.iterator.continue", "CONTINUE"), Wait)
+      .otherwise(Done);
+
+    new sfn.StateMachine(this, "PlayStateMachine", {
+      stateMachineName: "PlayStateMachine",
+      definition: ConfigureCount.next(Iterator).next(IsCountReached),
+    });
+  }
+}

lib/cdk-stack.ts

@@ -0,0 +1,27 @@
+{
+    "name": "aws-cdk-state-machine-with-sub-minute-loop",
+    "license": "MIT-0",
+    "version": "0.0.1",
+    "bin": {
+        "cdk": "bin/cdk.js"
+    },
+  "scripts": {
+    "build": "tsc",
+    "watch": "tsc -w",
+    "test": "jest",
+    "cdk": "cdk"
+  },
+  "devDependencies": {
+    "aws-cdk": "2.10.0",
+    "@types/jest": "^26.0.10",
+    "@types/node": "10.17.27",
+    "jest": "^26.4.2",
+    "ts-jest": "^26.2.0",
+    "ts-node": "^9.0.0",
+    "typescript": "~3.9.7"
+  },
+  "dependencies": {
+    "aws-cdk-lib": "2.10.0",
+    "constructs": "^10.0.0"
+  }
+}

package.json

@@ -0,0 +1,30 @@
+{
+    "compilerOptions": {
+        "target": "ES2018",
+        "module": "commonjs",
+        "lib": [
+            "es2018",
+        ],
+        "declaration": true,
+        "strict": true,
+        "noImplicitAny": true,
+        "strictNullChecks": true,
+        "noImplicitThis": true,
+        "alwaysStrict": true,
+        "noUnusedLocals": false,
+        "noUnusedParameters": false,
+        "noImplicitReturns": true,
+        "noFallthroughCasesInSwitch": false,
+        "inlineSourceMap": true,
+        "inlineSources": true,
+        "experimentalDecorators": true,
+        "strictPropertyInitialization": false,
+        "typeRoots": [
+            "./node_modules/@types"
+        ]
+    },
+    "exclude": [
+        "node_modules",
+        "cdk.out"
+    ]
+}