教程：将跨账户 Amazon SQS 队列用作事件源

创建执行角色

1. 在 AWS Identity and Access Management IAM 控制台中，打开 Roles (角色) 页面。

2. 选择 Create role（创建角色）。

3. 创建具有以下属性的角色。

   • Trusted entity (可信任的实体) – AWS Lambda

   • Permissions（权限） – AWSLambdaSQSQueueExecutionRole

   • Role name（角色名称）– cross-account-lambda-sqs-role

创建函数

1. 将代码示例保存为名为 index.mjs 的文件。

2. 创建部署程序包。

   zip function.zip index.mjs

3. 使用 create-function AWS Command Line Interface (AWS CLI) 命令创建函数。

   aws lambda create-function --function-name CrossAccountSQSExample \
   --zip-file fileb://function.zip --handler index.handler --runtime nodejs18.x \
   --role arn:aws:iam::<AccountA_ID>:role/cross-account-lambda-sqs-role

1. 将下列 JSON 保存为名为 input.txt 的文件。

   {
       "Records": [
           {
               "messageId": "059f36b4-87a3-44ab-83d2-661975830a7d",
               "receiptHandle": "AQEBwJnKyrHigUMZj6rYigCgxlaS3SLy0a...",
               "body": "test",
               "attributes": {
                   "ApproximateReceiveCount": "1",
                   "SentTimestamp": "1545082649183",
                   "SenderId": "AIDAIENQZJOLO23YVJ4VO",
                   "ApproximateFirstReceiveTimestamp": "1545082649185"
               },
               "messageAttributes": {},
               "md5OfBody": "098f6bcd4621d373cade4e832627b4f6",
               "eventSource": "aws:sqs",
               "eventSourceARN": "arn:aws:sqs:us-east-1:111122223333:example-queue",
               "awsRegion": "us-east-1"
           }
       ]
   }

   上述 JSON 模拟 Amazon SQS 可能发送到您的 Lambda 函数的事件，其中 "body" 包含来自该队列的实际消息。

2. 运行以下 invoke AWS CLI 命令。

   aws lambda invoke --function-name CrossAccountSQSExample \
   --cli-binary-format raw-in-base64-out \
   --payload file://input.txt outputfile.txt

   如果使用 cli-binary-format 版本 2，则 AWS CLI 选项是必需的。要将其设为默认设置，请运行 aws configure set cli-binary-format raw-in-base64-out。有关更多信息，请参阅版本 2 的 AWS Command Line Interface 用户指南中的 AWS CLI 支持的全局命令行选项。

3. 在 outputfile.txt 文件中验证输出。

创建队列

1. 打开 Amazon SQS 控制台。

2. 选择创建队列。

3. 创建具有以下属性的队列。

   • 类型 - 标准

   • 名称 - LambdaCrossAccountQueue

   • 配置 - 保留默认设置。

   • 访问策略 - 选择 Advanced (高级)。粘贴以下 JSON 策略：

     {
        "Version": "2012-10-17",
        "Id": "Queue1_Policy_UUID",
        "Statement": [{
           "Sid":"Queue1_AllActions",
           "Effect": "Allow",
           "Principal": {
              "AWS": [
                 "arn:aws:iam::<AccountA_ID>:role/cross-account-lambda-sqs-role"
              ]
           },
           "Action": "sqs:*",
           "Resource": "arn:aws:sqs:us-east-1:<AccountB_ID>:LambdaCrossAccountQueue"
         }
       ]
     }

     此策略授予账户 A 中 Lambda 执行角色权限，以使用 Amazon SQS 队列中的消息。

4. 创建队列后，记录其 Amazon Resource Name (ARN)。在下一步中将该队列与您的 Lambda 函数关联时，您将需要此类信息。

删除执行角色

1. 打开 IAM 控制台的角色页面。

2. 选择您创建的执行角色。

3. 选择删除。

4. 在文本输入字段中输入角色名称，然后选择 Delete（删除）。

删除 Lambda 函数

1. 打开 Lamba 控制台的 Functions（函数）页面。

2. 选择您创建的函数。

3. 依次选择操作和删除。

4. 在文本输入字段中键入 delete，然后选择 Delete（删除）。

删除 Amazon SQS 队列

1. 登录到 AWS Management Console 并打开 Amazon SQS 控制台，网址：https://console.aws.amazon.com/vpc/。

2. 选择创建的队列。

3. 选择删除。

4. 在文本输入字段中输入 confirm。

5. 选择 Delete（删除）。