ObsNet 1.0.0-beta.10

华为OBS存储 API

实现了对华为OBS存储的API调用，支持文件的上传、下载、删除等操作。

目录

• 华为OBS存储 API
  • 目录
  • 使用方法
    • 安装依赖
    • 配置文件
    • 使用示例

使用方法

安装依赖

Install-Package ObsNet

配置文件

{
  "OBS": {
    "Endpoint": "https://obs.[Location].myhuaweicloud.com",
    "ApiKey": "[Access Key Id]:[Secret Access Key]",
    "Location": "[Location]",
    "Bucket": "[Bucket Name]"
  }
}

使用示例

Init

    var endpoint = new Uri(configuration["OBS:Endpoint"]!);
    var key = configuration["OBS:ApiKey"];
    var apiKeyCredential = new ApiKeyCredential(key!);
    var serviceClient = new ObsNetClient(endpoint, apiKeyCredential);
    var bucketName = configuration["OBS:Bucket"];

CreateBucket

[TestMethod()]
public void GetItemsTest()
{
    try
    {
        var client = serviceClient.GetBucketClient();
        var result = client.GetBucketItems(bucketName, maxKeys: 1);
        Assert.IsNotNull(result?.Value);
        var res = (BucketItemsResponse)result.Value;
        Assert.IsNotNull(res?.Contents);
        Console.WriteLine(result.GetRawResponse().Content.ToString());
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}

//upload
[TestMethod()]
public async Task UploadTest()
{
    try
    {
        var tags = new Dictionary<string, string>
        {
            { "tag1", "value1" },
            { "tag2", "中/文" }
        };
        var metadata = new Dictionary<string, string>
        {
            { "key1", "value1" },
            { "key2", "中/文" }
        };
        var fileName = "sub/中文.txt";
        var client = serviceClient.GetBucketClient();
        var options = new RequestOptions();
        options.SetHeader("Content-Type", "application/octet-stream");
        foreach (var item in metadata)
        {
            options.AddHeader($"x-obs-meta-{item.Key}", Uri.EscapeDataString(item.Value));
        }
        var tagging = string.Join("&", tags.Select(c => $"{c.Key}={Uri.EscapeDataString(c.Value)}"));
        options.SetHeader("x-obs-tagging", tagging);
        var data = BinaryData.FromString("hello!");
        var result = await client.UploadObjectAsync(fileName, bucketName, BinaryContent.Create(data), options);
        Assert.IsNotNull(result);
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}

//download
[TestMethod()]
public async Task DownloadTest()
{
    try
    {
        var fileName = "sub/中文.txt";
        var client = serviceClient.GetBucketClient();
        var result = await client.DownloadObjectAsync(fileName, bucketName);
        Assert.IsNotNull(result?.Value);
        Console.WriteLine(result?.Value.ToString());
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}

//delete
[TestMethod()]
public async Task DeleteTest()
{
    try
    {
        var fileName = "sub/中文.txt";
        var client = serviceClient.GetBucketClient();
        var result = await client.DeleteObjectAsync(fileName, bucketName);
        Assert.IsNotNull(result);
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}

//create bucket
[TestMethod()]
public async Task CreateBucketTest()
{
    var location = configuration["OBS:Location"];
    var client = serviceClient.GetManagerClient();
    try
    {
        var result = await client.CreateBucketAsync(bucketName, location);
        Assert.IsNotNull(result);
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}

//list buckets
[TestMethod()]
public void ListBucketsTest()
{
    try
    {
        var client = serviceClient.GetManagerClient();
        var result = client.ListBuckets(BucketType.OBJECT);
        Assert.IsNotNull(result?.Value);
        //Console.WriteLine(result.GetRawResponse().Content.ToString());
    }
    catch (ClientResultException ex)
    {
        Console.WriteLine(ex.GetRawResponse()?.Content.ToString());
        throw;
    }
}