如何利用AWS SES追踪邮件回复，实现收件的存储与访问？

一、追踪收件人回复 #

• 使用带唯一标识的回复地址：发送邮件时，将回复地址设为包含唯一标识的格式（例如 reply+{{user_id}}_{{email_id}}@yourdomain.com），其中user_id关联收件人，email_id关联你发送的具体邮件。这样每一封回复都能直接对应到原始发送记录。
• 配置SES接收规则匹配回复：在SES控制台创建接收规则集，添加规则匹配回复地址的前缀（比如reply+），确保所有回复都能被SES捕获并处理。

二、存储与访问收到的邮件 #

1. 存储方案 #

• 路由至S3存储原始邮件：在SES接收规则中添加「S3动作」，指定目标S3存储桶。SES会将完整的原始邮件（包含邮件头、MIME内容）以文件形式存入S3，你可以设置存储前缀（例如 replies/%Y/%m/%d/）按日期分类存储。
• 用Lambda提取元数据至DynamoDB：搭配「Lambda动作」，在Lambda函数中解析邮件内容：
  • 提取回复的发件人、主题、发送时间
  • 从回复地址中解析出user_id和email_id，关联原始邮件
  • 将这些元数据（包括S3中的邮件文件路径）存入DynamoDB表，方便后续快速检索。
    示例Lambda代码片段（Node.js）：

  const AWS = require('aws-sdk');
  const mailparser = require('mailparser');
  const s3 = new AWS.S3();
  const dynamodb = new AWS.DynamoDB.DocumentClient();
  
  exports.handler = async (event) => {
    const record = event.Records[0];
    const s3Obj = await s3.getObject({
      Bucket: record.s3.bucket.name,
      Key: record.s3.object.key
    }).promise();
    
    const parsedMail = await mailparser.simpleParser(s3Obj.Body);
    const replyAddress = parsedMail.to.value[0].address;
    const [_, identifier] = replyAddress.split('+');
    const [userId, emailId] = identifier.split('_');
    
    await dynamodb.put({
      TableName: 'EmailReplies',
      Item: {
        userId,
        emailId,
        replyFrom: parsedMail.from.value[0].address,
        replySubject: parsedMail.subject,
        replyTime: parsedMail.date.toISOString(),
        s3Path: `s3://${record.s3.bucket.name}/${record.s3.object.key}`
      }
    }).promise();
  };
  

2. 访问方式 #

• 直接获取原始邮件：通过S3控制台找到对应文件下载，或使用AWS CLI命令：aws s3 cp s3://your-bucket/replies/2024/05/20/xxx.eml ./local-file.eml
• 基于元数据检索：通过DynamoDB控制台或API查询指定user_id或email_id的回复记录，获取S3路径后再提取邮件；如果需要可视化界面，可以搭建简单的Web应用，调用DynamoDB和S3的API展示邮件列表与内容。

三、优化建议 #

• S3生命周期管理：设置S3生命周期规则，将超过30天的邮件归档到S3 Glacier，降低长期存储成本。
• CloudWatch日志监控：为SES接收规则和Lambda函数开启CloudWatch日志，方便排查邮件接收、解析过程中的问题。
• 邮件内容预处理：在Lambda中解析邮件时，提取纯文本内容并存入DynamoDB，无需下载原始邮件即可快速查看回复内容。

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