package main import ( "github.com/aws/aws-cdk-go/awscdk/v2" "github.com/aws/aws-cdk-go/awscdk/v2/awsdynamodb" "github.com/aws/aws-cdk-go/awscdk/v2/awsiam" "github.com/aws/aws-cdk-go/awscdk/v2/awslambda" "github.com/aws/aws-cdk-go/awscdklambdagoalpha/v2" "github.com/aws/aws-sdk-go/aws" "github.com/aws/constructs-go/constructs/v10" "github.com/aws/jsii-runtime-go" ) type LambdaDynamodbStackProps struct { awscdk.StackProps } func NewLambdaDynamodbStack(scope constructs.Construct, id string, props *LambdaDynamodbStackProps) awscdk.Stack { var sprops awscdk.StackProps if props != nil { sprops = props.StackProps } stack := awscdk.NewStack(scope, &id, &sprops) // create AmazonDynamoDBFullAccess role dynamoDBRole := awsiam.NewRole(stack, aws.String("myDynamoDBFullAccessRole"), &awsiam.RoleProps{ AssumedBy: awsiam.NewServicePrincipal(aws.String("lambda.amazonaws.com"), &awsiam.ServicePrincipalOpts{}), ManagedPolicies: &[]awsiam.IManagedPolicy{ awsiam.ManagedPolicy_FromManagedPolicyArn(stack, aws.String("AmazonDynamoDBFullAccess"), aws.String("arn:aws:iam::aws:policy/AmazonDynamoDBFullAccess")), }, }) // create lambda function with previously created AmazonDynamoDBFullAccess role lambdaFunction := awscdklambdagoalpha.NewGoFunction(stack, jsii.String("myGoHandler"), &awscdklambdagoalpha.GoFunctionProps{ Runtime: awslambda.Runtime_GO_1_X(), Entry: jsii.String("./lambda-handler"), Bundling: &awscdklambdagoalpha.BundlingOptions{ GoBuildFlags: jsii.Strings(`-ldflags "-s -w"`), }, Role: dynamoDBRole, }) // create DynamoDB table awsdynamodb.NewTable(stack, jsii.String("myDynamoDB"), &awsdynamodb.TableProps{ BillingMode: awsdynamodb.BillingMode_PAY_PER_REQUEST, TableName: jsii.String("MyDynamoDB"), PartitionKey: &awsdynamodb.Attribute{ Name: aws.String("ID"), Type: awsdynamodb.AttributeType_STRING, }, }) // log lambda function ARN awscdk.NewCfnOutput(stack, jsii.String("lambdaFunctionArn"), &awscdk.CfnOutputProps{ Value: lambdaFunction.FunctionArn(), Description: jsii.String("Lambda function ARN"), }) return stack } func main() { app := awscdk.NewApp(nil) NewLambdaDynamodbStack(app, "LambdaDynamodbStack", &LambdaDynamodbStackProps{ awscdk.StackProps{ Env: env(), }, }) app.Synth(nil) } func env() *awscdk.Environment { return nil }