使用 Lambda 在 EventBridge 中安排事件

在这篇博文中，我们将探讨如何使用 AWS EventBridge Scheduler 和 AWS Lambda 安排事件。此方法高效且可扩展，确保您的应用程序可以处理多个计划事件，而无需创建混乱的单独 EventBridge 规则。让我们潜入吧！

什么是 AWS EventBridge？

AWS EventBridge 是一种无服务器事件总线服务，可让您轻松使用来自您自己的应用程序、集成软件即服务 (SaaS) 应用程序和 AWS 服务的数据来连接应用程序。 EventBridge 提供来自事件源的实时数据流，并将该数据路由到 AWS Lambda、Amazon SNS 等目标。

什么是 AWS Lambda？

AWS Lambda 是一种无服务器计算服务，让您无需预置或管理服务器即可运行代码。您可以直接从其他 AWS 服务（例如 S3、DynamoDB 或 EventBridge）触发 Lambda 函数，并自动从每天几个请求扩展到每秒数千个请求。

先决条件

在我们开始之前，请确保您具备以下条件：

1. AWS 账户
2. Node.js 基础知识
3. 您的计算机上配置的 AWS CLI

步骤 1：设置您的 AWS 环境

创建 IAM 角色

首先，我们需要创建一个 IAM 角色，以允许 AWS EventBridge Scheduler 调用您的 Lambda 函数。

1. 转到 IAM 控制台：导航到 IAM 控制台，从左侧导航窗格中选择角色，然后单击创建角色。

2. 选择可信实体：选择AWS 服务，选择Lambda，然后单击下一步：权限。

3. 附加策略：附加以下托管策略：

   • AWSLambdaBasicExecutionRole：提供基本的 Lambda 执行权限。
   • AmazonEventBridgeSchedulerFullAccess：允许 EventBridge Scheduler 管理计划。

4. 查看并创建：提供角色名称，例如 LambdaExecutionRole，查看设置，然后单击 创建角色。

5. 更新信任关系：角色创建后，进入角色详情页面。在信任关系选项卡下，单击编辑信任关系。更新信任策略以包含 Scheduler.amazonaws.com 服务：
   

   {
     "Version": "2012-10-17",
     "Statement": [
       {
         "Effect": "Allow",
         "Principal": {
           "Service": "lambda.amazonaws.com"
         },
         "Action": "sts:AssumeRole"
       },
       {
         "Effect": "Allow",
         "Principal": {
           "Service": "scheduler.amazonaws.com"
         },
         "Action": "sts:AssumeRole"
       }
     ]
   }

第 2 步：创建 Lambda 函数

我们将创建一个 Lambda 函数来处理计划的事件。

1. 转到 Lambda 控制台：导航到 Lambda 控制台，单击 创建函数，然后选择 从头开始创作。

2. 配置 Lambda 函数：将函数名称设置为 processScheduledEvent，选择 Node.js 16.x 作为运行时，并使用您之前创建的现有角色 (LambdaExecutionRole)。单击创建函数。

3. 添加函数代码：将默认代码替换为您处理事件的逻辑。例如，您可以记录事件详细信息或根据事件数据执行特定操作：
   

   {
     "Version": "2012-10-17",
     "Statement": [
       {
         "Effect": "Allow",
         "Principal": {
           "Service": "lambda.amazonaws.com"
         },
         "Action": "sts:AssumeRole"
       },
       {
         "Effect": "Allow",
         "Principal": {
           "Service": "scheduler.amazonaws.com"
         },
         "Action": "sts:AssumeRole"
       }
     ]
   }

1. 部署函数：点击部署保存更改。

第 3 步：安排活动

现在，让我们编写代码以使用 AWS EventBridge Scheduler 安排事件。

首先，安装必要的AWS SDK模块：

   exports.handler = async (event) => {
     const eventDetails = event;

     // Your logic to process the event
     console.log("Processing scheduled event:", eventDetails);

     // Example: Process event
     // processEvent(eventDetails);

     return {
       statusCode: 200,
       body: JSON.stringify('Event processed successfully'),
     };
   };

以下是实现调度功能的步骤总结：

提取事件详细信息

从应用程序的输入中提取事件详细信息。这是一个例子：

npm install @aws-sdk/client-scheduler @aws-sdk/client-lambda

将 IST 转换为 UTC

将预定时间从 IST（印度标准时间）转换为 UTC（协调世界时）。

const eventDetails = {
  name: "TEST-EVENT-01",
  userId: "USER123",
  eventId: "EVENT-001",
  eventTime: '2024-12-17T18:05:00+05:30' // IST time in ISO format
};

设置 UTC 时间字符串的格式

确保 UTC 时间字符串采用 EventBridge Scheduler 所需的正确格式 (yyyy-MM-ddTHH:mm:ssZ)。

const istTime = new Date(eventDetails.eventTime); // IST time
const utcTime = new Date(istTime.getTime() - 5.5 * 60 * 60 * 1000); // Convert to UTC

创建 EventBridge 时间表

使用 AWS SDK 创建 EventBridge 计划，指定 Lambda 函数 ARN 作为目标并包含事件详细信息作为输入。

const utcString = utcTime.toISOString().split('.')[0] + 'Z';

结论

在这篇博文中，我们演练了使用 AWS EventBridge Scheduler 和 Lambda 设置计划事件的过程。这种方法确保我们的应用程序可以高效且可扩展地处理多个计划事件。借助 AWS 的强大功能，您可以构建强大的功能来增强用户体验并简化操作。

编码愉快！

以上是使用 Lambda 在 EventBridge 中安排事件的详细内容。更多信息请关注PHP中文网其他相关文章！