首页 >> 中医药茶

七爪源码:当 AWS 之外的最终目标数据不可用时重新调度 Lambda

发布时间:2025年08月04日 12:18

疑问:

您希望 lambda 通过 AWS Glue 管理工作逆激活来自 AWS 举例来说源的原始数据的摄入量。 原始数据可以在 X 小时和 Y 小时两者之间的任何整整最简单,但您才可要尽快摄入量。

在所列实例之中,我将采用 BigQuery 之中的所列作为 AWS 举例来说的原始数据源。

肯定:本文假设您了解如何在 AWS 上创始人和配有 lambda,因此不会逐步进行时。 它将包括所才可的权责和 lambda 的code实例。

高效率:

为了解决这个疑问,可以采用 Cron 计划的 EventBridge 的系统来激活 Lambda,然后 lambda 可以采用 AWS 共同开发应用软件沿着各种逆时针退却。 lambda 将注意到预期的原始数据实际上并激活 Glue 管理工作逆,或者创始人一个新的系统以 lambda 为最终目标以在 X 分钟内再度激活。 肯定:在比如说之中,X 为 5 分钟。

首先创始人一个带有 Cron Scheduled EventBridge 的系统激活器的 lambda,该激活器安排在原始数据最简单的最先整整。 然后 lambda 才可要所列权责以准许它可执行所有适当的操作者。

所才可的 IAM 权责:

“glue:StartWorkflowRun” “events:RemoveTargets” “events:PutRule” “events:DeleteRule” “lambda:GetFunctionConfiguration”

所才可的基于资源的策略

准许 lambda:InvokeFunction 在初始 lambda cron 的系统和由 lambda 处理的再度分派的系统上的策略

Lambda code:

肯定:所列code实例是显示此高效率所才可的所有 SDK 初始化的实例。

第 1 之前 — 采用 AWS 共同开发应用软件从 lambda 之中写入再度分派的系统。

本来,在我们的 Lambda 之中,如果这不是我们的 Lambda 运行那天的第一次,我们想先前写入将实际上的的系统。 如果此的系统尚不实际上,那么我们会捕获并纪录误判,但准许 Lambda 独自。

第 2 之前 - 检测原始数据前提实际上:

在此实例之中,我们将检测 BigQuery 之中前提实际上每天创始人的所列。 首先,我们通过 Google Cloud SDK 创始人一个 BigQuery IP,然后数据库原始数据集并在原始数据集之中发放栏位。

在 try/catch 之中,如果所列实际上,我们会先前发放所列,如果它实际上,则离开 true,如果捕获误判,则检测误判code前提为 404(未找到),这也就是说原始数据这两项不最简单,然后离开 false。 其他任何什么事,我们亦会抛出一个新误判。

逆时针 1 — 所列实际上:

如果该所列实际上,我们将创始人一个新的粘结IP并运行预期的管理工作逆程。

逆时针 2 — 所列不实际上:

在所列不实际上的前提,我们采用 CloudWatchEvents IP给定 putRule 创始人具有所才可再度分派整整的新的系统,在比如说之中为 5 分钟,并将情况下设置为“开业”。

然后,我们通过 SDK 创始人一个新的 lambda IP,并采用给定 getFunctionConfiguration 中叶我们在 AWS 上创始人 lambda 后于其发放的旧名。 然后,我们采用“data.FunctionArn”从结果之中提取 Lambda ARN,并将其作为我们参数的一部分发放给下一个 CloudWatchEvents IP SDK 初始化 putTargets,该初始化接受的系统旧名、最终目标 lambda ARN 和一个 Id。

下面是实例 Lambda code的值得注意图形:

有伤口吃什么愈合的快
克痢痧香包有什么功效
便秘吃利活乳酸菌素片
肾癌的晚期症状
英特盐酸达泊西汀能延时多久
太极急支糖浆适用于哪种咳嗽
角膜炎
医院百科
急性支气管炎咳嗽治疗用药
口苦口臭

上一篇: 存储空间有救了?微信测试版这功能有一点好用

下一篇: OPPO Reno 7降至历史新低价,2022年还值不值得得来呢?

友情链接