サーバーレスアーキテクチャ：DXにおけるメリット・デメリットと実装戦略

// AWS Lambda関数の例（Node.js）
exports.handler = async (event) => {
    // イベントソース（S3、API Gateway、SQS等）からのトリガー
    console.log('受信イベント:', JSON.stringify(event, null, 2));
    
    // ビジネスロジックの実行
    const result = await processBusinessLogic(event);
    
    // レスポンスの返却
    return {
        statusCode: 200,
        body: JSON.stringify(result)
    };
};

async function processBusinessLogic(event) {
    // 実際の処理ロジック
    return { message: "処理完了", timestamp: new Date().toISOString() };
}

# AWS SAMテンプレートの例
Resources:
  GetProductFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: ./src/
      Handler: products.getProduct
      Runtime: nodejs14.x
      Events:
        GetProduct:
          Type: Api
          Properties:
            Path: /products/{productId}
            Method: get
  
  CreateProductFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: ./src/
      Handler: products.createProduct
      Runtime: nodejs14.x
      Events:
        CreateProduct:
          Type: Api
          Properties:
            Path: /products
            Method: post

# AWS CDKの例（TypeScript）
import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as apigateway from 'aws-cdk-lib/aws-apigateway';

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

    // Lambda関数の定義
    const handler = new lambda.Function(this, 'ApiHandler', {
      runtime: lambda.Runtime.NODEJS_14_X,
      code: lambda.Code.fromAsset('lambda'),
      handler: 'index.handler',
    });

    // API Gatewayの定義
    const api = new apigateway.RestApi(this, 'ServerlessApi', {
      restApiName: 'Serverless API Service',
      description: 'DXサービスのバックエンドAPI',
    });

    const integration = new apigateway.LambdaIntegration(handler);
    api.root.addMethod('GET', integration);
  }
}

// カート更新関数
exports.updateCart = async (event) => {
    const { userId, productId, quantity } = JSON.parse(event.body);
    
    // DynamoDBへのカート更新
    const params = {
        TableName: 'ShoppingCarts',
        Key: { userId },
        UpdateExpression: 'SET items.#productId = :quantity',
        ExpressionAttributeNames: { '#productId': productId },
        ExpressionAttributeValues: { ':quantity': quantity }
    };
    
    await dynamoDb.update(params).promise();
    
    // カート更新イベントの発行（他サービスへの通知）
    await eventBridge.putEvents({
        Entries: [{
            Source: 'com.example.cart',
            DetailType: 'CartUpdated',
            Detail: JSON.stringify({ userId, productId, quantity })
        }]
    }).promise();
    
    return { statusCode: 200, body: JSON.stringify({ success: true }) };
};

# Python AWS Lambda
def process_batch(event, context):
    # イベントからバッチパラメータを取得
    batch_size = event.get('batch_size', 100)
    start_id = event.get('start_id', 0)
    
    # データソースからレコード取得
    records = fetch_records(start_id, batch_size)
    
    results = []
    for record in records:
        # ビジネスロジック適用
        processed = apply_business_logic(record)
        results.append(processed)
    
    # 結果を保存
    save_results(results)
    
    # 次のバッチ呼び出し（Step Functionsと連携）
    if len(records) == batch_size:
        return {
            'continue': True,
            'next_id': start_id + batch_size
        }
    
    return {
        'continue': False,
        'processed_count': len(results)
    }