如何在Lambda函数中触发告警：S3桶指定文件不存在场景的实现方法

嘿，我来帮你把Lambda和SNS告警关联起来！既然你已经配置好带邮件订阅的SNS Topic了，接下来只需要做两件核心的事：给Lambda加权限、修改Lambda代码在文件不存在时发送告警。咱们一步步来：

1. 给Lambda执行角色添加SNS发布权限 #

Lambda需要有足够的权限才能向你的SNS Topic发送消息，所以得给它的执行角色附加一个IAM策略：

• 打开AWS IAM控制台，找到你的Lambda函数对应的执行角色
• 点击「添加权限」→「创建内联策略」
• 选择「JSON」模式，粘贴下面的策略（记得把YOUR_SNS_TOPIC_ARN替换成你自己的Topic ARN）：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "sns:Publish",
            "Resource": "YOUR_SNS_TOPIC_ARN"
        }
    ]
}

• 给策略起个名字（比如LambdaPublishToSNS），然后保存即可。

2. 修改Lambda代码，触发SNS告警 #

接下来要在你的Lambda逻辑里，当检测到目标文件不存在（也就是fileExists为false）时，调用AWS SDK发送消息到SNS Topic。下面以Python为例（如果用其他语言，思路是一样的，调用对应SDK的SNS发布方法）：

假设你的原有代码大概是这样的，我们在其中加入告警逻辑：

import boto3

s3 = boto3.client('s3')

def lambda_handler(event, context):
    bucket_name = "your-target-bucket"
    target_file = "path/to/your/target-file.txt"
    
    # 检查文件是否存在的原有逻辑
    try:
        s3.head_object(Bucket=bucket_name, Key=target_file)
        fileExists = True
    except s3.exceptions.ClientError as e:
        if e.response['Error']['Code'] == "404":
            fileExists = False
        else:
            # 处理其他未知错误
            raise e
    
    # 新增：当文件不存在时发送SNS告警
    if not fileExists:
        sns = boto3.client('sns')
        sns_topic_arn = "YOUR_SNS_TOPIC_ARN"
        message = f"告警：S3存储桶 {bucket_name} 中的目标文件 {target_file} 不存在！"
        subject = "S3目标文件缺失告警"
        
        sns.publish(
            TopicArn=sns_topic_arn,
            Message=message,
            Subject=subject
        )
    
    return {
        'statusCode': 200,
        'body': {'fileExists': fileExists}
    }

• 记得把代码里的bucket_name、target_file和sns_topic_arn替换成你自己的实际值
• 如果你的Lambda用的是Node.js、Java等其他语言，只需要调用对应SDK的SNS发布接口即可，逻辑完全一致：判断fileExists为false时，发送消息到指定Topic。

3. 测试验证 #

最后来验证一下是否生效：

• 手动删除S3桶里的目标文件
• 触发你的Lambda函数（可以在Lambda控制台手动测试，或者通过原有触发方式）
• 检查你订阅SNS的邮箱，应该会收到对应的告警邮件
• 也可以在SNS控制台查看「消息历史」，确认消息是否成功发送

如果遇到权限问题，先检查IAM策略是否正确配置；如果没收到邮件，确认SNS订阅是否已经完成邮箱验证（订阅后会收到确认邮件，需要点击链接激活）。

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