首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >使用具有AWS的Python中的Lambda将文件写入S3

使用具有AWS的Python中的Lambda将文件写入S3
EN

Stack Overflow用户
提问于 2018-03-07 23:43:17
回答 2查看 20.8K关注 0票数 4

在AWS中,我试图使用Lambda函数将一个文件保存到S3中。虽然这在我的本地计算机上工作,但我无法让它在Lambda工作。我一天大部分时间都在研究这个问题,希望能得到帮助。谢谢。

代码语言:javascript
复制
def pdfToTable(PDFfilename, apiKey, fileExt, bucket, key):

    # parsing a PDF using an API
    fileData = (PDFfilename, open(PDFfilename, "rb"))
    files = {"f": fileData}
    postUrl = "https://pdftables.com/api?key={0}&format={1}".format(apiKey, fileExt)
    response = requests.post(postUrl, files=files)
    response.raise_for_status()

    # this code is probably the problem!
    s3 = boto3.resource('s3')
    bucket = s3.Bucket('transportation.manifests.parsed')
    with open('/tmp/output2.csv', 'rb') as data:
        data.write(response.content)
        key = 'csv/' + key
        bucket.upload_fileobj(data, key)
代码语言:javascript
复制
    # FYI, on my own computer, this saves the file
    with open('output.csv', "wb") as f:
        f.write(response.content)

在S3中,有一个存储文件的存储桶transportation.manifests.parsed,其中包含应该保存文件的文件夹csv

response.content的类型是字节。

在AWS中,当前设置的错误实际上是[Errno 2] No such file or directory: '/tmp/output2.csv': FileNotFoundError.,我的目标是以唯一的名称将文件保存到csv文件夹中,因此tmp/output2.csv可能不是最好的方法。有指引吗?

此外,我尝试使用wbw,而不是rb,但也没有效果。wb的错误是Input <_io.BufferedWriter name='/tmp/output2.csv'> of type: <class '_io.BufferedWriter'> is not supported. -- 文档建议使用'rb‘是推荐用法,但我不明白为什么会这样。

另外,我尝试过s3_client.put_object(Key=key, Body=response.content, Bucket=bucket),但是接收了An error occurred (404) when calling the HeadObject operation: Not Found

EN

回答 2

Stack Overflow用户

发布于 2018-03-08 00:37:45

假设Python 3.6。我通常这样做的方法是将字节内容封装在BytesIO包装器中,以创建类似于对象的文件。而且,根据boto3文档,您可以使用调职经理进行托管传输:

代码语言:javascript
复制
from io import BytesIO
import boto3
s3 = boto3.client('s3')

fileobj = BytesIO(response.content)

s3.upload_fileobj(fileobj, 'mybucket', 'mykey')

如果这不起作用,我会再次检查所有IAM权限是否正确。

票数 5
EN

Stack Overflow用户

发布于 2018-03-08 00:53:58

您有一个可写流,您要求boto3将其用作一个无法工作的可读流。

编写文件,然后在之后使用bucket.upload_file(),如下所示:

代码语言:javascript
复制
s3 = boto3.resource('s3')
bucket = s3.Bucket('transportation.manifests.parsed')
with open('/tmp/output2.csv', 'w') as data:
    data.write(response.content)

key = 'csv/' + key
bucket.upload_file('/tmp/output2.csv', key)
票数 4
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/49163099

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档