如何扩展或覆盖AWS EventBridge事件字段适配Lambda输入

已通过AWS CDK完成AWS EventBridge与AWS Lambda的集成并创建了Rule。现有如下格式的EventBridge事件：

{
  "event": {
    "version": "0",
    "id": "e7e4d675-1bea-ad19-ffa3-4d6e962e15af",
    "detail-type": "SOMETHING_HAPPENED",
    "source": "source",
    "account": "111111111111",
    "time": "2023-02-23T14:52:34Z",
    "region": "eu-west-1",
    "resources": [],
    "detail": {
      "data": { "key": "value" },
      "metadata": { "correlation-id": "some uuid" }
    }
  }
}

希望在Lambda的输入中移除metadata字段，并将detail替换为嵌套的data字段，同时保留其他字段，目标输入格式如下：

{
  "event": {
    "version": "0",
    "id": "e7e4d675-1bea-ad19-ffa3-4d6e962e15af",
    "detail-type": "SOMETHING_HAPPENED",
    "source": "source",
    "account": "111111111111",
    "time": "2023-02-23T14:52:34Z",
    "region": "eu-west-1",
    "resources": [],
    "detail": { "key": "value" }
  }
}

请问是否可以扩展或替换原事件的部分字段？

完全可以通过EventBridge Rule的**输入转换（Input Transformation）**功能实现字段替换与移除，无需在Lambda内部处理原始事件。在AWS CDK中，可通过配置RuleTargetInput定义转换规则。

具体实现方式 #

1. 提取目标字段：通过路径引用从原始事件中提取需要保留的字段，以及要替换到detail位置的data字段。
2. 重组事件结构：将提取的字段重新组合成目标格式，覆盖原detail字段并剔除metadata。

CDK代码示例（TypeScript） #

import * as cdk from 'aws-cdk-lib';
import * as events from 'aws-cdk-lib/aws-events';
import * as targets from 'aws-cdk-lib/aws-events-targets';
import * as lambda from 'aws-cdk-lib/aws-lambda';

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

    // 已定义的Lambda函数
    const myLambda = new lambda.Function(this, 'MyLambda', {
      runtime: lambda.Runtime.NODEJS_18_X,
      handler: 'index.handler',
      code: lambda.Code.fromAsset('lambda'),
    });

    // 创建EventBridge Rule
    const eventRule = new events.Rule(this, 'MyEventRule', {
      eventPattern: {
        source: ['source'],
        detailType: ['SOMETHING_HAPPENED'],
      },
    });

    // 配置输入转换规则
    const transformedInput = events.RuleTargetInput.fromObject({
      event: {
        version: <any>events.EventField.fromPath('$.event.version'),
        id: <any>events.EventField.fromPath('$.event.id'),
        'detail-type': <any>events.EventField.fromPath('$.event.detail-type'),
        source: <any>events.EventField.fromPath('$.event.source'),
        account: <any>events.EventField.fromPath('$.event.account'),
        time: <any>events.EventField.fromPath('$.event.time'),
        region: <any>events.EventField.fromPath('$.event.region'),
        resources: <any>events.EventField.fromPath('$.event.resources'),
        detail: <any>events.EventField.fromPath('$.event.detail.data'),
      },
    });

    // 将Lambda设为Rule目标并应用转换
    eventRule.addTarget(new targets.LambdaFunction(myLambda, {
      event: transformedInput,
    }));
  }
}

简化写法（InputPath + InputTemplate） #

若不想逐个字段映射，可结合路径提取与模板组合：

const transformedInput = events.RuleTargetInput.fromTemplate(
  JSON.stringify({
    event: {
      version: '<version>',
      id: '<id>',
      'detail-type': '<detail-type>',
      source: '<source>',
      account: '<account>',
      time: '<time>',
      region: '<region>',
      resources: '<resources>',
      detail: '<data>'
    }
  }),
  events.InputPath.fromJsonPath('$.event'),
  {
    version: '$.version',
    id: '$.id',
    'detail-type': '$.detail-type',
    source: '$.source',
    account: '$.account',
    time: '$.time',
    region: '$.region',
    resources: '$.resources',
    data: '$.detail.data'
  }
);

核心说明 #

• 转换逻辑在EventBridge层面完成，Lambda直接接收处理后的事件，减少函数内部逻辑。
• 所有字段均可通过路径引用或模板变量关联原始事件的对应位置。
• 后续调整字段结构仅需修改CDK配置，重新部署即可生效。

内容的提问来源于stack exchange，提问作者Kanstantsin T.