上传回调是指客户端在请求时携带回调（Callback）参数，服务端在上传完成后，发送同步的 POST 回调请求到 CallBack 中指定的第三方应用服务器，在服务器确认接受并返回结果后，才将所有结果返回给客户端。
关于上传回调的详细介绍，请参见上传回调。
using System;
using System.IO;
using System.Text;
using TOS;
using TOS.Error;
using TOS.Model;
namespace TestTos
{
internal class Program
{
private static void Main(string[] args)
{
var ak = Environment.GetEnvironmentVariable("TOS_ACCESS_KEY");
var sk = Environment.GetEnvironmentVariable("TOS_SECRET_KEY");
// endpoint 若没有指定HTTP协议（HTTP/HTTPS），默认使用 HTTPS
// Bucket 的 Endpoint，以华北2（北京）为例：https://tos-cn-beijing.volces.com
var endpoint = "https://tos-cn-beijing.volces.com";
var region = "cn-beijing";
// 填写 BucketName
var bucketName = "*** Provide your bucket name ***";
// 上传对象 Body，以 string 对象为例
var objectContent = "Hello TOS";
// 将文件上传到 example_dir 目录下的 example.txt 文件
var objectKey = "example_dir/example.txt";
// 上传回调参数
var callback = "your callback param";
// 上传回调自定义变量
var callbackVar = "your callback custom variable";
// 创建TOSClient实例
var client = TosClientBuilder.Builder().SetAk(ak).SetSk(sk).SetEndpoint(endpoint).SetRegion(region).Build();
try
{
byte[] binaryData = Encoding.UTF8.GetBytes(objectContent);
using (MemoryStream requestContent = new MemoryStream(binaryData))
{
// 创建上传文件输入
var putObjectInput = new PutObjectInput()
{
Bucket = bucketName,
Key = objectKey,
Content = requestContent,
Callback = Convert.ToBase64String(Encoding.UTF8.GetBytes(callback)),
CallbackVar = Convert.ToBase64String(Encoding.UTF8.GetBytes(callbackVar))
};
// 将字符串 “Hello TOS” 上传到指定 example_dir 目录下的 example.txt
var putObjectOutput = client.PutObject(putObjectInput);
Console.WriteLine("Put object succeeded, ETag: {0} ", putObjectOutput.ETag);
Console.WriteLine("Put object succeeded, CallbackResult: {0} ", putObjectOutput.CallbackResult);
}
}
catch (TosServerException ex)
{
Console.WriteLine("Put object failed, request id {0}", ex.RequestID);
Console.WriteLine("Put object failed, status code {0}", ex.StatusCode);
Console.WriteLine("Put object failed, response error code {0}", ex.Code);
Console.WriteLine("Put object failed, response error message {0}", ex.Message);
}
catch (TosClientException ex)
{
Console.WriteLine("Put object failed, error message {0}", ex.Message);
}
catch (Exception ex)
{
Console.WriteLine("Put object failed, {0}", ex.Message);
}
}
}
}
using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
using TOS;
using TOS.Error;
using TOS.Model;
namespace ConsoleApp
{
internal class Program
{
private static void Main(string[] args)
{
var ak = Environment.GetEnvironmentVariable("TOS_ACCESS_KEY");
var sk = Environment.GetEnvironmentVariable("TOS_SECRET_KEY");
// endpoint 若没有指定HTTP协议（HTTP/HTTPS），默认使用 HTTPS
// Bucket 的 Endpoint，以华北2（北京）为例：https://tos-cn-beijing.volces.com
var endpoint = "https://tos-cn-beijing.volces.com";
var region = "cn-beijing";
// 填写 BucketName
var bucketName = "*** Provide your bucket name ***";
// 将文件上传到 example_dir 目录下的 example.txt 文件
var objectKey = "example_dir/example.txt";
// 需要上传的本地文件
var localFileName = "/usr/local/test.txt";
// 上传回调参数
var callback = "your callback param";
// 上传回调自定义变量
var callbackVar = "your callback custom variable";
// 创建TOSClient实例
var client = TosClientBuilder.Builder().SetAk(ak).SetSk(sk).SetEndpoint(endpoint).SetRegion(region).Build();
// 初始化分片，指定对象权限为私有，存储类型为低频并设置元数据信息
var uploadID = "";
try
{
var createMultipartUploadInput = new CreateMultipartUploadInput
{
Bucket = bucketName,
Key = objectKey,
ACL = ACLType.ACLPrivate,
StorageClass = StorageClassType.StorageClassIa,
Meta = new Dictionary<string, string> { { "key", "value" } }
};
var createMultipartUploadOutput = client.CreateMultipartUpload(createMultipartUploadInput);
uploadID = createMultipartUploadOutput.UploadID;
Console.WriteLine("CreateMultipartUpload succeeded, request id {0}",
createMultipartUploadOutput.RequestID);
Console.WriteLine("CreateMultipartUpload succeeded, upload id {0}", uploadID);
}
catch (TosServerException ex)
{
Console.WriteLine("CreateMultipartUpload failed, request id {0}", ex.RequestID);
Console.WriteLine("CreateMultipartUpload failed, status code {0}", ex.StatusCode);
Console.WriteLine("CreateMultipartUpload failed, response error code {0}", ex.Code);
Console.WriteLine("CreateMultipartUpload failed, response error message {0}", ex.Message);
}
catch (TosClientException ex)
{
Console.WriteLine("CreateMultipartUpload failed, error message {0}", ex.Message);
}
catch (Exception ex)
{
Console.WriteLine("CreateMultipartUpload failed, {0}", ex.Message);
}
// part size 大小设置为 20M
long partSize = 20 * 1024 * 1024;
// 计算分片信息
var fi = new FileInfo(localFileName);
var fileSize = fi.Length;
var partCount = fileSize / partSize;
if (fileSize % partSize != 0) partCount++;
var parts = new UploadedPart[partCount];
// 开始分片上传
try
{
using (var fileStream = File.Open(localFileName, FileMode.Open, FileAccess.Read))
{
for (var i = 0; i < partCount; i++)
{
var offset = partSize * i;
// 定位到本次上传的起始位置。
fileStream.Seek(offset, 0);
// 计算本次上传的分片大小，最后一片为剩余的数据大小。
var contentSize = partSize < fileSize - offset ? partSize : fileSize - offset;
var UploadPartInput = new UploadPartInput
{
Bucket = bucketName,
Key = objectKey,
UploadID = uploadID,
// partNumber 编号从 1 开始
PartNumber = i + 1,
Content = fileStream,
ContentLength = contentSize
};
var uploadPartOutput = client.UploadPart(UploadPartInput);
parts[i] = new UploadedPart { PartNumber = i + 1, ETag = uploadPartOutput.ETag };
Console.WriteLine("UploadPart succeeded, request id {0}", uploadPartOutput.RequestID);
}
}
}
catch (TosServerException ex)
{
Console.WriteLine("UploadPart failed, request id {0}", ex.RequestID);
Console.WriteLine("UploadPart failed, status code {0}", ex.StatusCode);
Console.WriteLine("UploadPart failed, response error code {0}", ex.Code);
Console.WriteLine("UploadPart failed, response error message {0}", ex.Message);
}
catch (TosClientException ex)
{
Console.WriteLine("UploadPart failed, error message {0}", ex.Message);
}
catch (Exception ex)
{
Console.WriteLine("UploadPart failed, {0}", ex.Message);
}
// 合并分片
try
{
var completeMultipartUploadInput = new CompleteMultipartUploadInput
{
Bucket = bucketName,
Key = objectKey,
UploadID = uploadID,
Parts = parts,
Callback = Convert.ToBase64String(Encoding.UTF8.GetBytes(callback)),
CallbackVar = Convert.ToBase64String(Encoding.UTF8.GetBytes(callbackVar))
};
var completeMultipartUploadOutput = client.CompleteMultipartUpload(completeMultipartUploadInput);
Console.WriteLine("CompleteMultipartUpload succeeded, request id {0}", completeMultipartUploadOutput.RequestID);
Console.WriteLine("CompleteMultipartUpload succeeded, callback result {0}", completeMultipartUploadOutput.CallbackResult);
}
catch (TosServerException ex)
{
Console.WriteLine("CompleteMultipartUpload failed, request id {0}", ex.RequestID);
Console.WriteLine("CompleteMultipartUpload failed, status code {0}", ex.StatusCode);
Console.WriteLine("CompleteMultipartUpload failed, response error code {0}", ex.Code);
Console.WriteLine("CompleteMultipartUpload failed, response error message {0}", ex.Message);
}
catch (TosClientException ex)
{
Console.WriteLine("CompleteMultipartUpload failed, error message {0}", ex.Message);
}
catch (Exception ex)
{
Console.WriteLine("CompleteMultipartUpload failed, {0}", ex.Message);
}
}
}
}