如何将 PDF 从一个 lambda 发送到另一个？

Question

我正在尝试将 S3 存储桶中的 PDF 文件从一个 lambda 发送到一秒。为此，我正在从 S3 存储桶中下载 tmp 文件夹中的 PDF，然后调用第二个 lambda。

我的代码：

s3r = boto3.resource('s3')
client = boto3.client('lambda')
s3r.meta.client.download_file(
    Bucket='my_bucket',
    Key='pdf_folder' + '/{}'.format(pdf_name),
    Filename='/tmp/'+pdf_name
)

然后我尝试调用第二个 lambda 并将 PDF 作为有效负载发送，如下所示：

client.invoke(
    FunctionName='second_lambda',
    InvocationType="RequestResponse",
    Payload={
        'pdf': '/tmp/'+pdf_name,
        'email': receiver_email,
    }
)

但我收到以下错误：

botocore.exceptions.ParamValidationError：参数验证失败： 参数有效负载的类型无效，值：{'pdf': '/tmp/test_pdf_ff9cf3167ae6fc1552f340a7abc529970fb8cf5a65f8bc825d772fa5e707c81d.pdf', 'email'：receiver_email}，类型：，有效类型：, , 类文件对象

我做错了什么？

Answer 1

Payload 只能是“字节或可查找的类文件对象”。但是你有一本字典。

要提供类似文件的对象，您可以这样做：

with open('/tmp/'+pdf_name, 'rb') as f:
   client.invoke(
      FunctionName='second_lambda',
      InvocationType="RequestResponse",
      Payload=f
  )

更新：

您可以将文件编码为base64，放入dict，然后将dict转换为json，然后转换为bytes：

import base64
import json

with open('/tmp/'+pdf_name, 'rb') as f:
   client.invoke(
      FunctionName='second_lambda',
      InvocationType="RequestResponse",
      Payload=json.dumps({
        'pdf': base64.b64encode(f.read()).decode("ascii"),
        'email': receiver_email,
    }).encode()
  )

或者pickle:

import pickle

with open('/tmp/'+pdf_name, 'rb') as f:
   client.invoke(
      FunctionName='second_lambda',
      InvocationType="RequestResponse",
      Payload=pickle.dumps({
        'pdf': f.read(),
        'email': receiver_email,
    })
  )