使用Api Gateway+EventBridge时，能否返回Lambda的响应结果？

你的核心问题是默认情况下EventBridge与Lambda的集成是异步的，它不会主动把Lambda的执行结果回传给API Gateway。要让客户端拿到Lambda的返回值，需要采用同步调用模式或者自定义回调机制，以下是具体实现方案：

方案一：使用EventBridge同步目标调用（推荐） #

EventBridge支持Request/Response模式的同步调用，配置后它会等待Lambda执行完成，并将结果返回给上游的API Gateway：

1. 配置API Gateway与EventBridge的同步集成

   • 在API Gateway的集成请求中，选择EventBridge作为目标时，指定InvocationType为REQUEST_RESPONSE（默认是EVENT异步模式）。
   • 如果使用API Gateway REST API，可在集成请求的映射模板中添加同步调用参数，示例模板：

     {
       "Entries": [
         {
           "Source": "api.gateway",
           "DetailType": "api.request",
           "Detail": "$util.escapeJavaScript($input.json('$'))",
           "EventBusName": "your-event-bus-name"
         }
       ],
       "InvocationType": "REQUEST_RESPONSE"
     }
     

2. 配置EventBridge规则的同步目标

   • 在EventBridge规则中添加Lambda作为目标时，设置调用模式为同步（控制台选“同步”选项，CLI则用--invocation-type RequestResponse参数）。

3. 处理API Gateway的响应映射
   EventBridge会将Lambda的返回结果包装在ResponseBody字段中，需要在API Gateway的集成响应中添加映射模板，解析出真实的Lambda结果：

   #set($inputRoot = $input.path('$'))
   $inputRoot.ResponseBody
   

   配置后客户端就能直接拿到Lambda返回的JSON内容。

注意事项 #

• 同步调用有30秒超时限制，Lambda执行时间必须控制在30秒内，否则EventBridge会返回超时错误给API Gateway。
• 确保EventBridge拥有调用Lambda的IAM权限（配置lambda:InvokeFunction策略），同时Lambda具备必要的执行权限。
• 如果Lambda抛出异常，EventBridge会将错误信息返回给API Gateway，需在API Gateway中配置错误状态码映射，将异常转换为合适的HTTP响应。

方案二：自定义异步回调机制（适合长耗时任务） #

如果Lambda执行时间超过30秒，无法使用同步模式，可通过自定义回调实现：

1. 在EventBridge事件中携带API Gateway上下文信息
   在API Gateway的集成请求模板中，将API Gateway的requestContext（含回调相关信息）传入EventBridge的事件Detail中：

   {
     "Entries": [
       {
         "Source": "api.gateway",
         "DetailType": "api.request",
         "Detail": "{\"requestBody\": $util.escapeJavaScript($input.json('$')), \"requestContext\": $util.escapeJavaScript($input.json('$.requestContext'))}",
         "EventBusName": "your-event-bus-name"
       }
     ]
   }
   

2. Lambda执行完成后主动回调API Gateway
   Lambda处理完成后，调用API Gateway的异步回调URL（从requestContext中获取callbackUrl），将结果返回。需确保Lambda拥有调用API Gateway的权限。

3. API Gateway配置异步响应
   将API Gateway配置为支持异步响应，比如使用Lambda集成的异步模式，或者配置WebSocket API实现实时回调。这种方式复杂度较高，适合处理长耗时任务。

内容的提问来源于stack exchange，提问作者Manuel Arevalo