Amazon Web Services – 到 SNS 的 Amazon S3 通知

如果您在使用Amazon S3时需要实时通知一些事件，如新文件的上传或旧文件的删除，可以使用Amazon SNS服务来实现。Amazon SNS是一项高度可扩展的消息传递服务，能够向多个终端点提供即时、可靠的发布/订阅功能。

下面是一个简单的代码示例，演示如何将Amazon S3事件通知发送到Amazon SNS主题。

import boto3
import json

s3 = boto3.client('s3')
sns = boto3.client('sns')

def lambda_handler(event, context):
    bucket_name = event['Records'][0]['s3']['bucket']['name']
    object_name = event['Records'][0]['s3']['object']['key']
    event_time = event['Records'][0]['eventTime']
    message = f"New file uploaded: s3://{bucket_name}/{object_name}, at {event_time}"
    
    sns.publish(
        TopicArn='arn:aws:sns:us-west-2:123456789012:my-topic',
        Message=json.dumps({'default': json.dumps(message)}),
        MessageStructure='json'
    )
    
    return {
        'statusCode': 200,
        'body': json.dumps('Notification sent successfully')
    }

在这个示例中，我们首先导入必要的AWS SDK模块：boto3和json。然后，我们分别初始化S3和SNS客户端：

s3 = boto3.client('s3')
sns = boto3.client('sns')

在Lambda函数的handler中，我们获取S3事件的相关信息：

def lambda_handler(event, context):
    bucket_name = event['Records'][0]['s3']['bucket']['name']
    object_name = event['Records'][0]['s3']['object']['key']
    event_time = event['Records'][0]['eventTime']

然后，我们按照一定的格式构造通知消息，并调用SNS client的publish方法将其发送到指定的SNS主题中：

    message = f"New file uploaded: s3://{bucket_name}/{object_name}, at {event_time}"
    
    sns.publish(
        TopicArn='arn:aws:sns:us-west-2:123456789012:my-topic',
        Message=json.dumps({'default': json.dumps(message)}),
        MessageStructure='json'
    )

注意，这里需要将通知消息用JSON格式进行编码，并将编码后的结果传递给SNS client的publish方法，同时以json结构传递消息。

最后，我们返回一个确认消息给S3服务，表示通知发送成功：

    return {
        'statusCode': 200,
        'body': json.dumps('Notification sent successfully')
    }

这样，只要您将该Lambda函数与S3桶的事件集成，就可以实现在S3事件发生时自动将通知消息发布到指定的SNS主题中，方便监测S3事件的发生，及时作出相应处理。

以上就是Amazon Web Services – 到 SNS 的 Amazon S3 通知的介绍，希望能够帮助到您。