如何解决Lambda不会执行所有承诺
我的Lambda函数为Pets API预先渲染了React用户界面。它由API Gateway端点调用。我正在根据cra-serverless项目改编该项目。我正在使用的NodeJS服务器框架是Koa。我做了一个异步handler
函数来响应客户端请求。它做三件事:
- 从Pet API获取数据并填充
getCatsResponse
。 - 使用
getCatsResponse
对象呈现UI。 - 将猫项目存储在DynamoDB表中以进行进一步处理。
我注意到这使我的请求花了很长时间才能得到答复,我认为这个问题有点开放性,但是我希望对这3点进行澄清:
- 当我从由
Promise.all()
函数创建的Promise
列表中删除.map()
时,为什么项目没有插入表中?- 我认为,由于这是一个异步函数调用,因此请求已发送,无需处理重新放置。我有什么误会?
- 假设我需要等待所有
Promise
的问题解决,我是否应该将该职责委托给另一个Lambda函数?- 如果是这样,我可以从此Lambda中调用该Lambda并将其遗忘(不必
await
即可解决),对吧?
- 如果是这样,我可以从此Lambda中调用该Lambda并将其遗忘(不必
- 当我设置
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))
解决方法
-
由于lambda是如何工作的:当到达末尾时,它不仅返回想要返回的内容,而且还终止了该过程。因此,如果这种情况发生得太快,您的呼叫甚至在被杀死之前甚至根本没有足够的时间来处理,并且不会在数据库中创建项目。
-
是,但是您没有正当理由增加了复杂性。当然,您可以调用另一个lambda(例如,使用invokeAsync),但是您将遇到与上述完全相同的问题。同样,DynamoDB对于这样的简单操作相当快(阅读:非常),可能甚至比调用lambda还要快。
但是,如果您担心速度,则可能需要执行以下操作,而不是多次调用putItem(如果您需要编写多个项目),而是调用batchWriteItem,从而允许您一次调用最多写入25个项目:因此,您实际上只有1个单次通话即可一次写入25个项目,而不是25个项目的25次网络延迟往返行程:https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html#batchWriteItem-property
-
通常不熟悉此特定设置或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)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。