AWS Lambda C#上传对象到S3

5

我有一个用C#编写的Lambda函数,试图将对象上传到S3存储桶,但未成功。为了测试目的,我将输入字符串转换为字节数组,并将其作为对象内容使用。我的处理程序函数定义如下:

public void FunctionHandler(string input, ILambdaContext context)
{
    IAmazonS3 client = new AmazonS3Client(Amazon.RegionEndpoint.USEast1);

    byte[] bytes = new byte[input.Length * sizeof(char)];
    Buffer.BlockCopy(input.ToCharArray(), 0, bytes, 0, bytes.Length);

    using (MemoryStream ms = new MemoryStream())
    {
        foreach (Byte b in bytes)
        {
            ms.WriteByte(b);
        }

        PutObjectRequest request = new PutObjectRequest()
        {
            BucketName = "BUCKET_NAME",
            Key = "OBJECT_KEY",
            InputStream = ms
        };

        client.PutObjectAsync(request);
    }
}

该函数运行无误,但对象未被写入S3。我认为这可能与PutObjectAsync方法有关,但不确定。IAmazonS3接口包括一个PutObject方法,但当我尝试使用该方法时,收到以下错误提示:

“IAmazonS3”不包含“PutObject”的定义。

在C# Lambda函数中上传对象到S3 bucket的最佳方式是什么?
2个回答

10

这是我在C# Lambda函数中使用的帮助函数,用于将S3对象放入S3(它可行)。您可能可以将其用作您的起点。

不确定为什么您要将字符串转换为字节,在C# / Lambda中,您需要使用PutObjectAsync方法而不是PutObject方法:

 public static async Task<bool> PutS3Object(string bucket, string key, string content)
        {
            try
            {
                using (var client = new AmazonS3Client(Amazon.RegionEndpoint.USEast1))
                {
                    var request = new PutObjectRequest
                    {
                        BucketName = bucket,
                        Key = key,
                        ContentBody = content
                    };
                    var response = await client.PutObjectAsync(request);
                }
                return true;
            }
            catch (Exception ex)
            {
                Console.WriteLine("Exception in PutS3Object:" + ex.Message);
                return false;
            }
        }

1
实际上,返回值应该是 return response.HttpStatusCode == HttpStatusCode.OK; - Rob Sanders
不确定为什么要将字符串转换为字节 - 你是什么意思?自从何时处理字符串比字节数组更好了?Base64会增加33%的大小。能解释一下吗? - Royi Namir
我只是在陈述我无法评论他代码中将字符串转换为字节的部分 - 不持任何意见 - 但我的解决方案并不依赖于它,所以我让他自己决定是否需要,并根据他的需求进行调整。 - E.J. Brennan

2

在使用Async方法时应该加上await关键字

await client.PutObjectAsync(request);


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接