如何通过AWS Lambda获取SQS消息中的EC2实例ID？

当SQS触发Lambda时，Lambda的事件参数里包含了所有接收到的SQS消息。你需要从事件的Records数组里提取每条消息的body字段，这个字段就是你通过bash脚本发送的EC2实例ID。

1. Lambda事件结构说明 #

SQS触发的Lambda事件大致结构如下（简化版）：

{
  "Records": [
    {
      "messageId": "xxx",
      "receiptHandle": "xxx",
      "body": "i-1234567890abcdef0", // 这里就是你的实例ID
      "attributes": {...},
      "messageAttributes": {...},
      "md5OfBody": "xxx",
      "eventSource": "aws:sqs",
      "eventSourceARN": "arn:aws:sqs:region:account-id:queue-name",
      "awsRegion": "us-east-1"
    }
  ]
}

2. Python Lambda示例代码 #

下面是完整的Lambda函数示例，它会提取每个消息里的实例ID，然后执行EC2修改操作（示例为添加标签，可替换为你需要的操作）：

import boto3

ec2 = boto3.client('ec2')

def lambda_handler(event, context):
    # 遍历所有SQS消息
    for record in event['Records']:
        # 提取实例ID并去除可能的空白字符
        instance_id = record['body'].strip()
        print(f"开始处理实例: {instance_id}")
        
        # 替换为你需要的EC2修改操作，比如修改实例类型、添加标签等
        try:
            ec2.create_tags(
                Resources=[instance_id],
                Tags=[
                    {
                        'Key': 'ProcessedByLambda',
                        'Value': 'Completed'
                    }
                ]
            )
            print(f"实例 {instance_id} 处理成功")
        except Exception as e:
            print(f"实例 {instance_id} 处理失败: {str(e)}")
            # 可根据需求添加错误处理逻辑，例如将消息转入死信队列
    
    return {
        'statusCode': 200,
        'body': f"共处理 {len(event['Records'])} 条消息"
    }

3. 关键注意事项 #

• 权限配置：Lambda的执行角色需要添加对应权限：
  • SQS相关：sqs:ReceiveMessage、sqs:DeleteMessage、sqs:GetQueueAttributes（触发器会自动添加基础权限，建议根据实际场景确认）
  • EC2操作权限：比如ec2:CreateTags、ec2:ModifyInstanceAttribute等，根据你要执行的修改操作添加对应权限
• 批量消息处理：Lambda默认每次会从SQS拉取1-10条消息，因此代码必须遍历Records数组，逐个处理每条消息中的实例ID
• 错误处理：如果处理某条消息失败，Lambda会自动将消息放回SQS重试，达到重试次数后会转入死信队列（若已配置），可根据业务需求调整重试策略和错误处理逻辑

4. 验证方法 #

你可以在Lambda控制台的测试功能中，模拟一个包含目标实例ID的SQS事件，运行测试后查看日志，确认是否成功提取并修改实例。

内容的提问来源于stack exchange，提问作者Vitor Antoni