asp.net core系列 69 Amazon S3 资源文件上传示例

using amazon;
using amazon.runtime;
using amazon.s3;
using amazon.s3.model;
using system;
using system.collections.generic;
using system.io;
using system.text;
using system.threading.tasks;

/*
     //上传篮球资料图片
     awss3helper s3 = new awss3helper(resourcetype.basketballnewsimg);
     s3.writinganobjectasync("e:\\11\\test1.jpg").wait();    
 */
namespace awss3withnetcore
{

    /// <summary>
    ///amazon s3 上传数据（照片、视频、文档等） 
    /// </summary>
    public class awss3helper
    {

        /// <summary>
        /// 地区是亚太香港
        /// </summary>
        readonly regionendpoint bucketregion = regionendpoint.getbysystemname("ap-east-1");


        /// <summary>
        /// 要向 amazon s3 上传数据（照片、视频、文档等），
        /// 您必须首先在其中一个 aws 区域中创建 s3 存储桶, 比如：在亚太香港地址，创建了一个gfbk桶
        /// 然后，您可以将任何数量的对象上传到该存储桶。
        /// 每个 aws 账户中创建多达 100 个存储桶，一个存储桶中可以存储任意数量的对象。
        /// 资料：https://docs.aws.amazon.com/zh_cn/amazons3/latest/dev/usingbucket.html
        /// </summary>
        readonly string bucketname = constants.bucketname;


        /// <summary>
        /// 请求s3的凭据
        /// </summary>
        readonly awscredentials awscredentials = new basicawscredentials(constants.accesskey, constants.secretkey);


        /// <summary>
        /// 请求客户端
        /// </summary>
        amazons3client client = null;


        /// <summary>
        /// 上传资源类型
        /// </summary>
        resourcetype _resourcetype;

        public awss3helper(resourcetype resourcetype)
        {
            _resourcetype = resourcetype;
            client = new amazons3client(awscredentials, bucketregion);
        }


        /// <summary>
        ///创建一个桶
        /// </summary>
        /// <returns></returns>
        public async task createbucket()
        {
            var putbucketrequest = new putbucketrequest
            {
                bucketname = bucketname,
                useclientregion = true
            };
            putbucketresponse putbucketresponse = await client.putbucketasync(putbucketrequest);
            string bucketlocation = await findbucketlocationasync(client);
        }


        /// <summary>
        /// 查找桶所在的地区
        /// </summary>
        /// <param name="client"></param>
        /// <returns></returns>
        private async task<string> findbucketlocationasync(iamazons3 client)
        {
            string bucketlocation;
            var request = new getbucketlocationrequest()
            {
                bucketname = bucketname
            };
            getbucketlocationresponse response = await client.getbucketlocationasync(request);
            bucketlocation = response.location.tostring();
            return bucketlocation;
        }



        /// <summary>
        /// 上传文件
        /// </summary>
        /// <param name="uploadfilepath">上传的文件地址如:e:\test.jpg</param>
        /// <returns></returns>
        public async task<bool> writinganobjectasync(string uploadfilepath)
        {
            try
            {
                string filename = uploadfilepath.substring(uploadfilepath.lastindexof('\\')+1);
                string key = string.format("resource/img/{0}/{1}", _resourcetype.tostring().replace("img", ""), filename);
                var putrequest2 = new putobjectrequest
                {
                    bucketname = bucketname,
                    //获取和设置键属性。此键用于标识s3中的对象,上传到s3的路径+文件名，
                    //s3上没有文件夹可以创建一个，参考https://www.cnblogs.com/web424/p/6840207.html
                    key = key,
                    //所有者获得完全控制权，匿名主体被授予读访问权。如果
                    //此策略用于对象，它可以从浏览器中读取，无需验证
                    cannedacl = s3cannedacl.publicread,
                    //上传的文件路径
                    filepath = uploadfilepath,
                    //为对象设置的标记。标记集必须编码为url查询参数
                    tagset = new list<tag>{
                                    new tag { key = "test", value = "s3test"} }
                    //contenttype = "image/png"
                };
                putrequest2.metadata.add("x-amz-meta-title", "awss3net");
                putobjectresponse response2 = await client.putobjectasync(putrequest2);
                return true;
            }
            catch (amazons3exception e)
            {
                throw new exception(string.format("error encountered ***. message:'{0}' when writing an object", e.message));
            }
            catch (exception e)
            {
                throw new exception(string.format("unknown encountered on server. message:'{0}' when writing an object", e.message));
            }
        }



        /// <summary>
        /// 上传文件 (未经测试)
        /// </summary>
        /// <param name="inputstream">以流的形式</param>
        /// <returns></returns>
        public async task<bool> writinganobjectbystreamasync(stream inputstream,string filename)
        {
            string key = string.format("resource/img/{0}/{1}", _resourcetype.tostring().replace("img", ""), filename);
            try
            {
                var putrequest1 = new putobjectrequest
                {
                    bucketname = bucketname,
                    //创建对象时，要指定键名，它在存储桶中唯一地标识该对象
                    key = key,
                    inputstream= inputstream
                };
                putobjectresponse response1 = await client.putobjectasync(putrequest1);
                return true;
            }
            catch (amazons3exception e)
            {
                throw new exception(string.format("error encountered ***. message:'{0}' when writing an object", e.message));
            }
            catch (exception e)
            {
                throw new exception(string.format("unknown encountered on server. message:'{0}' when writing an object", e.message));
            }
        }


        /// <summary>
        /// 删除一个对象
        /// </summary>
        /// <param name="key">删除的对象的键如:resource/img/basketballnews/test1.jpg</param>
        /// <returns></returns>
        public async task<bool> deleteanobjectasync(string key)
        {
            try
            {
                // 1. delete object-specify only key name for the object.
                var deleterequest1 = new deleteobjectrequest
                {
                    bucketname = bucketname,
                    key = key
                };
                deleteobjectresponse response1 = await client.deleteobjectasync(deleterequest1);
                return true;
            }
            catch (amazons3exception e)
            {
                throw new exception(string.format("error encountered ***. message:'{0}' when writing an object", e.message));
            }
            catch (exception e)
            {
                throw new exception(string.format("unknown encountered on server. message:'{0}' when writing an object", e.message));
            }
        }


        /// <summary>
        /// 获取
        /// </summary>
        /// <param name="prefix">限制对以指定前缀开头的键的响应</param>
        /// <returns></returns>
        public async task<list<s3object>> listobjectsasync(string prefix = "")
        {
            try
            {

                var list = new listobjectsrequest
                {
                    bucketname = bucketname,
                    prefix = prefix
                };

                listobjectsresponse response1 = await client.listobjectsasync(list);

                return response1.s3objects;
            }
            catch (amazons3exception e)
            {
                throw new exception(string.format("error encountered ***. message:'{0}' when writing an object", e.message));
            }
            catch (exception e)
            {
                throw new exception(string.format("unknown encountered on server. message:'{0}' when writing an object", e.message));
            }
        }
    }



    public enum resourcetype
    {
        basketballnewsimg,
        footballnewsimg,
        bannerimg,
        videoimg,
        logoimg
    }

    internal class constants
    {
        internal const string bucketname = "gfbk";//write your bucket name
        internal const string accesskey = "xxxxxx"; // write your iam credentials first access key
        internal const string secretkey = "xxxxxx"; // write your iam credentials second access key(secret key)
    }
}