Lambda不会执行所有承诺

问题描述

我的Lambda函数为Pets API预先渲染了React用户界面。它由API Gateway端点调用。我正在根据cra-serverless项目改编该项目。我正在使用的NodeJS服务器框架是Koa。我做了一个异步handler函数来响应客户端请求。它做三件事：

1. 从Pet API获取数据并填充getCatsResponse。
2. 使用getCatsResponse对象呈现UI。
3. 将猫项目存储在DynamoDB表中以进行进一步处理。

我注意到这使我的请求花了很长时间才能得到答复，我认为这个问题有点开放性，但是我希望对这3点进行澄清：

1. 当我从由Promise.all()函数创建的Promise列表中删除.map()时，为什么项目没有插入表中？
   1. 我认为，由于这是一个异步函数调用，因此请求已发送，无需处理重新放置。我有什么误会？
2. 假设我需要等待所有Promise的问题解决，我是否应该将该职责委托给另一个Lambda函数？
   1. 如果是这样，我可以从此Lambda中调用该Lambda并将其遗忘（不必await即可解决），对吧？
3. 当我设置ctx.body时，仅当Lambda到达函数末尾时才发送该响应，对吗？

import koa from 'koa'
import http from 'koa-route'
import serve from 'koa-static'

import App from '../src/App'
import { paths } from './config'
import { render } from './lib/render'
import AWS from 'aws-sdk'
import GetCatsResponse from '../typings/GetCatsResponse'

import fetch from 'node-fetch';
import { Cat } from '../typings/Cat'

export const Router = new koa()
const DynamoDB: AWS.DynamoDB = new AWS.DynamoDB();

const handler = async (ctx: koa.Context) => {

  // Try Pet API
  let url = 'https://api.pets.com/v2/cats'
  let getCatsResponse: GetCatsResponse = Object.create(GetCatsResponse);
  await fetch(url).then((response: any) => response.json().then((jsonData: any) => {
    getCatsResponse = jsonData;
  }));
  console.log(getCatsResponse);

  // Render response body 
  ctx.body = render(getCatsResponse,App,ctx.request.path)

  // Enter item into DynamoDB
  return Promise.all(getCatsResponse.items.map((catResponse) => {
    const input: AWS.DynamoDB.PutItemInput = Cat.toDynamoDBTableItemInput(catResponse)
    console.log(input);
    return DynamoDB.putItem(input).promise()
      .then(() => {
        console.log('Inserted cat ID ' + catResponse.cat_id.toString());
      })
      .catch((err) => {
        console.error(err);
      });
  }))

}

Router.use(http.get('/',handler))
Router.use(http.get('/index.html',handler))

Router.use(serve(paths.assets))

Router.use(http.get('*',handler))

解决方法

1. 由于lambda是如何工作的：当到达末尾时，它不仅返回想要返回的内容，而且还终止了该过程。因此，如果这种情况发生得太快，您的呼叫甚至在被杀死之前甚至根本没有足够的时间来处理，并且不会在数据库中创建项目。

2. 是，但是您没有正当理由增加了复杂性。当然，您可以调用另一个lambda（例如，使用invokeAsync），但是您将遇到与上述完全相同的问题。同样，DynamoDB对于这样的简单操作相当快（阅读：非常），可能甚至比调用lambda还要快。

   但是，如果您担心速度，则可能需要执行以下操作，而不是多次调用putItem（如果您需要编写多个项目），而是调用batchWriteItem，从而允许您一次调用最多写入25个项目：因此，您实际上只有1个单次通话即可一次写入25个项目，而不是25个项目的25次网络延迟往返行程：https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html#batchWriteItem-property

3. 通常不熟悉此特定设置或koa，因此我不确定render通常在Lambda上做什么或如何工作。但是，如果您担心渲染会“停止”发生的情况，则可以改成类似以下内容的方法，这样做的好处是可以按照操作顺序（get the cats,THEN write them to DB,THEN return the body）更加明确

// Try Pet API
await fetch(url)...

// Enter item into DynamoDB
await Promise.all(...)

// Render response body 
ctx.body = render(getCatsResponse,App,ctx.request.path)