使用临时url进行授权访问-j9九游会登录

创建桶

// 初始化配置参数
obsconfig config = new obsconfig();
config.endpoint = "https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
string accesskey= environment.getenvironmentvariable("accesskeyid", environmentvariabletarget.machine);
string secretkey= environment.getenvironmentvariable("secretaccesskey", environmentvariabletarget.machine);
// 创建obsclient实例
obsclient client = new obsclient(accesskey, secretkey, config);
// url有效期，3600秒
long exipreseconds = 3600;
createtemporarysignaturerequest request = new createtemporarysignaturerequest();
request.bucketname = "bucketname";
request.method = httpverb.put;
request.expires = exipreseconds;
createtemporarysignatureresponse response = client.createtemporarysignature(request);
console.writeline("creating bucket using temporary signature url:");
console.writeline("\t"   response.signurl);
// 使用put请求创建桶
httpwebrequest webrequest = webrequest.create(response.signurl) as httpwebrequest;
webrequest.method = "put";
foreach (keyvaluepair header in response.actualsignedrequestheaders)
{
    if (!header.key.equals("host", stringcomparison.ordinalignorecase))
    {
        webrequest.headers.add(header.key, header.value);
    }
}
string location = "your bucket location";
            
webrequest.sendchunked = true;
webrequest.allowwritestreambuffering = false;
using (stream requeststream = webrequest.getrequeststream())
{
    byte[] buffer = encoding.utf8.getbytes(""   location   "");
    requeststream.write(buffer, 0, buffer.length);
}
httpwebresponse webresponse = null;
try
{
    webresponse = webrequest.getresponse() as httpwebresponse;
}
catch (webexception ex)
{
    webresponse = ex.response as httpwebresponse;
}
console.writeline("response status:"   convert.toint32(webresponse.statuscode));
using (memorystream dest = new memorystream())
{
    using (stream stream = webresponse.getresponsestream())
    {
        byte[] buffer = new byte[8192];
        int bytesread;
        while ((bytesread = stream.read(buffer, 0, buffer.length)) > 0)
        {
            dest.write(buffer, 0, bytesread);
        }
    }
    console.writeline("response content:");
    console.writeline(encoding.utf8.getstring(dest.toarray()));
}

上传对象

// 初始化配置参数
obsconfig config = new obsconfig();
config.endpoint = "https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
string accesskey= environment.getenvironmentvariable("accesskeyid", environmentvariabletarget.machine);
string secretkey= environment.getenvironmentvariable("secretaccesskey", environmentvariabletarget.machine);
// 创建obsclient实例
obsclient client = new obsclient(accesskey, secretkey, config);
// url有效期，3600秒
long exipreseconds = 3600;
createtemporarysignaturerequest request = new createtemporarysignaturerequest();
request.bucketname = "bucketname";
request.objectkey = "objectkey";         
request.method = httpverb.put;
request.expires = exipreseconds;
createtemporarysignatureresponse response = client.createtemporarysignature(request);
console.writeline("creating object using temporary signature url:");
console.writeline("\t"   response.signurl);
// 使用put请求上传对象
httpwebrequest webrequest = webrequest.create(response.signurl) as httpwebrequest;
webrequest.method = "put";
foreach (keyvaluepair header in response.actualsignedrequestheaders)
{
    if (!header.key.equals("host", stringcomparison.ordinalignorecase))
    {
        webrequest.headers.add(header.key, header.value);
    }
}
            
webrequest.sendchunked = true;
webrequest.allowwritestreambuffering = false;
using (stream requeststream = webrequest.getrequeststream())
{
    byte[] buffer = encoding.utf8.getbytes("hello obs");
    requeststream.write(buffer, 0, buffer.length);
}
httpwebresponse webresponse = null;
try
{
    webresponse = webrequest.getresponse() as httpwebresponse;
}
catch (webexception ex)
{
    webresponse = ex.response as httpwebresponse;
}
console.writeline("response status:"   convert.toint32(webresponse.statuscode));
using (memorystream dest = new memorystream())
{
    using (stream stream = webresponse.getresponsestream())
    {
        byte[] buffer = new byte[8192];
        int bytesread;
        while ((bytesread = stream.read(buffer, 0, buffer.length)) > 0)
        {
            dest.write(buffer, 0, bytesread);
        }
    }
    console.writeline("response content:");
    console.writeline(encoding.utf8.getstring(dest.toarray()));
}

