AWS新手求助：配置CloudWatch触发Lambda处理SQS新消息

Hey there! Since you're new to AWS, let me walk you through getting this set up step by step, plus share a pro tip that might make your workflow way more efficient.

一、按你的计划：用CloudWatch定时触发Lambda #

You’ve got the right idea here for a scheduled approach. Let’s break down the setup:

1. 创建CloudWatch EventBridge定时规则 #

• 打开CloudWatch控制台，进入EventBridge > 规则页面
• 点击「创建规则」，选择计划作为事件源
• 如果要每分钟触发一次，使用AWS Cron表达式：cron(0/1 * * * ? *)（注意：AWS Cron格式把分钟放在第一位，固定间隔调度时周字段用?）
• 在「目标」中选择你的Lambda函数，完成规则创建

2. 给Lambda配置SQS访问权限 #

Lambda需要权限读取和删除SQS队列的消息：

• 打开IAM控制台，找到你的Lambda执行角色
• 添加一条内联策略，包含权限：sqs:ReceiveMessage、sqs:DeleteMessage、sqs:GetQueueAttributes
• 将策略的资源设置为你的SQS队列ARN

3. Lambda代码示例（基于AWS GitHub示例调整） #

这里是一个Python版本的高效处理示例：

import boto3

# 初始化SQS客户端
sqs_client = boto3.client('sqs')
# 替换为你的SQS队列实际URL
SQS_QUEUE_URL = "https://sqs.<region>.amazonaws.com/<account-id>/your-queue-name"

def lambda_handler(event, context):
    # 批量拉取最多10条消息（SQS单次请求上限），启用长轮询
    response = sqs_client.receive_message(
        QueueUrl=SQS_QUEUE_URL,
        MaxNumberOfMessages=10,
        WaitTimeSeconds=20,  # 长轮询减少空调用次数
        AttributeNames=['All']
    )

    if 'Messages' in response:
        for message in response['Messages']:
            # --------------------------
            # 在这里添加你的业务逻辑
            print(f"处理消息内容：{message['Body']}")
            # --------------------------

            # 处理完成后删除消息，避免重复处理
            sqs_client.delete_message(
                QueueUrl=SQS_QUEUE_URL,
                ReceiptHandle=message['ReceiptHandle']
            )
        print(f"已处理 {len(response['Messages'])} 条消息")
    else:
        print("队列中没有新消息")

小提示：设置WaitTimeSeconds=20启用长轮询，Lambda会等待最多20秒直到有消息再返回，能减少无意义的空调用，帮你节省成本。

二、更优方案：直接用SQS作为Lambda触发器 #

给你提个醒：AWS现在已经支持SQS直接触发Lambda了——完全不需要CloudWatch定时调度！这种方式效率更高，因为只有队列中有消息时Lambda才会运行，不会浪费资源：

• 打开Lambda控制台，进入你的函数，点击「添加触发器」
• 从触发器列表中选择SQS
• 选择目标队列，设置批量大小（比如10），保存配置
• AWS会自动配置好所需的IAM权限，消息进入队列时Lambda会自动触发，只要你的代码运行无异常，还会自动删除消息

这是大部分场景下的推荐方案——更简单、更省钱、响应更及时。

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