使用 Lambda 处理数据

步骤 1：创建 IAM 角色以向您的函数授予访问 AWS 资源的权限

1. 在 IAM 控制台中，打开角色页面。

2. 选择创建角色。

3. 在选择受信任的实体页面上，请执行以下操作：

   • 在可信实体类型中，选择AWS服务。

   • 在用例中，对于服务或用例，选择 Lambda。

   • 选择下一步。

     

4. 在 “添加权限” 页面中，执行以下操作：

   • 在权限策略中，选择 AWSLambdaKinesisExecutionRole （以及 AWSKeyManagementServicePowerUser 是否已加密 Kinesis 流）。

   • 将 “设置权限边界” 中的配置保持不变。

   • 选择下一步。

     

5. 在 “名称、查看和创建” 页面中，执行以下操作：

   • 在角色详细信息中，在角色名称中，输入角色的名称。例如lambda-kinesis-role。您也可以选择添加可选的描述。

   • 保留步骤 1：选择可信实体和步骤 2：按原样添加权限的设置。您可以在步骤 3：添加标签中选择添加标签以跟踪您的资源。

   

6. 选择创建角色。

步骤 2：创建 Lambda 函数

1. 在 Lambda 控制台中打开函数页面。

2. 选择创建函数。

3. 选择使用蓝图。

4. 在蓝图搜索栏中，搜索并选择 kinesis-process-record (nodejs) 或。kinesis-process-record-python

5. 选择配置。

   

步骤 3：配置 Lambda 函数

1. 选择函数名称。

2. 选择在第一步中创建的角色作为执行角色。

3. 配置 Kinesis 触发器。

   1. 选择您的 Kinesis 流。

   2. 单击创建函数。

   

步骤 4：在 AWS Lambda 控制台中启用 Kinesis 触发器

1. 在配置选项卡中，选择触发器。

2. 选中 Kinesis 流名称旁边的框，然后选择启用。

   

本示例中使用的蓝图仅使用来自选定数据流的日志数据。您可以在之后进一步编辑 Lambda 函数代码以完成更复杂的任务。