如何通过AWS S3->Lambda->SNS向Android应用发送新图片URL链接？

当然可行啦！其实这个需求的核心就是在Lambda里正确生成S3对象的可访问URL，然后把这个URL塞进SNS的通知 payload 里，让Android端能解析并处理跳转。我给你捋清楚实现步骤和代码调整方案：

1. 生成S3对象的可访问URL #

S3对象的URL分两种场景，你可以根据自己的桶权限选择：

• 如果是公开可读的对象，直接用固定格式拼接URL就行，格式是：https://<bucket-name>.s3.<region>.amazonaws.com/<object-key>
• 如果是私有对象，就得生成带签名的预签名URL，这个URL有有效期（你可以自己设置，比如1小时），能让Android端临时访问私有对象。

2. 构造符合Android要求的SNS通知Payload #

不能只给SNS发纯文本消息，得构造一个JSON格式的payload，包含Android通知的标题、内容，还有点击后要打开的链接。这里要用到GCM字段（对应Firebase Cloud Messaging，Android推送的标准服务），把URL放在data字段里，方便Android端解析。

3. 整理Lambda代码 #

我把你混乱的代码片段整理成了清晰的版本，核心步骤都标注出来了：

import logging
import boto3
import urllib.parse
from botocore.exceptions import ClientError

# 初始化AWS客户端
sns = boto3.client('sns')
s3 = boto3.client('s3')

# 替换成你自己的配置
SNS_TOPIC_ARN = 'arn:aws:sns:你的区域:你的账号ID:你的SNS主题ARN'
S3_REGION = '你的S3桶所在区域'

logger = logging.getLogger()
logger.setLevel(logging.INFO)

def lambda_handler(event, context):
    try:
        # 从Lambda触发事件里提取S3对象的关键信息
        record = event['Records'][0]
        bucket_name = record['s3']['bucket']['name']
        object_key = record['s3']['object']['key']
        
        # 处理对象键里的特殊字符（比如空格、中文），避免URL无效
        encoded_object_key = urllib.parse.quote_plus(object_key)
        logger.info(f"检测到新S3对象：{bucket_name}/{object_key}")

        # 生成可访问URL，二选一即可：
        # 选项1：公开对象的直接URL
        object_url = f"https://{bucket_name}.s3.{S3_REGION}.amazonaws.com/{encoded_object_key}"
        
        # 选项2：私有对象的预签名URL（有效期设置为3600秒=1小时）
        # object_url = s3.generate_presigned_url(
        #     'get_object',
        #     Params={'Bucket': bucket_name, 'Key': object_key},
        #     ExpiresIn=3600
        # )

        # 构造SNS推送的JSON payload
        sns_payload = {
            'default': f"新文件已上传到S3：{object_url}",  # 作为其他平台的 fallback 消息
            'GCM': '{"notification": {"title": "S3新文件通知", "body": "点击查看刚上传的文件"}, "data": {"url": "' + object_url + '"}}'
        }

        # 调用SNS发送通知
        response = sns.publish(
            TopicArn=SNS_TOPIC_ARN,
            MessageStructure='json',
            Message=str(sns_payload)
        )
        logger.info(f"SNS通知发送成功，消息ID：{response['MessageId']}")
        return {
            'statusCode': 200,
            'body': '通知已成功发送'
        }
    except ClientError as e:
        logger.error(f"AWS客户端错误：{e}")
        raise e
    except Exception as e:
        logger.error(f"未知错误：{e}")
        raise e

• 权限配置：一定要给Lambda的执行角色加上这两个权限：s3:GetObject（生成预签名URL需要）和sns:Publish，同时要确保S3桶的触发事件已经正确关联到这个Lambda函数。
• Android端处理：你的Android应用需要集成Firebase Cloud Messaging（FCM），在收到推送消息时，解析data字段里的url，然后用Intent打开系统浏览器或者应用内的WebView。
• URL编码：如果你的S3对象键里有空格、中文或者特殊符号，一定要用urllib.parse.quote_plus编码，不然生成的URL会无效，这个我已经在代码里加上了。

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