下载对象

// 初始化配置参数
obsconfig config = new obsconfig();
config.endpoint = "https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
string accesskey= environment.getenvironmentvariable("accesskeyid", environmentvariabletarget.machine);
string secretkey= environment.getenvironmentvariable("secretaccesskey", environmentvariabletarget.machine);
// 创建obsclient实例
obsclient client = new obsclient(accesskey, secretkey, config);
// url有效期，3600秒
long exipreseconds = 3600;
createtemporarysignaturerequest request = new createtemporarysignaturerequest();
request.bucketname = "bucketname";
request.objectkey = "objectkey";         
request.method = httpverb.get;
request.expires = exipreseconds;
createtemporarysignatureresponse response = client.createtemporarysignature(request);
console.writeline("getting object using temporary signature url:");
console.writeline("\t"   response.signurl);
// 使用get请求下载对象
httpwebrequest webrequest = webrequest.create(response.signurl) as httpwebrequest;
webrequest.method = "get";
foreach (keyvaluepair header in response.actualsignedrequestheaders)
{
    if (!header.key.equals("host", stringcomparison.ordinalignorecase))
    {
        webrequest.headers.add(header.key, header.value);
    }
}
            
httpwebresponse webresponse = null;
try
{
    webresponse = webrequest.getresponse() as httpwebresponse;
}
catch (webexception ex)
{
    webresponse = ex.response as httpwebresponse;
}
console.writeline("response status:"   convert.toint32(webresponse.statuscode));
using (memorystream dest = new memorystream())
{
    using (stream stream = webresponse.getresponsestream())
    {
        byte[] buffer = new byte[8192];
        int bytesread;
        while ((bytesread = stream.read(buffer, 0, buffer.length)) > 0)
        {
            dest.write(buffer, 0, bytesread);
        }
    }
    console.writeline("response content:");
    console.writeline(encoding.utf8.getstring(dest.toarray()));
}

列举对象

// 初始化配置参数
obsconfig config = new obsconfig();
config.endpoint = "https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
string accesskey= environment.getenvironmentvariable("accesskeyid", environmentvariabletarget.machine);
string secretkey= environment.getenvironmentvariable("secretaccesskey", environmentvariabletarget.machine);
// 创建obsclient实例
obsclient client = new obsclient(accesskey, secretkey, config);
// url有效期，3600秒
long exipreseconds = 3600;
createtemporarysignaturerequest request = new createtemporarysignaturerequest();
request.bucketname = "bucketname";
request.method = httpverb.get;
request.expires = exipreseconds;
createtemporarysignatureresponse response = client.createtemporarysignature(request);
console.writeline("getting object list using temporary signature url:");
console.writeline("\t"   response.signurl);
// 使用get请求获取对象列表
httpwebrequest webrequest = webrequest.create(response.signurl) as httpwebrequest;
webrequest.method = "get";
foreach (keyvaluepair header in response.actualsignedrequestheaders)
{
    if (!header.key.equals("host", stringcomparison.ordinalignorecase))
    {
        webrequest.headers.add(header.key, header.value);
    }
}
            
httpwebresponse webresponse = null;
try
{
    webresponse = webrequest.getresponse() as httpwebresponse;
}
catch (webexception ex)
{
    webresponse = ex.response as httpwebresponse;
}
console.writeline("response status:"   convert.toint32(webresponse.statuscode));
using (memorystream dest = new memorystream())
{
    using (stream stream = webresponse.getresponsestream())
    {
        byte[] buffer = new byte[8192];
        int bytesread;
        while ((bytesread = stream.read(buffer, 0, buffer.length)) > 0)
        {
            dest.write(buffer, 0, bytesread);
        }
    }
    console.writeline("response content:");
    console.writeline(encoding.utf8.getstring(dest.toarray()));
}

