AWS CDKでLambda Durable Functionsがサポートされたので早速試してみた #AWSreInvent

lambda-durable-function-cdk-test/
├── infra/                    # CDKプロジェクト
│   ├── lib/
│   │   └── lambda-durable-function-cdk-test-stack.ts
│   └── package.json
└── server/                   # Lambdaハンドラー
    ├── src/
    │   └── index.ts
    └── package.json

"dependencies": {
+ "aws-cdk-lib": "2.232.0",
  "constructs": "^10.0.0"
}

import { Duration } from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as path from 'path';

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

    new lambda.Function(this, 'LambdaDurableFunction', {
      runtime: lambda.Runtime.NODEJS_24_X,
      handler: 'index.handler',
      code: lambda.Code.fromAsset(path.join(__dirname, '../../server/dist')),
+     durableConfig: {
+       executionTimeout: Duration.hours(1),
+       retentionPeriod: Duration.days(30),
+     },
    });
  }
}

#!/usr/bin/env node
import * as cdk from 'aws-cdk-lib/core';
import { LambdaDurableFunctionCdkTestStack } from '../lib/lambda-durable-function-cdk-test-stack';

const app = new cdk.App();
new LambdaDurableFunctionCdkTestStack(app, 'LambdaDurableFunctionCdkTestStack', {
+   // Lambda Durable Functions は現在オハイオ（us-east-2）でのみ利用可能
+   env: { region: 'us-east-2' },
+ });

cd server
npm install @aws/durable-execution-sdk-js

{
  "name": "lambda-durable-function-server",
  "version": "1.0.0",
  "private": true,
  "dependencies": {
+   "@aws/durable-execution-sdk-js": "^1.0.0"
  },
  "devDependencies": {
    "@types/node": "^22.0.0",
    "typescript": "~5.7.0"
  }
}

import {
  DurableContext,
  withDurableExecution,
} from "@aws/durable-execution-sdk-js";

export const handler = withDurableExecution(
  async (event, context) => {
    const orderId = event.orderId;

    // ステップ1: 注文のバリデーション
    const validationResult = await context.step(async (stepContext) => {
      stepContext.logger.info(`Validating order ${orderId}`);
      return { orderId, status: "validated" };
    });

    // ステップ2: 決済処理
    const paymentResult = await context.step(async (stepContext) => {
      stepContext.logger.info(`Processing payment for order ${orderId}`);
      return { orderId, status: "paid", amount: 99.99 };
    });

    // 外部確認をシミュレートするために10秒待機
    // この間、コンピュート料金は発生しない
    await context.wait({ seconds: 10 });

    // ステップ3: 注文の確定
    const confirmationResult = await context.step(async (stepContext) => {
      stepContext.logger.info(`Confirming order ${orderId}`);
      return { orderId, status: "confirmed" };
    });

    return {
      orderId: orderId,
      status: "completed",
      steps: [validationResult, paymentResult, confirmationResult],
    };
  }
);

cd server
npm run build

cd infra
cdk bootstrap --region us-east-2 # オハイオリージョンでCDKを使うのが初めての場合、Bootstrapを実行
cdk deploy