Object Storage Service:再開可能なアップロード (C# SDK V1)

注意事項

• このトピックでは、中国 (杭州) リージョンのパブリックエンドポイントを使用します。 OSS と同じリージョンにある他の Alibaba Cloud サービスから OSS にアクセスする場合は、内部エンドポイントを使用します。 OSS のリージョンとエンドポイントの詳細については、「リージョンとエンドポイント」をご参照ください。

• このトピックでは、OSS エンドポイントを使用して OSSClient インスタンスを作成します。 カスタムドメイン名または Security Token Service (STS) を使用して OSSClient インスタンスを作成する場合は、「初期化」をご参照ください。

• 再開可能なアップロードを実行するには、oss:PutObject 権限が必要です。 詳細については、「RAM ユーザーへのカスタムポリシーのアタッチ」をご参照ください。

サンプルコード

次のコードは、再開可能なアップロードを実行する方法の例を示しています。

using Aliyun.OSS;
using Aliyun.OSS.Common;

// yourEndpoint を、バケットが配置されているリージョンのエンドポイントに設定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
var endpoint = "yourEndpoint";
// 環境変数からアクセス認証情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
var accessKeyId = Environment.GetEnvironmentVariable("OSS_ACCESS_KEY_ID");
var accessKeySecret = Environment.GetEnvironmentVariable("OSS_ACCESS_KEY_SECRET");
// バケット名を指定します。 例： examplebucket
var bucketName = "examplebucket";
// オブジェクトの完全なパスを指定します。 完全なパスにバケット名を含めることはできません。 例： exampledir/exampleobject.txt
var objectName = "exampledir/exampleobject.txt";
// ローカルファイルの完全なパスを指定します。 例： D:\\localpath\\examplefile.txt
// 完全なパスを指定せずにファイル名 (例: examplefile.txt) のみを指定した場合、ファイルはサンプルプログラムのプロジェクトに対応するローカルパスからアップロードされます。
var localFilename = "D:\\localpath\\examplefile.txt";
// チェックポイントファイルを保存するディレクトリ。 アップロードの進捗状況がこのファイルに保存されます。
string checkpointDir = "yourCheckpointDir";
// バケットが配置されているリージョンを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、リージョンを cn-hangzhou に設定します。
const string region = "cn-hangzhou";

// ClientConfiguration インスタンスを作成し、必要に応じてデフォルトパラメーターを変更します。
var conf = new ClientConfiguration();

// シグネcha V4 を使用します。
conf.SignatureVersion = SignatureVersion.V4;

// OssClient インスタンスを作成します。
var client = new OssClient(endpoint, accessKeyId, accessKeySecret, conf);
client.SetRegion(region);
try
{
    // UploadObjectRequest を使用して複数のパラメーターを設定します。
    UploadObjectRequest request = new UploadObjectRequest(bucketName, objectName, localFilename)
    {
        // 各パートのサイズを指定します。
        PartSize = 8 * 1024 * 1024,
        // 同時実行スレッドの数を指定します。
        ParallelThreadCount = 3,
        // checkpointDir パラメーターは、再開可能なアップロードの中間状態を保存するディレクトリを指定します。 これにより、失敗後にアップロードを再開できます。
        // checkpointDir が null に設定されている場合、再開可能なアップロード機能は無効になります。 失敗後、ファイル全体が再アップロードされます。
        CheckpointDir = checkpointDir,
    };
    // 再開可能なアップロードを実行します。
    client.ResumableUploadObject(request);
    Console.WriteLine("オブジェクト {0} の再開可能なアップロードに成功しました", objectName);
}
catch (OssException ex)
{
    Console.WriteLine("エラーコード: {0}、エラー情報: {1} で失敗しました。 \nRequestID:{2}\tHostID:{3}",
        ex.ErrorCode, ex.Message, ex.RequestId, ex.HostId);
}
catch (Exception ex)
{
    Console.WriteLine("エラー情報: {0} で失敗しました", ex.Message);
}

関連ドキュメント

再開可能なアップロードの完全なサンプルコードについては、GitHub の例をご参照ください。