Resumable upload (C++ SDK) - Object Storage Service - Alibaba Cloud ドキュメントセンター

再開可能なアップロードを使用して Object Storage Service (OSS) にファイルをアップロードする場合、チェックポイントファイルを指定できます。ネットワークエラーやプログラムのクラッシュによってアップロードが中断された場合、プロセスはチェックポイントファイルに記録された位置から再開されます。

注意事項

このトピックでは、中国 (杭州) リージョンのパブリックエンドポイントを使用します。OSS と同じリージョンにある他の Alibaba Cloud サービスから OSS にアクセスする場合は、内部エンドポイントを使用してください。OSS のリージョンとエンドポイントの詳細については、「リージョンとエンドポイント」をご参照ください。
このトピックでは、OSS エンドポイントを使用して OSSClient インスタンスを作成します。カスタムドメイン名または Security Token Service (STS) を使用して OSSClient を作成する場合は、「OssClient インスタンスの作成」をご参照ください。
再開可能なアップロードを実行するには、oss:PutObject 権限が必要です。詳細については、「RAM ユーザーへのカスタムポリシーのアタッチ」をご参照ください。
再開可能なアップロードを使用すると、アップロードの進捗がチェックポイントファイルに記録されます。パートのアップロードに失敗した場合、アップロードはチェックポイントファイルに記録された時点から再開されます。アップロードが完了すると、チェックポイントファイルは削除されます。
チェックポイントファイル内の検証情報は変更しないでください。チェックポイントファイルが破損している場合、すべてのパートが再アップロードされます。
アップロード中にローカルファイルが変更された場合、すべてのパートが再アップロードされます。

実装

client.ResumableUploadObject メソッドを使用して、再開可能なアップロードを実行できます。このメソッドの UploadObjectRequest には、次のパラメーターが含まれています：

パラメーター	説明	必須	デフォルト値	設定方法
bucket	バケット名。	はい	なし	コンストラクターで設定します。
key	OSS にアップロードするファイルの名前。	はい	なし
filePath	アップロードするローカルファイルの名前。	いいえ	なし
partSize	各パートのサイズ。有効値は 100 KB～5 GB です。	いいえ	8 MB	setPartSize を使用します。
threadNum	マルチパートアップロードの同時実行スレッド数。	いいえ	3	コンストラクターで設定するか、setThreadNum を使用します。
checkpointDir	アップロードの進捗を記録するファイル。アップロードが中断された場合、このファイルに記録された時点から再開されます。アップロードが完了すると、ファイルは削除されます。	いいえ	DownloadFile と同じフォルダ。	コンストラクターで設定するか、setCheckpointDir を使用します。

サンプルコード

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

#include <alibabacloud/oss/OssClient.h>
using namespace AlibabaCloud::OSS;

int main(void)
{
    /* OSS アカウント情報を初期化します。*/
            
    /* バケットが所在するリージョンのエンドポイントに yourEndpoint を設定します。たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。*/
    std::string Endpoint = "yourEndpoint";
    /* バケットが所在するリージョンに yourRegion を設定します。たとえば、バケットが中国 (杭州) リージョンにある場合、リージョンを cn-hangzhou に設定します。*/
    std::string Region = "yourRegion";
    /* バケット名を指定します (例: examplebucket)。*/
    std::string BucketName = "examplebucket";
    /* オブジェクトの完全なパスを指定します。完全なパスにバケット名を含めることはできません。例: exampledir/exampleobject.txt */
    std::string ObjectName = "exampledir/exampleobject.txt";
    /* ローカルファイルの完全なパスを指定します (例: D:\\localpath\\examplefile.txt)。ローカルパスを指定しない場合、ファイルはサンプルプログラムが配置されているプロジェクトに対応するローカルパスからアップロードされます。*/
    std::string UploadFilePath = "D:\\localpath\\examplefile.txt";
    /* ローカルパートのアップロード結果を記録するファイル。アップロードの進捗はこのファイルに保存されます。パートのアップロードに失敗した場合、次のアップロード試行はファイルに記録されたブレークポイントから再開されます。アップロードが完了すると、このファイルは削除されます。*/
    /* チェックポイントファイルを保存するディレクトリを設定し、指定したディレクトリが存在することを確認します (例: D:\\local)。この値を設定しない場合、チェックポイント情報は記録されず、再開可能なアップロードは使用されません。*/
    std::string CheckpointFilePath = "D:\\local";

    /* ネットワークおよびその他のリソースを初期化します。*/
    InitializeSdk();

    ClientConfiguration conf;
    conf.signatureVersion = SignatureVersionType::V4;
    /* 環境変数からアクセス認証情報を取得します。このサンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。*/
    auto credentialsProvider = std::make_shared<EnvironmentVariableCredentialsProvider>();
    OssClient client(Endpoint, credentialsProvider, conf);
    client.SetRegion(Region);

    /* 再開可能なアップロードを実行します。*/
    UploadObjectRequest request(BucketName, ObjectName, UploadFilePath, CheckpointFilePath);
    auto outcome = client.ResumableUploadObject(request);

    if (!outcome.isSuccess()) {
        /* 例外を処理します。*/
        std::cout << "ResumableUploadObject fail" <<
        ",code:" << outcome.error().Code() <<
        ",message:" << outcome.error().Message() <<
        ",requestId:" << outcome.error().RequestId() << std::endl;
        return -1;
    }

    /* ネットワークおよびその他のリソースを解放します。*/
    ShutdownSdk();
    return 0;
}

Object Storage Service:Resumable upload (C++ SDK)

注意事項

実装

サンプルコード

関連ドキュメント