import { Construct } from "constructs"; import * as cdk from "aws-cdk-lib"; import * as s3 from "aws-cdk-lib/aws-s3"; import * as events from "aws-cdk-lib/aws-events"; import * as path from "node:path"; import * as lambda from "aws-cdk-lib/aws-lambda"; import * as targets from "aws-cdk-lib/aws-events-targets"; import * as sqs from "aws-cdk-lib/aws-sqs"; import { SqsEventSource } from "aws-cdk-lib/aws-lambda-event-sources"; import * as sns from "aws-cdk-lib/aws-sns"; import { LambdaSubscription, EmailSubscription, } from "aws-cdk-lib/aws-sns-subscriptions"; export class S3EventbridgeTargetsStack extends cdk.Stack { constructor(scope: Construct, id: string, props?: cdk.StackProps) { super(scope, id, props); const ebSourceBucket = new s3.Bucket(this, "ebSourceBucket", { eventBridgeEnabled: true, removalPolicy: cdk.RemovalPolicy.DESTROY, blockPublicAccess: s3.BlockPublicAccess.BLOCK_ALL, }); const s3SourceRule = new events.Rule(this, "s3SourceRule", { eventPattern: { source: ["aws.s3"], detailType: ["Object Created"], detail: { bucket: { name: [ebSourceBucket.bucketName] } }, }, }); const ebLambda = new lambda.Function(this, "ebLambda", { runtime: lambda.Runtime.NODEJS_18_X, code: lambda.Code.fromAsset( path.join(__dirname, "./../../", "./functions/EbTriggered"), ), handler: "index.handler", environment: {}, }); s3SourceRule.addTarget(new targets.LambdaFunction(ebLambda)); const scheduleCronRule = new events.Rule(this, "scheduleCronRule", { description: "Trigger my ebSqs queue every 2 minutes.", schedule: events.Schedule.expression("cron(0/2 * * * ? *)"), }); const ebSqs = new sqs.Queue(this, "ebSqs", {}); scheduleCronRule.addTarget(new targets.SqsQueue(ebSqs)); const sqsTriggered = new lambda.Function(this, "sqsTriggered", { runtime: lambda.Runtime.NODEJS_18_X, code: lambda.Code.fromAsset( path.join(__dirname, "./../../", "./functions/SqSnsTriggered"), ), handler: "index.handler", environment: {}, }); sqsTriggered.addEventSource(new SqsEventSource(ebSqs, {})); const scheduleRateRule = new events.Rule(this, "scheduleRateRule", { description: "Trigger SNS every 5 days.", schedule: events.Schedule.rate(cdk.Duration.days(5)), }); const ebSns = new sns.Topic(this, "ebSns", {}); scheduleRateRule.addTarget(new targets.SnsTopic(ebSns)); const snsTriggered = new lambda.Function(this, "snsTriggered", { runtime: lambda.Runtime.NODEJS_18_X, code: lambda.Code.fromAsset( path.join(__dirname, "./../../", "./functions/SqSnsTriggered"), ), handler: "index.handler", environment: {}, }); ebSns.addSubscription(new LambdaSubscription(snsTriggered)); const email = new EmailSubscription("test@test.com"); ebSns.addSubscription(email); const defaultBus = events.EventBus.fromEventBusName( this, "Default bus", "default", ); // Akeero tags cdk.Tags.of(this).add("akeero:project-id", "2RYbBcCEDXD0JkgronbkKgMzD0o"); cdk.Tags.of(ebSourceBucket).add("akeero:id", "2RYbDDEUcFm2xFxkqKsTIwESszx"); cdk.Tags.of(ebLambda).add("akeero:id", "2RYbEgA4wbzot6CMhtO2hlraVRk"); cdk.Tags.of(ebSqs).add("akeero:id", "2RYbF5zivNfNySvs6pRT0ZPIYnO"); cdk.Tags.of(ebSns).add("akeero:id", "2RYbFaFgcloEwN2U0r0OoSc3oZS"); cdk.Tags.of(snsTriggered).add("akeero:id", "2RYbGQEF5syaeR759Hlve8uXOxM"); cdk.Tags.of(s3SourceRule).add("akeero:id", "2RqDLBnG27ORoryuXrkZz6MLwtq"); cdk.Tags.of(scheduleCronRule).add( "akeero:id", "2RqDPPvLYDBrpygkTwMqKSrlSWc", ); cdk.Tags.of(scheduleRateRule).add( "akeero:id", "2RqDQGBX6Mr7SwM8Kie1TkK0RHK", ); cdk.Tags.of(sqsTriggered).add("akeero:id", "2RqDioWdGOOb2osXfxqUOH0BRX0"); new cdk.CfnOutput(this, "AkeeroProjectId", { value: "2RYbBcCEDXD0JkgronbkKgMzD0o", }); new cdk.CfnOutput(this, "EbLambdaFunctionArn", { value: ebLambda.functionArn, }); new cdk.CfnOutput(this, "SqsTriggeredFunctionArn", { value: sqsTriggered.functionArn, }); new cdk.CfnOutput(this, "SnsTriggeredFunctionArn", { value: snsTriggered.functionArn, }); } }