移除await后AWS EventBridge无法二次触发Lambda函数求助

问题根源 #

当你移除await ebClient.send(command)里的await关键字后，sendMessage内部的EventBridge请求会变成未被等待的异步Promise。Lambda的handler函数在循环执行完所有sendMessage(dta)调用后会直接结束，而Lambda运行时会在handler执行完成后立即终止所有未完成的异步操作，导致后续的EventBridge事件还没发送成功就被中断，所以第二个Lambda无法收到后续的触发请求。

修复方案 #

必须保证所有异步请求都被完整执行，以下是两种可行的修复方式：

方式1：逐个等待异步请求完成 #

适合需要按顺序发送事件的场景：

const sendMessage = async (data) => {
  const ebClient = new EventBridgeClient({});
  const params = {
    Entries: [ 
      {
        Detail: JSON.stringify(data),
        DetailType: 'Message',
        EventBusName: 'default',
        Source: 'sendEvent',
        Time: new Date()
      }
    ]
  }
  const command = new PutEventsCommand(params);
  await ebClient.send(command); // 必须保留await，确保请求执行完成
}

export const handler = async (event) => {
  // 循环中逐个等待sendMessage执行完毕
  for (const dta of event.params.data) {
    await sendMessage(dta);
  }
}

方式2：并行处理所有请求（效率更高） #

适合不需要严格顺序、数据量不大的场景：

// 优化：将EventBridgeClient移到外部，避免每次调用重复初始化
const ebClient = new EventBridgeClient({});

const sendMessage = async (data) => {
  const params = {
    Entries: [ 
      {
        Detail: JSON.stringify(data),
        DetailType: 'Message',
        EventBusName: 'default',
        Source: 'sendEvent',
        Time: new Date()
      }
    ]
  }
  const command = new PutEventsCommand(params);
  return ebClient.send(command); // 返回Promise，后续统一等待
}

export const handler = async (event) => {
  // 生成所有请求的Promise数组，并行等待全部完成
  const eventPromises = event.params.data.map(dta => sendMessage(dta));
  await Promise.all(eventPromises);
}

额外优化建议 #

• 复用客户端实例：不要在sendMessage内部每次创建新的EventBridgeClient，移到函数外部可以减少性能损耗。
• 添加错误处理：避免单个请求失败导致整个handler终止，根据业务需求选择是否捕获异常：

const sendMessage = async (data) => {
  try {
    const params = { /* ... */ };
    const command = new PutEventsCommand(params);
    await ebClient.send(command);
  } catch (err) {
    console.error(`事件发送失败: ${err.message}`, data);
    // 可选：根据业务逻辑决定是否抛出错误或继续执行
  }
}

内容的提问来源于stack exchange，提问作者Ilya Shcherbakov