使用 Lambda 在 EventBridge 中安排事件

本文将介绍如何利用 AWS EventBridge Scheduler 和 AWS Lambda 来安排事件。此方法高效且可扩展，能够轻松处理多个计划任务，避免了创建多个 EventBridge 规则的复杂性。

什么是 AWS EventBridge？

AWS EventBridge 是一款无服务器事件总线服务，用于连接应用程序，并处理来自应用程序、SaaS 应用和 AWS 服务的数据。它提供实时数据流，并将数据路由到 AWS Lambda、Amazon SNS 等目标。

什么是 AWS Lambda？

AWS Lambda 是一款无服务器计算服务，允许您在无需管理服务器的情况下运行代码。Lambda 函数可由其他 AWS 服务（例如 S3、DynamoDB 或 EventBridge）触发，并根据需求自动扩展。

前提条件

开始之前，请确保您已准备好以下条件：

1. AWS 账户
2. Node.js 基础知识
3. 已配置的 AWS CLI

步骤 1：设置 AWS 环境

创建 IAM 角色

首先，创建一个 IAM 角色，允许 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 作为运行时，并使用您之前创建的 IAM 角色 (LambdaExecutionRole)。点击“创建函数”。
3. 添加函数代码：替换默认代码，添加处理事件的逻辑。例如，记录事件详细信息或执行特定操作：

exports.handler = async (event) => {
  const eventDetails = event;
  console.log("Processing scheduled event:", eventDetails);
  return {
    statusCode: 200,
    body: JSON.stringify('Event processed successfully'),
  };
};

4. 部署函数：点击“部署”保存更改。

步骤 3：安排事件

使用 AWS SDK 创建 EventBridge 计划。

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

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

以下步骤总结了如何实现调度功能：

提取事件详细信息

从应用输入中提取事件信息。例如：

const eventDetails = {
  name: "test-event-01",
  userId: "user123",
  eventId: "event-001",
  eventTime: '2024-12-17T18:05:00+05:30' // IST 时间，ISO 格式
};

将 IST 转换为 UTC

将 IST 时间转换为 UTC 时间。

const istTime = new Date(eventDetails.eventTime);
const utcTime = new Date(istTime.getTime() - 5.5 * 60 * 60 * 1000);

设置 UTC 时间字符串格式

确保 UTC 时间字符串格式符合 EventBridge Scheduler 的要求 (yyyy-mm-ddThh:mm:ssZ)。

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

创建 EventBridge 计划

使用 AWS SDK 创建 EventBridge 计划，指定 Lambda 函数 ARN 作为目标，并包含事件详细信息作为输入。（请替换您的区域、账户 ID 和 Lambda 函数 ARN）

// ... (AWS SDK 代码，类似于原文中的代码，需根据您的实际情况修改) ...

结论

本文演示了如何使用 AWS EventBridge Scheduler 和 Lambda 设置计划事件。此方法高效且可扩展，方便处理多个计划任务。