%global _empty_manifest_terminate_build 0
Name: python-cdk-lambda-subminute
Version: 2.0.166
Release: 1
Summary: A construct for deploying a Lambda function that can be invoked every time unit less than one minute.
License: Apache-2.0
URL: https://github.com/HsiehShuJeng/cdk-lambda-subminute.git
Source0: https://mirrors.nju.edu.cn/pypi/web/packages/6c/ea/1a84b3a7b23e47680bb2bf7fa5737b5a13edef4ecd3de8207e8be88f9722/cdk_lambda_subminute-2.0.166.tar.gz
BuildArch: noarch
Requires: python3-aws-cdk-lib
Requires: python3-constructs
Requires: python3-jsii
Requires: python3-publication
Requires: python3-typeguard
%description
# cdk-lambda-subminute
[](https://opensource.org/licenses/Apache-2.0) [](https://github.com/HsiehShuJeng/cdk-lambda-subminute/actions/workflows/release.yml) [](https://img.shields.io/npm/dt/cdk-lambda-subminute?label=npm%20downloads&style=plastic) [](https://img.shields.io/pypi/dm/cdk-lambda-subminute?label=pypi%20downloads&style=plastic) [](https://img.shields.io/nuget/dt/Lambda.Subminute?label=NuGet%20downloads&style=plastic) [](https://img.shields.io/github/languages/count/HsiehShuJeng/cdk-lambda-subminute?style=plastic)
| npm (JS/TS) | PyPI (Python) | Maven (Java) | Go | NuGet |
| --- | --- | --- | --- | --- |
| [Link](https://www.npmjs.com/package/cdk-lambda-subminute) | [Link](https://pypi.org/project/cdk_lambda_subminute/) | [Link](https://search.maven.org/artifact/io.github.hsiehshujeng/cdk-lambda-subminute) | [Link](https://github.com/HsiehShuJeng/cdk-lambda-subminute-go) | [Link](https://www.nuget.org/packages/Lambda.Subminute/) |
This construct creates a state machine that can invoke a Lambda function per time unit which can be less than one minute, such as invoking every 10 seconds. You only need to craft a Lambda function and then assign it as an argument into the construct. An example is included.
# Serverless Architecture
# Introduction
This construct library is reffered to thie AWS Architecture blog post, [*A serverless solution for invoking AWS Lambda at a sub-minute frequency*](https://aws.amazon.com/tw/blogs/architecture/a-serverless-solution-for-invoking-aws-lambda-at-a-sub-minute-frequency/), written by **Emanuele Menga**. I made it as a constrcut library where you only need to care about a target Lambda function, how frequent and how long you want to execute.
# Example
## Typescript
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/typescript).
```bash
$ cdk --init language typescript
$ yarn add cdk-lambda-subminute
```
```python
class TypescriptStack extends cdk.Stack {
constructor(scope: cdk.Construct, id: string, props?: cdk.StackProps) {
super(scope, id, props);
const targetLabmda = new Function(this, 'targetFunction', {
code: Code.fromInline('exports.handler = function(event, ctx, cb) { return cb(null, "hi"); })'), // It's just a simple function for demonstration purpose only.
functionName: 'testTargetFunction',
runtime: Runtime.NODEJS_18_X,
handler: 'index.handler',
});
const cronJobExample = 'cron(50/1 15-17 ? * SUN-SAT *)';
const subminuteMaster = new LambdaSubminute(this, 'LambdaSubminute', { targetFunction: targetLabmda, cronjobExpression: cronJobExample });
new cdk.CfnOutput(this, 'OStateMachineArn', { value: subminuteMaster.stateMachineArn });
new cdk.CfnOutput(this, 'OIteratorFunctionArn', { value: subminuteMaster.iteratorFunction.functionArn });
}
}
const app = new cdk.App();
new TypescriptStack(app, 'TypescriptStack', {
});
```
## Python
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/python).
```bash
# upgrading related Python packages
$ python -m ensurepip --upgrade
$ python -m pip install --upgrade pip
$ python -m pip install --upgrade virtualenv
# initialize a CDK Python project
$ cdk init --language python
# make packages installed locally instead of globally
$ source .venv/bin/activate
$ cat < requirements.txt
aws-cdk.core
aws-cdk.aws-lambda
cdk-lambda-subminute
EOL
$ python -m pip install -r requirements.txt
```
```python
from aws_cdk import core as cdk
from aws_cdk.aws_lambda import Code, Function, Runtime
from cdk_lambda_subminute import LambdaSubminute
class PythonStack(cdk.Stack):
def __init__(self, scope: cdk.Construct, construct_id: str, **kwargs) -> None:
super().__init__(scope, construct_id, **kwargs)
target_lambda = Function(
self, "targetFunction",
code=Code.from_inline(
"exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
function_name="testTargetFunction",
runtime=Runtime.NODEJS_18_X,
handler="index.handler"
)
cron_job_example = "cron(10/1 4-5 ? * SUN-SAT *)"
subminute_master = LambdaSubminute(
self, "LambdaSubminute",
target_function=target_lambda,
cronjob_expression=cron_job_example,
frequency=7,
interval_time=8)
cdk.CfnOutput(self, "OStateMachineArn",
value=subminute_master.state_machine_arn)
cdk.CfnOutput(self, "OIteratorFunctionArn",
value=subminute_master.iterator_function.function_arn)
```
```bash
$ deactivate
```
## Java
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/java).
```bash
$ cdk init --language java
$ mvn package
```
```xml
.
.
UTF-8
2.76.0
2.0.128
5.7.1
.
.
software.amazon.awscdk
core
${cdk.version}
software.amazon.awscdk
lambda
${cdk.version}
io.github.hsiehshujeng
cdk-lambda-subminute
${constrcut.verion}
.
.
.
```
```java
package com.myorg;
import software.amazon.awscdk.core.CfnOutput;
import software.amazon.awscdk.core.CfnOutputProps;
import software.amazon.awscdk.core.Construct;
import software.amazon.awscdk.core.Stack;
import software.amazon.awscdk.core.StackProps;
import software.amazon.awscdk.services.lambda.Code;
import software.amazon.awscdk.services.lambda.Function;
import software.amazon.awscdk.services.lambda.FunctionProps;
import software.amazon.awscdk.services.lambda.Runtime;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminute;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminuteProps;
public class JavaStack extends Stack {
public JavaStack(final Construct scope, final String id) {
this(scope, id, null);
}
public JavaStack(final Construct scope, final String id, final StackProps props) {
super(scope, id, props);
Function targetLambda = new Function(this, "targetFunction",
FunctionProps.builder()
.code(Code.fromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"))
.functionName("estTargetFunction")
.runtime(Runtime.NODEJS_18_X)
.handler("index.handler")
.build());
String cronJobExample = "cron(50/1 4-5 ? * SUN-SAT *)";
LambdaSubminute subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", LambdaSubminuteProps.builder()
.targetFunction(targetLambda)
.cronjobExpression(cronJobExample)
.frequency(6)
.intervalTime(9)
.build());
new CfnOutput(this, "OStateMachineArn",
CfnOutputProps.builder()
.value(subminuteMaster.getStateMachineArn())
.build());
new CfnOutput(this, "OIteratorFunctionArn",
CfnOutputProps.builder()
.value(subminuteMaster.getIteratorFunction().getFunctionName())
.build());
}
}
```
## C#
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/csharp).
```bash
$ cdk init --language csharp
$ dotnet add src/Csharp package Amazon.CDK.AWS.Lambda
$ dotnet add src/Csharp package Lambda.Subminute --version 2.0.128
```
```cs
using Amazon.CDK;
using Amazon.CDK.AWS.Lambda;
using ScottHsieh.Cdk;
namespace Csharp
{
public class CsharpStack : Stack
{
internal CsharpStack(Construct scope, string id, IStackProps props = null) : base(scope, id, props)
{
var targetLambda = new Function(this, "targetFunction", new FunctionProps
{
Code = Code.FromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
FunctionName = "testTargetFunction",
Runtime = Runtime.NODEJS_18_X,
Handler = "index.handler"
});
string cronJobExample = "cron(50/1 6-7 ? * SUN-SAT *)";
var subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", new LambdaSubminuteProps
{
TargetFunction = targetLambda,
CronjobExpression = cronJobExample,
Frequency = 10,
IntervalTime = 6,
});
new CfnOutput(this, "OStateMachineArn", new CfnOutputProps
{
Value = subminuteMaster.StateMachineArn
});
new CfnOutput(this, "OIteratorFunctionArn", new CfnOutputProps
{
Value = subminuteMaster.IteratorFunction.FunctionArn
});
}
}
}
```
# Statemachine Diagram
# Known issue
Originally, I utilized `PythonFuncion` in the module of [**@aws-cdk/aws-lambda-python**](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-lambda-python-readme.html) to build the iterator Lambda function. Every thing works fine, including test, on my local machine (MacBook Pro M1), until it comes to the CI in Github Actions, it awlays gave me the following message:
```bash
## cdk version: 1.105.0 (build 4813992)
Bundling did not produce any output. Check that content is written to /asset-output.
64 | }));
65 |
> 66 | this.function = new PythonFunction(this, 'Iterator', {
| ^
67 | functionName: 'lambda-subminute-iterator',
68 | description: 'A function for breaking the limit of 1 minute with the CloudWatch Rules.',
69 | logRetention: RetentionDays.THREE_MONTHS,
at AssetStaging.bundle (node_modules/@aws-cdk/core/lib/asset-staging.ts:484:13)
at AssetStaging.stageByBundling (node_modules/@aws-cdk/core/lib/asset-staging.ts:328:10)
at stageThisAsset (node_modules/@aws-cdk/core/lib/asset-staging.ts:194:35)
at Cache.obtain (node_modules/@aws-cdk/core/lib/private/cache.ts:24:13)
at new AssetStaging (node_modules/@aws-cdk/core/lib/asset-staging.ts:219:44)
at new Asset (node_modules/@aws-cdk/aws-s3-assets/lib/asset.ts:127:21)
at AssetCode.bind (node_modules/@aws-cdk/aws-lambda/lib/code.ts:277:20)
at new Function (node_modules/@aws-cdk/aws-lambda/lib/function.ts:583:29)
at new PythonFunction (node_modules/@aws-cdk/aws-lambda-python/lib/function.ts:106:5)
at new IteratorLambda (src/cdk-lambda-subminute.ts:66:21)
at new LambdaSubminute (src/cdk-lambda-subminute.ts:25:22)
at Object..test (test/integ.test.ts:23:3)
```
I actually have tried many different methods according to the following threads but to no avail. I'll attempt to test some thoughts or just post the issue onto the CDK Github repo.
* [Asset Bundling](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-s3-assets-readme.html#asset-bundling)
* [Change the bundler's /asset-output local volume mount location #8589](https://github.com/aws/aws-cdk/issues/8589)
* [(aws-lambda-python: PythonFunction): unable to use bundling in BitBucket #14156](https://github.com/aws/aws-cdk/issues/14516)
* [BundlingDockerImage.cp() needs to be explained more in the README #11914](https://github.com/aws/aws-cdk/issues/11914)
%package -n python3-cdk-lambda-subminute
Summary: A construct for deploying a Lambda function that can be invoked every time unit less than one minute.
Provides: python-cdk-lambda-subminute
BuildRequires: python3-devel
BuildRequires: python3-setuptools
BuildRequires: python3-pip
%description -n python3-cdk-lambda-subminute
# cdk-lambda-subminute
[](https://opensource.org/licenses/Apache-2.0) [](https://github.com/HsiehShuJeng/cdk-lambda-subminute/actions/workflows/release.yml) [](https://img.shields.io/npm/dt/cdk-lambda-subminute?label=npm%20downloads&style=plastic) [](https://img.shields.io/pypi/dm/cdk-lambda-subminute?label=pypi%20downloads&style=plastic) [](https://img.shields.io/nuget/dt/Lambda.Subminute?label=NuGet%20downloads&style=plastic) [](https://img.shields.io/github/languages/count/HsiehShuJeng/cdk-lambda-subminute?style=plastic)
| npm (JS/TS) | PyPI (Python) | Maven (Java) | Go | NuGet |
| --- | --- | --- | --- | --- |
| [Link](https://www.npmjs.com/package/cdk-lambda-subminute) | [Link](https://pypi.org/project/cdk_lambda_subminute/) | [Link](https://search.maven.org/artifact/io.github.hsiehshujeng/cdk-lambda-subminute) | [Link](https://github.com/HsiehShuJeng/cdk-lambda-subminute-go) | [Link](https://www.nuget.org/packages/Lambda.Subminute/) |
This construct creates a state machine that can invoke a Lambda function per time unit which can be less than one minute, such as invoking every 10 seconds. You only need to craft a Lambda function and then assign it as an argument into the construct. An example is included.
# Serverless Architecture
# Introduction
This construct library is reffered to thie AWS Architecture blog post, [*A serverless solution for invoking AWS Lambda at a sub-minute frequency*](https://aws.amazon.com/tw/blogs/architecture/a-serverless-solution-for-invoking-aws-lambda-at-a-sub-minute-frequency/), written by **Emanuele Menga**. I made it as a constrcut library where you only need to care about a target Lambda function, how frequent and how long you want to execute.
# Example
## Typescript
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/typescript).
```bash
$ cdk --init language typescript
$ yarn add cdk-lambda-subminute
```
```python
class TypescriptStack extends cdk.Stack {
constructor(scope: cdk.Construct, id: string, props?: cdk.StackProps) {
super(scope, id, props);
const targetLabmda = new Function(this, 'targetFunction', {
code: Code.fromInline('exports.handler = function(event, ctx, cb) { return cb(null, "hi"); })'), // It's just a simple function for demonstration purpose only.
functionName: 'testTargetFunction',
runtime: Runtime.NODEJS_18_X,
handler: 'index.handler',
});
const cronJobExample = 'cron(50/1 15-17 ? * SUN-SAT *)';
const subminuteMaster = new LambdaSubminute(this, 'LambdaSubminute', { targetFunction: targetLabmda, cronjobExpression: cronJobExample });
new cdk.CfnOutput(this, 'OStateMachineArn', { value: subminuteMaster.stateMachineArn });
new cdk.CfnOutput(this, 'OIteratorFunctionArn', { value: subminuteMaster.iteratorFunction.functionArn });
}
}
const app = new cdk.App();
new TypescriptStack(app, 'TypescriptStack', {
});
```
## Python
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/python).
```bash
# upgrading related Python packages
$ python -m ensurepip --upgrade
$ python -m pip install --upgrade pip
$ python -m pip install --upgrade virtualenv
# initialize a CDK Python project
$ cdk init --language python
# make packages installed locally instead of globally
$ source .venv/bin/activate
$ cat < requirements.txt
aws-cdk.core
aws-cdk.aws-lambda
cdk-lambda-subminute
EOL
$ python -m pip install -r requirements.txt
```
```python
from aws_cdk import core as cdk
from aws_cdk.aws_lambda import Code, Function, Runtime
from cdk_lambda_subminute import LambdaSubminute
class PythonStack(cdk.Stack):
def __init__(self, scope: cdk.Construct, construct_id: str, **kwargs) -> None:
super().__init__(scope, construct_id, **kwargs)
target_lambda = Function(
self, "targetFunction",
code=Code.from_inline(
"exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
function_name="testTargetFunction",
runtime=Runtime.NODEJS_18_X,
handler="index.handler"
)
cron_job_example = "cron(10/1 4-5 ? * SUN-SAT *)"
subminute_master = LambdaSubminute(
self, "LambdaSubminute",
target_function=target_lambda,
cronjob_expression=cron_job_example,
frequency=7,
interval_time=8)
cdk.CfnOutput(self, "OStateMachineArn",
value=subminute_master.state_machine_arn)
cdk.CfnOutput(self, "OIteratorFunctionArn",
value=subminute_master.iterator_function.function_arn)
```
```bash
$ deactivate
```
## Java
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/java).
```bash
$ cdk init --language java
$ mvn package
```
```xml
.
.
UTF-8
2.76.0
2.0.128
5.7.1
.
.
software.amazon.awscdk
core
${cdk.version}
software.amazon.awscdk
lambda
${cdk.version}
io.github.hsiehshujeng
cdk-lambda-subminute
${constrcut.verion}
.
.
.
```
```java
package com.myorg;
import software.amazon.awscdk.core.CfnOutput;
import software.amazon.awscdk.core.CfnOutputProps;
import software.amazon.awscdk.core.Construct;
import software.amazon.awscdk.core.Stack;
import software.amazon.awscdk.core.StackProps;
import software.amazon.awscdk.services.lambda.Code;
import software.amazon.awscdk.services.lambda.Function;
import software.amazon.awscdk.services.lambda.FunctionProps;
import software.amazon.awscdk.services.lambda.Runtime;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminute;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminuteProps;
public class JavaStack extends Stack {
public JavaStack(final Construct scope, final String id) {
this(scope, id, null);
}
public JavaStack(final Construct scope, final String id, final StackProps props) {
super(scope, id, props);
Function targetLambda = new Function(this, "targetFunction",
FunctionProps.builder()
.code(Code.fromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"))
.functionName("estTargetFunction")
.runtime(Runtime.NODEJS_18_X)
.handler("index.handler")
.build());
String cronJobExample = "cron(50/1 4-5 ? * SUN-SAT *)";
LambdaSubminute subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", LambdaSubminuteProps.builder()
.targetFunction(targetLambda)
.cronjobExpression(cronJobExample)
.frequency(6)
.intervalTime(9)
.build());
new CfnOutput(this, "OStateMachineArn",
CfnOutputProps.builder()
.value(subminuteMaster.getStateMachineArn())
.build());
new CfnOutput(this, "OIteratorFunctionArn",
CfnOutputProps.builder()
.value(subminuteMaster.getIteratorFunction().getFunctionName())
.build());
}
}
```
## C#
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/csharp).
```bash
$ cdk init --language csharp
$ dotnet add src/Csharp package Amazon.CDK.AWS.Lambda
$ dotnet add src/Csharp package Lambda.Subminute --version 2.0.128
```
```cs
using Amazon.CDK;
using Amazon.CDK.AWS.Lambda;
using ScottHsieh.Cdk;
namespace Csharp
{
public class CsharpStack : Stack
{
internal CsharpStack(Construct scope, string id, IStackProps props = null) : base(scope, id, props)
{
var targetLambda = new Function(this, "targetFunction", new FunctionProps
{
Code = Code.FromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
FunctionName = "testTargetFunction",
Runtime = Runtime.NODEJS_18_X,
Handler = "index.handler"
});
string cronJobExample = "cron(50/1 6-7 ? * SUN-SAT *)";
var subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", new LambdaSubminuteProps
{
TargetFunction = targetLambda,
CronjobExpression = cronJobExample,
Frequency = 10,
IntervalTime = 6,
});
new CfnOutput(this, "OStateMachineArn", new CfnOutputProps
{
Value = subminuteMaster.StateMachineArn
});
new CfnOutput(this, "OIteratorFunctionArn", new CfnOutputProps
{
Value = subminuteMaster.IteratorFunction.FunctionArn
});
}
}
}
```
# Statemachine Diagram
# Known issue
Originally, I utilized `PythonFuncion` in the module of [**@aws-cdk/aws-lambda-python**](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-lambda-python-readme.html) to build the iterator Lambda function. Every thing works fine, including test, on my local machine (MacBook Pro M1), until it comes to the CI in Github Actions, it awlays gave me the following message:
```bash
## cdk version: 1.105.0 (build 4813992)
Bundling did not produce any output. Check that content is written to /asset-output.
64 | }));
65 |
> 66 | this.function = new PythonFunction(this, 'Iterator', {
| ^
67 | functionName: 'lambda-subminute-iterator',
68 | description: 'A function for breaking the limit of 1 minute with the CloudWatch Rules.',
69 | logRetention: RetentionDays.THREE_MONTHS,
at AssetStaging.bundle (node_modules/@aws-cdk/core/lib/asset-staging.ts:484:13)
at AssetStaging.stageByBundling (node_modules/@aws-cdk/core/lib/asset-staging.ts:328:10)
at stageThisAsset (node_modules/@aws-cdk/core/lib/asset-staging.ts:194:35)
at Cache.obtain (node_modules/@aws-cdk/core/lib/private/cache.ts:24:13)
at new AssetStaging (node_modules/@aws-cdk/core/lib/asset-staging.ts:219:44)
at new Asset (node_modules/@aws-cdk/aws-s3-assets/lib/asset.ts:127:21)
at AssetCode.bind (node_modules/@aws-cdk/aws-lambda/lib/code.ts:277:20)
at new Function (node_modules/@aws-cdk/aws-lambda/lib/function.ts:583:29)
at new PythonFunction (node_modules/@aws-cdk/aws-lambda-python/lib/function.ts:106:5)
at new IteratorLambda (src/cdk-lambda-subminute.ts:66:21)
at new LambdaSubminute (src/cdk-lambda-subminute.ts:25:22)
at Object..test (test/integ.test.ts:23:3)
```
I actually have tried many different methods according to the following threads but to no avail. I'll attempt to test some thoughts or just post the issue onto the CDK Github repo.
* [Asset Bundling](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-s3-assets-readme.html#asset-bundling)
* [Change the bundler's /asset-output local volume mount location #8589](https://github.com/aws/aws-cdk/issues/8589)
* [(aws-lambda-python: PythonFunction): unable to use bundling in BitBucket #14156](https://github.com/aws/aws-cdk/issues/14516)
* [BundlingDockerImage.cp() needs to be explained more in the README #11914](https://github.com/aws/aws-cdk/issues/11914)
%package help
Summary: Development documents and examples for cdk-lambda-subminute
Provides: python3-cdk-lambda-subminute-doc
%description help
# cdk-lambda-subminute
[](https://opensource.org/licenses/Apache-2.0) [](https://github.com/HsiehShuJeng/cdk-lambda-subminute/actions/workflows/release.yml) [](https://img.shields.io/npm/dt/cdk-lambda-subminute?label=npm%20downloads&style=plastic) [](https://img.shields.io/pypi/dm/cdk-lambda-subminute?label=pypi%20downloads&style=plastic) [](https://img.shields.io/nuget/dt/Lambda.Subminute?label=NuGet%20downloads&style=plastic) [](https://img.shields.io/github/languages/count/HsiehShuJeng/cdk-lambda-subminute?style=plastic)
| npm (JS/TS) | PyPI (Python) | Maven (Java) | Go | NuGet |
| --- | --- | --- | --- | --- |
| [Link](https://www.npmjs.com/package/cdk-lambda-subminute) | [Link](https://pypi.org/project/cdk_lambda_subminute/) | [Link](https://search.maven.org/artifact/io.github.hsiehshujeng/cdk-lambda-subminute) | [Link](https://github.com/HsiehShuJeng/cdk-lambda-subminute-go) | [Link](https://www.nuget.org/packages/Lambda.Subminute/) |
This construct creates a state machine that can invoke a Lambda function per time unit which can be less than one minute, such as invoking every 10 seconds. You only need to craft a Lambda function and then assign it as an argument into the construct. An example is included.
# Serverless Architecture
# Introduction
This construct library is reffered to thie AWS Architecture blog post, [*A serverless solution for invoking AWS Lambda at a sub-minute frequency*](https://aws.amazon.com/tw/blogs/architecture/a-serverless-solution-for-invoking-aws-lambda-at-a-sub-minute-frequency/), written by **Emanuele Menga**. I made it as a constrcut library where you only need to care about a target Lambda function, how frequent and how long you want to execute.
# Example
## Typescript
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/typescript).
```bash
$ cdk --init language typescript
$ yarn add cdk-lambda-subminute
```
```python
class TypescriptStack extends cdk.Stack {
constructor(scope: cdk.Construct, id: string, props?: cdk.StackProps) {
super(scope, id, props);
const targetLabmda = new Function(this, 'targetFunction', {
code: Code.fromInline('exports.handler = function(event, ctx, cb) { return cb(null, "hi"); })'), // It's just a simple function for demonstration purpose only.
functionName: 'testTargetFunction',
runtime: Runtime.NODEJS_18_X,
handler: 'index.handler',
});
const cronJobExample = 'cron(50/1 15-17 ? * SUN-SAT *)';
const subminuteMaster = new LambdaSubminute(this, 'LambdaSubminute', { targetFunction: targetLabmda, cronjobExpression: cronJobExample });
new cdk.CfnOutput(this, 'OStateMachineArn', { value: subminuteMaster.stateMachineArn });
new cdk.CfnOutput(this, 'OIteratorFunctionArn', { value: subminuteMaster.iteratorFunction.functionArn });
}
}
const app = new cdk.App();
new TypescriptStack(app, 'TypescriptStack', {
});
```
## Python
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/python).
```bash
# upgrading related Python packages
$ python -m ensurepip --upgrade
$ python -m pip install --upgrade pip
$ python -m pip install --upgrade virtualenv
# initialize a CDK Python project
$ cdk init --language python
# make packages installed locally instead of globally
$ source .venv/bin/activate
$ cat < requirements.txt
aws-cdk.core
aws-cdk.aws-lambda
cdk-lambda-subminute
EOL
$ python -m pip install -r requirements.txt
```
```python
from aws_cdk import core as cdk
from aws_cdk.aws_lambda import Code, Function, Runtime
from cdk_lambda_subminute import LambdaSubminute
class PythonStack(cdk.Stack):
def __init__(self, scope: cdk.Construct, construct_id: str, **kwargs) -> None:
super().__init__(scope, construct_id, **kwargs)
target_lambda = Function(
self, "targetFunction",
code=Code.from_inline(
"exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
function_name="testTargetFunction",
runtime=Runtime.NODEJS_18_X,
handler="index.handler"
)
cron_job_example = "cron(10/1 4-5 ? * SUN-SAT *)"
subminute_master = LambdaSubminute(
self, "LambdaSubminute",
target_function=target_lambda,
cronjob_expression=cron_job_example,
frequency=7,
interval_time=8)
cdk.CfnOutput(self, "OStateMachineArn",
value=subminute_master.state_machine_arn)
cdk.CfnOutput(self, "OIteratorFunctionArn",
value=subminute_master.iterator_function.function_arn)
```
```bash
$ deactivate
```
## Java
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/java).
```bash
$ cdk init --language java
$ mvn package
```
```xml
.
.
UTF-8
2.76.0
2.0.128
5.7.1
.
.
software.amazon.awscdk
core
${cdk.version}
software.amazon.awscdk
lambda
${cdk.version}
io.github.hsiehshujeng
cdk-lambda-subminute
${constrcut.verion}
.
.
.
```
```java
package com.myorg;
import software.amazon.awscdk.core.CfnOutput;
import software.amazon.awscdk.core.CfnOutputProps;
import software.amazon.awscdk.core.Construct;
import software.amazon.awscdk.core.Stack;
import software.amazon.awscdk.core.StackProps;
import software.amazon.awscdk.services.lambda.Code;
import software.amazon.awscdk.services.lambda.Function;
import software.amazon.awscdk.services.lambda.FunctionProps;
import software.amazon.awscdk.services.lambda.Runtime;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminute;
import io.github.hsiehshujeng.cdk.lambda.subminute.LambdaSubminuteProps;
public class JavaStack extends Stack {
public JavaStack(final Construct scope, final String id) {
this(scope, id, null);
}
public JavaStack(final Construct scope, final String id, final StackProps props) {
super(scope, id, props);
Function targetLambda = new Function(this, "targetFunction",
FunctionProps.builder()
.code(Code.fromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"))
.functionName("estTargetFunction")
.runtime(Runtime.NODEJS_18_X)
.handler("index.handler")
.build());
String cronJobExample = "cron(50/1 4-5 ? * SUN-SAT *)";
LambdaSubminute subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", LambdaSubminuteProps.builder()
.targetFunction(targetLambda)
.cronjobExpression(cronJobExample)
.frequency(6)
.intervalTime(9)
.build());
new CfnOutput(this, "OStateMachineArn",
CfnOutputProps.builder()
.value(subminuteMaster.getStateMachineArn())
.build());
new CfnOutput(this, "OIteratorFunctionArn",
CfnOutputProps.builder()
.value(subminuteMaster.getIteratorFunction().getFunctionName())
.build());
}
}
```
## C#
You could also refer to [here](https://github.com/HsiehShuJeng/cdk-lambda-subminute/tree/main/src/demo/csharp).
```bash
$ cdk init --language csharp
$ dotnet add src/Csharp package Amazon.CDK.AWS.Lambda
$ dotnet add src/Csharp package Lambda.Subminute --version 2.0.128
```
```cs
using Amazon.CDK;
using Amazon.CDK.AWS.Lambda;
using ScottHsieh.Cdk;
namespace Csharp
{
public class CsharpStack : Stack
{
internal CsharpStack(Construct scope, string id, IStackProps props = null) : base(scope, id, props)
{
var targetLambda = new Function(this, "targetFunction", new FunctionProps
{
Code = Code.FromInline("exports.handler = function(event, ctx, cb) { return cb(null, \"hi\"); })"),
FunctionName = "testTargetFunction",
Runtime = Runtime.NODEJS_18_X,
Handler = "index.handler"
});
string cronJobExample = "cron(50/1 6-7 ? * SUN-SAT *)";
var subminuteMaster = new LambdaSubminute(this, "LambdaSubminute", new LambdaSubminuteProps
{
TargetFunction = targetLambda,
CronjobExpression = cronJobExample,
Frequency = 10,
IntervalTime = 6,
});
new CfnOutput(this, "OStateMachineArn", new CfnOutputProps
{
Value = subminuteMaster.StateMachineArn
});
new CfnOutput(this, "OIteratorFunctionArn", new CfnOutputProps
{
Value = subminuteMaster.IteratorFunction.FunctionArn
});
}
}
}
```
# Statemachine Diagram
# Known issue
Originally, I utilized `PythonFuncion` in the module of [**@aws-cdk/aws-lambda-python**](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-lambda-python-readme.html) to build the iterator Lambda function. Every thing works fine, including test, on my local machine (MacBook Pro M1), until it comes to the CI in Github Actions, it awlays gave me the following message:
```bash
## cdk version: 1.105.0 (build 4813992)
Bundling did not produce any output. Check that content is written to /asset-output.
64 | }));
65 |
> 66 | this.function = new PythonFunction(this, 'Iterator', {
| ^
67 | functionName: 'lambda-subminute-iterator',
68 | description: 'A function for breaking the limit of 1 minute with the CloudWatch Rules.',
69 | logRetention: RetentionDays.THREE_MONTHS,
at AssetStaging.bundle (node_modules/@aws-cdk/core/lib/asset-staging.ts:484:13)
at AssetStaging.stageByBundling (node_modules/@aws-cdk/core/lib/asset-staging.ts:328:10)
at stageThisAsset (node_modules/@aws-cdk/core/lib/asset-staging.ts:194:35)
at Cache.obtain (node_modules/@aws-cdk/core/lib/private/cache.ts:24:13)
at new AssetStaging (node_modules/@aws-cdk/core/lib/asset-staging.ts:219:44)
at new Asset (node_modules/@aws-cdk/aws-s3-assets/lib/asset.ts:127:21)
at AssetCode.bind (node_modules/@aws-cdk/aws-lambda/lib/code.ts:277:20)
at new Function (node_modules/@aws-cdk/aws-lambda/lib/function.ts:583:29)
at new PythonFunction (node_modules/@aws-cdk/aws-lambda-python/lib/function.ts:106:5)
at new IteratorLambda (src/cdk-lambda-subminute.ts:66:21)
at new LambdaSubminute (src/cdk-lambda-subminute.ts:25:22)
at Object..test (test/integ.test.ts:23:3)
```
I actually have tried many different methods according to the following threads but to no avail. I'll attempt to test some thoughts or just post the issue onto the CDK Github repo.
* [Asset Bundling](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-s3-assets-readme.html#asset-bundling)
* [Change the bundler's /asset-output local volume mount location #8589](https://github.com/aws/aws-cdk/issues/8589)
* [(aws-lambda-python: PythonFunction): unable to use bundling in BitBucket #14156](https://github.com/aws/aws-cdk/issues/14516)
* [BundlingDockerImage.cp() needs to be explained more in the README #11914](https://github.com/aws/aws-cdk/issues/11914)
%prep
%autosetup -n cdk-lambda-subminute-2.0.166
%build
%py3_build
%install
%py3_install
install -d -m755 %{buildroot}/%{_pkgdocdir}
if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
pushd %{buildroot}
if [ -d usr/lib ]; then
find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst
fi
if [ -d usr/lib64 ]; then
find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst
fi
if [ -d usr/bin ]; then
find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst
fi
if [ -d usr/sbin ]; then
find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst
fi
touch doclist.lst
if [ -d usr/share/man ]; then
find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst
fi
popd
mv %{buildroot}/filelist.lst .
mv %{buildroot}/doclist.lst .
%files -n python3-cdk-lambda-subminute -f filelist.lst
%dir %{python3_sitelib}/*
%files help -f doclist.lst
%{_docdir}/*
%changelog
* Tue May 30 2023 Python_Bot - 2.0.166-1
- Package Spec generated