もう二度と 10日間で AWS Lambda 関数を 28億回 実行させない

import { LambdaClient, InvokeCommand }  from '@aws-sdk/client-lambda';
const lambda = new LambdaClient({});

export const handler = async (event) => {
  console.log("Lambda executed with event:", event);

  // 自分自身を呼び出す
  await lambda.send(new InvokeCommand({
    FunctionName: "SelfCallingLambda",
    InvocationType: "Event", // 非同期呼び出し
    Payload: JSON.stringify({ triggeredBy: "self" }),
  }));

  console.log("Self-invocation triggered");
  return { statusCode: 200, body: "Self-invoked!" };
};

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as s3 from 'aws-cdk-lib/aws-s3';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as s3Notifications from 'aws-cdk-lib/aws-s3-notifications';

export class S3LoopDynamicStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    // バケットとLambdaのペア数
    const numBuckets = 10;

    const buckets: s3.Bucket[] = [];
    const lambdas: lambda.Function[] = [];

    // バケットを作成
    for (let i = 0; i < numBuckets; i++) {
      const bucket = new s3.Bucket(this, `Bucket${i}`, {
        bucketName: `s3-loop-bucket-${i}`,
        removalPolicy: cdk.RemovalPolicy.DESTROY,
        autoDeleteObjects: true,
      });
      buckets.push(bucket);
    }

    // Lambdaを作成
    for (let i = 0; i < numBuckets; i++) {
      const lambdaFn = new cdk.aws_lambda_nodejs.NodejsFunction(this, `Lambda${i}`, {
        functionName: `LoopLambda${i}`,
        runtime: lambda.Runtime.NODEJS_20_X,
        handler: 'index.handler',
        entry: 'funcs/loop-s3/index.js',
        environment: {
          BUCKET_NAME: buckets[(i + 1) % numBuckets].bucketName,
        }
      });
      lambdas.push(lambdaFn);
    }

    // イベント通知の設定
    for (let i = 0; i < numBuckets; i++) {
      buckets[i].addEventNotification(
        s3.EventType.OBJECT_CREATED,
        new s3Notifications.LambdaDestination(lambdas[i])
      );
      buckets[i].grantReadWrite(lambdas[(i + numBuckets - 1) % numBuckets]);
    }
  }
}

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as s3 from 'aws-cdk-lib/aws-s3';
import * as sns from 'aws-cdk-lib/aws-sns';
import * as sqs from 'aws-cdk-lib/aws-sqs';
import * as s3Notifications from 'aws-cdk-lib/aws-s3-notifications';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import { SqsEventSource, SnsEventSource } from 'aws-cdk-lib/aws-lambda-event-sources';

export class LoopS3SnsSqsStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    // S3バケットの作成
    const bucket = new s3.Bucket(this, 'BucketFirst', {
      bucketName: 'loop-sqs-sns-bucket',
      removalPolicy: cdk.RemovalPolicy.DESTROY,
      autoDeleteObjects: true,
    });

    // S3バケットにイベント通知を追加(S3 -> SNS)
    const topic = new sns.Topic(this, 'TopicFirst', {
      displayName: 'S3LoopTopic',

    });
    bucket.addEventNotification(
      s3.EventType.OBJECT_CREATED,
      new s3Notifications.SnsDestination(topic)
    );

    // SQSトピック
    const queue = new sqs.Queue(this, 'QueueFirst', {
      queueName: 'S3LoopQueue',
    });

    // Lambda -> SQS
    for (let i = 0; i < 2; i++) {
      const lambdaFn = new cdk.aws_lambda_nodejs.NodejsFunction(this, `Lambda${i}`, {
        functionName: `WorkerLambda${i}`,
        runtime: lambda.Runtime.NODEJS_20_X,
        handler: 'index.handler',
        entry: 'funcs/sns-worker/index.js',
        environment: {
          BUCKET_NAME: bucket.bucketName,
          TOPIC_ARN: topic.topicArn,
          QUEUE_URL: queue.queueUrl,
        },
      });
      queue.grantSendMessages(lambdaFn);
      topic.grantPublish(lambdaFn);
      lambdaFn.addEventSource(new SnsEventSource(topic));
    }

    // SQS -> Lambda
    const consumeLambda = new cdk.aws_lambda_nodejs.NodejsFunction(this, 'SubscriberLambda', {
      functionName: 'ConsumeLambda',
      runtime: lambda.Runtime.NODEJS_20_X,
      handler: 'index.handler',
      entry: 'funcs/sqs-consume/index.js',
      environment: {
        BUCKET_NAME: bucket.bucketName,
        QUEUE_URL: queue.queueUrl,
      },
    });
    bucket.grantReadWrite(consumeLambda);
    queue.grantConsumeMessages(consumeLambda);
    consumeLambda.addEventSource(new SqsEventSource(queue));
  }
}