删除对象

// 初始化配置参数
obsconfig config = new obsconfig();
config.endpoint = "https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
string accesskey= environment.getenvironmentvariable("accesskeyid", environmentvariabletarget.machine);
string secretkey= environment.getenvironmentvariable("secretaccesskey", environmentvariabletarget.machine);
// 创建obsclient实例
obsclient client = new obsclient(accesskey, secretkey, config);
// url有效期，3600秒
long exipreseconds = 3600;
createtemporarysignaturerequest request = new createtemporarysignaturerequest();
request.bucketname = "bucketname";
request.objectkey = "objectkey";
request.method = httpverb.delete;
request.expires = exipreseconds;
createtemporarysignatureresponse response = client.createtemporarysignature(request);
console.writeline("deleting object using temporary signature url:");
console.writeline("\t"   response.signurl);
// 使用delete请求删除对象
httpwebrequest webrequest = webrequest.create(response.signurl) as httpwebrequest;
webrequest.method = "delete";
foreach (keyvaluepair header in response.actualsignedrequestheaders)
{
    if (!header.key.equals("host", stringcomparison.ordinalignorecase))
    {
        webrequest.headers.add(header.key, header.value);
    }
}
            
httpwebresponse webresponse = null;
try
{
    webresponse = webrequest.getresponse() as httpwebresponse;
}
catch (webexception ex)
{
    webresponse = ex.response as httpwebresponse;
}
console.writeline("response status:"   convert.toint32(webresponse.statuscode));
using (memorystream dest = new memorystream())
{
    using (stream stream = webresponse.getresponsestream())
    {
        byte[] buffer = new byte[8192];
        int bytesread;
        while ((bytesread = stream.read(buffer, 0, buffer.length)) > 0)
        {
            dest.write(buffer, 0, bytesread);
        }
    }
    console.writeline("response content:");
    console.writeline(encoding.utf8.getstring(dest.toarray()));
}

初始化分段上传任务

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

// 初始化配置参数
obsconfigconfig=newobsconfig();
config.endpoint="https://your-endpoint";
// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量accesskeyid和secretaccesskey。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
stringaccesskey=environment.getenvironmentvariable("accesskeyid",environmentvariabletarget.machine);
stringsecretkey=environment.getenvironmentvariable("secretaccesskey",environmentvariabletarget.machine);
// 创建obsclient实例
obsclientclient=newobsclient(accesskey,secretkey,config);
// url有效期，3600秒
longexipreseconds=3600;
createtemporarysignaturerequestrequest=newcreatetemporarysignaturerequest();
request.bucketname="bucketname";
request.objectkey="objectkey";
request.method=httpverb.post;
request.expires=exipreseconds;
request.subresource=subresourceenum.uploads;
createtemporarysignatureresponseresponse=client.createtemporarysignature(request);
console.writeline("creating mission using temporary signature url:");
console.writeline("\t"response.signurl);
// 使用post请求创建多段任务
httpwebrequestwebrequest=webrequest.create(response.signurl)ashttpwebrequest;
webrequest.method="post";
foreach(keyvaluepair<string,string>headerinresponse.actualsignedrequestheaders)
{
if(!header.key.equals("host",stringcomparison.ordinalignorecase))
{
webrequest.headers.add(header.key,header.value);
}
}
httpwebresponsewebresponse=null;
try
{
webresponse=webrequest.getresponse()ashttpwebresponse;
}
catch(webexceptionex)
{
webresponse=ex.responseashttpwebresponse;
}
console.writeline("response status:"convert.toint32(webresponse.statuscode));
using(memorystreamdest=newmemorystream())
{
using(streamstream=webresponse.getresponsestream())
{
byte[]buffer=newbyte[8192];
intbytesread;
while((bytesread=stream.read(buffer,0,buffer.length))>0)
{
dest.write(buffer,0,bytesread);
}
}
console.writeline("response content:");
console.writeline(encoding.utf8.getstring(dest.toarray()));
}