Wes*_*key 2 c# lambda amazon-s3 amazon-web-services
我有一个用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);
}
}
Run Code Online (Sandbox Code Playgroud)
该函数运行时没有错误,但该对象未写入S3.我觉得它可能与该PutObjectAsync方法有关,但我并不积极.IAmazonS3接口包含一个PutObject方法,但在尝试使用该方法时,我收到以下错误:
'IAmazonS3'不包含'PutObject'的定义
在C#Lambda函数中将对象上传到S3存储桶的最佳方法是什么?
这是我用来将S3对象从C#lambda函数放入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;
}
}
Run Code Online (Sandbox Code Playgroud)