Shi*_*hti 5 mapreduce amazon-sqs amazon-web-services aws-lambda
我有一个 Lambda 函数,它会生成许多工作 Lambda 函数,如果出现任何错误,每个工作函数都会发布到 SQS 队列。
有一个 UI 可以长时间轮询 SQS 队列以查找任何错误。我的问题是我如何知道处理何时完成?
由于第一个 Lambda 函数(生成工作器 Lambda 函数)异步运行,也就是说,它将数据拆分到工作器 Lambda 函数中,然后返回/完成。我需要有能力弄清楚处理何时完成。
我只将错误发布到 SQS 队列而不是成功的原因是,如果我有 10,000 个对象要处理并且有 9,000 个成功,我将不得不执行很多操作ReceiveMessages
(SQS API 调用以从 SQS 检索项目)队列)在 UI/客户端(如果我将每次调用接收的最大消息数指定为 10 条,则可能约为 900 次调用。每次调用无法从队列中检索超过 10 条消息。)
我怎样才能克服这个设计问题?
我正在使用 API Gateway、AWS Lambda 和 Dynamo DB(请随意推荐任何其他可以使工作更轻松地完成的 Amazon/AWS 服务。)
归档时间: |
|
查看次数: |
689 次 |
最近记录: |