如何使用 python 将流上传到 AWS s3
Posted
技术标签:
【中文标题】如何使用 python 将流上传到 AWS s3【英文标题】:how to upload stream to AWS s3 with python 【发布时间】:2018-07-09 13:40:32 【问题描述】:我想创建一个从 S3 获取 zip 文件(可能包含 csv 文件列表)的 lambda,将其解压缩并上传回 s3。 由于 lambda 受内存/磁盘大小的限制,我必须将它从 s3 流式传输并返回到它。 我使用python(boto3) 请参阅下面的代码
count = 0
obj = s3.Object( bucket_name, key )
buffer = io.BytesIO(obj.get()["Body"].read())
print (buffer)
z = zipfile.ZipFile(buffer)
for x in z.filelist:
with z.open(x) as foo2:
print(sys.getsizeof(foo2))
line_counter = 0
out_buffer = io.BytesIO()
for f in foo2:
out_buffer.write(f)
# out_buffer.writelines(f)
line_counter += 1
print (line_counter)
print foo2.name
s3.Object( bucket_name, "output/"+foo2.name+"_output" ).upload_fileobj(out_buffer)
out_buffer.close()
z.close()
结果是,在存储桶中创建了空文件。 例如:如果文件:input.zip 包含文件:1.csv,2.csv 我进入桶 2 具有相应名称的空 csv 文件。 另外,我不确定它是否确实流式传输文件,或者只是下载所有 zip 文件 谢谢
【问题讨论】:
查看已编辑的问题 boto3 client.get_object() 方法支持 Range 参数。您可以使用它来请求一系列字节,例如“字节=1024-2048”。 @RELW 您可以使用 Python 将流上传到 AWS S3。请在下面查看我的答案 【参考方案1】:上传前需要seek回到ByesIO文件的开头。
out_buffer = io.BytesIO()
for f in foo2:
out_buffer.write(f)
# out_buffer.writelines(f)
line_counter += 1
out_buffer.seek(0) # Change stream position to beginning of file
s3.Object( bucket_name, "output/"+foo2.name+"_output").upload_fileobj(out_buffer)
out_buffer.close()
【讨论】:
【参考方案2】:您可以将文件从 S3 解压缩并提取到 S3。
s3Bucket ="s3-bucket" #Provide S3 bucket name
file_name = "test.zip" #Provide zip file name
s3=boto3.resource('s3')
zip_obj = s3.Object(bucket_name=s3Bucket, key=file_name)
buffer = BytesIO(zip_obj.get()["Body"].read())
z = zipfile.ZipFile(buffer)
for file in z.namelist():
file_info = z.getinfo(file)
s3.meta.client.upload_fileobj(
z.open(file),
Bucket=s3Bucket,
Key=file,
ExtraArgs='ServerSideEncryption':'aws:kms','SSEKMSKeyId':'alias/<alias_name>')
参考 - https://github.com/vhvinod/ftp-to-s3/blob/master/extract-s3-to-s3.py
【讨论】:
以上是关于如何使用 python 将流上传到 AWS s3的主要内容,如果未能解决你的问题,请参考以下文章
我想将相机视频流上传到 Amazon S3 并将其下载到 Android 手机。我对此完全陌生。我怎样才能做到这一点?
如何使用 Python 在 myBucket 中上传 CSV 文件并在 S3 AWS 中读取文件
使用 REST API 将文件流上传到 AZURE BLOB STORAGE