使用boto3将XML文件上传到S3存储桶

Question

我正在尝试将XML文件上传到带有Lambda功能和HTTP请求的AWS的S3存储桶中。主要问题是我无法转换由HTTP请求的正文传递的XML文件。

import json
import boto3

s3 = boto3.client('s3')

def lambda_handler(event, context):
    bucket = 'xmlresultmarco'
    
    fileName = 'Test'+'.xml'
    
    uploadByteStream = event

    try:
        s3.put_object(Bucket = bucket, Key = fileName, Body = uploadByteStream )
        return "Upload completed"
    
    except Exception as e:
        return e
        raise e

有人可以帮助我吗？

Answer 1

这是一些可以让您入门的代码。

lambda函数定义可能看起来像这样。

def download_lambda(event, context):
    url = event['url']
    bucket = event['bucket_name']
    key = event['key']
    download_url(url, bucket_name=bucket, key=key)

然后下载功能可能看起来像这样。我使用多部分来满足大型文件。

def download_url(url, bucket_name, key):
    response = requests.get(url, stream=True)
    response.raise_for_status()
    assert response.status_code == 200
    obj = s3.Object(bucket_name, key)
    multi_part_upload = obj.initiate_multipart_upload()
    partNo = 1
    parts = []
    default_chunk_size = 1024*1024*10 # Must be at least 5mb
    for chunk in response.iter_content(chunk_size=default_chunk_size):
        if chunk:
            part = multi_part_upload.Part(partNo)
            response = part.upload(Body=chunk)
            parts.append({
                'PartNumber': partNo,
                'ETag': response['ETag']
            })
            partNo += 1
    part_info = {}
    part_info['Parts'] = parts
    multi_part_upload.complete(MultipartUpload=part_info)

显然，根据Mark的观点，我在这里没有处理任何XML转换。阅读文件时，您需要弄清楚这一点。