你如何并行运行的功能呢?

问题描述 投票:1回答:1

我的愿望是要检索的基于一些自定义的select语句数据库中的记录x个,输出将是JSON数据的数组。然后我想将阵列中的每个元件通入并联另一个lambda函数。

所以,如果返回1000条记录,1000个lambda函数需要并行(提高我的帐户限制什么,我需要)被执行。如果30出的1000失败,这是检索的记录的主要任务,需要了解它。

我挣扎放在一起这个简单的流程。

我目前使用JavaScript和AWS极光。我不是在寻找的node.js /检索数据,只是AWS步骤的功能配置,以及如何构建每个函数中的数组JavaScript代码。

谢谢。

amazon-web-services aws-step-functions
1个回答
2
投票

如果返回1000条记录,1000个lambda函数需要并行执行

你所想达到不被步骤功能的支持。根据收到的输入状态机任务,无法修改。因此,例如,一个并行任务不能被配置为添加/删除基于它在阵列中接收到的输入项目数的功能。

你或许应该考虑使用SQS Lambda trigger。从DB检索到的记录号码可被添加到SQS队列然后将接收到的每个项目触发lambda函数。

如果30出的1000失败,这是检索的记录的主要任务,需要了解它。

有多种方法来实现这一目标。如果LAMBDA返回错误SQS不会从队列中删除的项目。您可以根据您的要求配置DLQRedrivePolicy。或者你可能要拿出一个定制的解决方案,以保持数量上没有lambda表达式来调用获取从数据库记录的服务。

© www.soinside.com 2019 - 2024. All rights reserved.