问题描述
我有一个 python lambda，它会在文件从其他 AWS 服务上传/导出到 S3 存储桶时触发，并向收件人发送附有文件的电子邮件。
当我手动将文件上传到 S3 时，Lambda 工作正常。但是，当文件（CSV 格式的报告文件）从 Amazon Connect（AWS 服务）导出到 S3 存储桶时，它不起作用。
示例：从 AC 连接导出到 S3 的文件保存为 (TestReport-2021-01-26T21:30:00Z.csv)
CloudWatch 日志将 KEY 显示为：TestReport-2021-01-26T21%3A30%3A00Z.csv 并且错误是：[ERROR] ClientError：调用Headobject操作时发生错误（404）：未找到回溯（最近一次调用）
Lambda 代码如下，正在使用 Python Lambda to send files uploaded to s3 as email attachments
import os.path
import boto3
import email
from botocore.exceptions import ClientError
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.application import MIMEApplication
s3 = boto3.client("s3")
def lambda_handler(event,context):
# Replace sender@example.com with your "From" address.
# This address must be verified with Amazon SES.
SENDER = "Test Test <test@test.com>"
# Replace recipient@example.com with a "To" address. If your account
# is still in the sandBox,this address must be verified.
RECIPIENT = "Test Test <test@test.com>"
# Specify a configuration set. If you do not want to use a configuration
# set,comment the following variable,and the
# ConfigurationSetName=CONfigURATION_SET argument below.
# CONfigURATION_SET = "ConfigSet"
AWS_REGION = "eu-west-1"
SUBJECT = "Test Send Mesage with Attachment"
# This is the start of the process to pull the files we need from the S3 bucket into the email.
# Get the records for the triggered event
FILEOBJ = event["Records"][0]
# Extract the bucket name from the records for the triggered event
BUCKET_NAME = str(FILEOBJ['s3']['bucket']['name'])
# Extract the object key (basicaly the file name/path - note that in S3 there are
# no folders,the path is part of the name) from the records for the triggered event
KEY = str(FILEOBJ['s3']['object']['key'])
# extract just the last portion of the file name from the file. This is what the file
# would have been called prior to being uploaded to the S3 bucket
FILE_NAME = os.path.basename(KEY)
# Using the file name,create a new file location for the lambda. This has to
# be in the tmp dir because that's the only place lambdas let you store up to
# 500mb of stuff,hence the '/tmp/'+ prefix
TMP_FILE_NAME = '/tmp/' +FILE_NAME
# Download the file/s from the event (extracted above) to the tmp location
s3.download_file(BUCKET_NAME,KEY,TMP_FILE_NAME)
# Make explicit that the attachment will have the tmp file path/name. You Could just
# use the TMP_FILE_NAME in the statments below if you'd like.
ATTACHMENT = TMP_FILE_NAME
# The email body for recipients with non-HTML email clients.
BODY_TEXT = "Hello,\r\nPlease see the attached file related to recent submission."
# The HTML body of the email.
BODY_HTML = """\
<html>
<head></head>
<body>
<h1>Hello!</h1>
<p>Please see the attached file related to recent submission.</p>
</body>
</html>
"""
# The character encoding for the email.
CHARSET = "utf-8"
# Create a new SES resource and specify a region.
client = boto3.client('ses',region_name=AWS_REGION)
# Create a multipart/mixed parent container.
msg = MIMEMultipart('mixed')
# Add subject,from and to lines.
msg['Subject'] = SUBJECT
msg['From'] = SENDER
msg['To'] = RECIPIENT
# Create a multipart/alternative child container.
msg_body = MIMEMultipart('alternative')
# Encode the text and HTML content and set the character encoding. This step is
# necessary if you're sending a message with characters outside the ASCII range.
textpart = MIMEText(BODY_TEXT.encode(CHARSET),'plain',CHARSET)
htmlpart = MIMEText(BODY_HTML.encode(CHARSET),'html',CHARSET)
# Add the text and HTML parts to the child container.
msg_body.attach(textpart)
msg_body.attach(htmlpart)
# Define the attachment part and encode it using MIMEApplication.
att = MIMEApplication(open(ATTACHMENT,'rb').read())
# Add a header to tell the email client to treat this part as an attachment,# and to give the attachment a name.
att.add_header('Content-disposition','attachment',filename=os.path.basename(ATTACHMENT))
# Attach the multipart/alternative child container to the multipart/mixed
# parent container.
msg.attach(msg_body)
# Add the attachment to the parent container.
msg.attach(att)
print(msg)
try:
#Provide the contents of the email.
response = client.send_raw_email(
Source=SENDER,Destinations=[
RECIPIENT
],RawMessage={
'Data':msg.as_string(),},# ConfigurationSetName=CONfigURATION_SET
)
# display an error if something goes wrong.
except ClientError as e:
print(e.response['Error']['Message'])
else:
print("Email sent! Message ID:"),print(response['MessageId'])
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）